2017-02-14 8 views
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') 

答えて

0

@app.task(reply_to='result_queue)

私はこのようなものが必要

関連する問題