ブローカーとしてRabbitMQでCeleryを使用しています。
私のプロジェクトは、長時間実行される一連のタスクグループで構成されます。前の一連のタスクの出力は、次の一連のタスクの入力です。
すべてのワーカーノードは最初に最初のタイプ(グループ)のタスクを消費し、次にすべてのワーカーが次のタイプのタスクを消費し、前の結果を入力などとして順番に消費します。
私の質問は、Celeryで、いくつのキューを定義する必要があるかということです。すべてのタスクに対して1つのキューのみですか?または、タスクの種類ごとに1つのキューを使用する必要がありますか?この場合、1つ以上のキューを使用する利点は何ですか?
前もって感謝します!