如何为 celery 任务选择结果队列？答案

【问题标题】：How to choose result queue for celery task?如何为 celery 任务选择结果队列？
【发布时间】：2017-02-14 07:53:15
【问题描述】：

这是我的芹菜配置：

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

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

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

Celery 按预期工作，我在“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')

【问题讨论】：

【解决方案1】：

@app.task(reply_to='result_queue)

【讨论】：