Kombu を使用したメッセージ パッシング システムの構築に取り組んでいますが、次の問題が発生しました。ルーティング キー 'x' と 'y' にルーティングされているメッセージがあるとします。これは、「x」と「y」の間に依存関係がない状況でうまく機能します。
ただし、ルーティング キー 'a'、'b'、および 'c' にデータを送信し、単一のキューがそれらのルーティング キーからメッセージを取得している別の状況を考えてみましょう。単一のコールバックを処理するために a、b、および c からのデータが一緒に必要な場合、これらのメッセージを単一のワーカー ドレインに集約する方法はありますか?それとも、これはメッセージ パッシング パラダイムの完全な粗悪品ですか?
メッセージを別の場所 (Redis など) にキャッシュし、必要なデータがある場合にのみ処理できることはわかっていますが、データをキャッシュして毎回ワーカーを起動することなく、Kombu がこれを実行できるかどうか疑問に思っています。ご提案ありがとうございます。役立つ場合は、コード例をいくつか挙げることができます。