2016-12-09 22 views
0

私はpythonスクリプト(3.5.2)とRabbitMQワーカーキューを使ってデータを処理しています。外部システムのユーザー要求でいっぱいになっているキューがあります。これらのユーザー要求は私のpythonスクリプトによって処理され、各ユーザー要求によっていくつかの出力メッセージが生成されます。私はacknoledge機能を使用して、受信メッセージが処理後にのみ削除されるようにします。これにより、作業者が時折死亡した場合にメッセージが再割り当てされます。しかし、メッセージの送信中に作業者が死亡した場合、このユーザー要求の一部のメッセージはすでにキューに送信されている可能性があり、他のメッセージは送信されない可能性があります。原子的にいくつかのメッセージを送信する方法はありますか? e。すべてのメッセージを送信したかどうかRabbitMQへのメッセージの送信

答えて

0

はい、トランザクションとして要求に応じてすべてのメッセージがラップされます。

+0

複数のメッセージではなくすべての情報を含む1つのメッセージを送信するだけですか? – Stefan

関連する問題