python - 如何将一系列任务路由到 celery 中的特定队列？

Question

当我将任务路由到特定队列时，它会起作用:

task.apply_async(queue='beetroot')

但是如果我创建一个链:

chain = task | task

然后我写

chain.apply_async(queue='beetroot')

它似乎忽略了 queue 关键字并分配给默认的 'celery' 队列。

如果 celery 支持链式路由就好了——所有任务都在同一个队列中按顺序执行。

Answer 1

我是这样做的:

subtask = task.s(*myargs, **mykwargs).set(queue=myqueue)
mychain = celery.chain(subtask, subtask2, ...)
mychain.apply_async()