0
は私のセロリの設定です:セロリタスクの結果キューを選択する方法は?ここ
BROKER_TRANSPORT='amqp',
CELERY_RESULT_BACKEND='rpc://',
私はこの方法を実行するためにタスクを送信しています:予想通り
result = my_function.apply_async(('arguments here',), queue='queue_123')
セロリは動作しますが、私は「queue_123」でこのタスクを参照してください。
これで、実行結果をすべて「my_result_queue」にする必要があります。どうしたらいいですか?
セロリーは "19b7013a-a077-3d2a-b60a-d57c51d5d30c"のような名前の新しいキューを作成し、結果を挿入します。この動作を修正し、結果を指定された名前のキューに挿入する必要があります。
result = my_function.apply_async(('arguments here',), queue='queue_123', results_queue='my_result_queue')