私は pika (Python) で RabbitMQ を使用していますが、メッセージが再キューイングされた回数を判断する方法があるかどうか疑問に思っています。
一般的な考え方は、処理しているメッセージが X 回前に拒否/再キューイングされたことをワーカーに伝え、適切なアクションを実行してエラー処理を実行し、アイテムを明示的に削除できるようにすることです。 Y 回の再試行の制限に達した場合、キュー。
メッセージのコピーを作成し、priority プロパティの値をインクリメントする (またはヘッダーの値をインクリメントする) 可能性があることを知っています。次に、コピーをキューに発行し、元のメッセージを確認します (アプローチと同様)。この例を見つけました)、しかし私は明示的にメッセージを nack して再キューイングすることを好みます。
何か案は？