如何为芹菜任务选择结果队列

Question

这是我的芹菜配置：

BROKER_TRANSPORT='amqp',
CELERY_RESULT_BACKEND='rpc://',

我正在发送任务以这种方式执行：

result = my_function.apply_async(('arguments here',), queue='queue_123')

芹菜按预期工作，我在"queue_123"中看到此任务。

现在我需要将所有执行结果都排在队列"my_result_queue"。我该怎么做？

Celery 现在创建名称为"19b7013a-a077-3d2a-b60a-d57c51d5d30c"的新队列，并将结果插入其中。我需要修复此行为并将结果插入到具有指定名称的队列中。

我需要这样的东西：

result = my_function.apply_async(('arguments here',), queue='queue_123', results_queue='my_result_queue')

Answer 1

@app.task(reply_to='result_queue)