Celery中子任务的自定义路由任务集

Question

是否可以在apply_async（）中设置子任务参数“queue”和“routing_key”。

在Taskset中需要每个子任务都去自定义队列和routing_key。

的样子：

tasks = [] 
for item in items: 
    tasks.append(task_name.s((params).<method for set custom queue and routing_key>)) 
job = TaskSet(tasks=tasks) 

Answer 1

这是不太清楚是什么问题。如果您问是否可以将routing_key和queue参数提供给子任务，则可以使用subtask()而不是s()。

从subtask DOC：

选项 - 附加选项Task.apply_async（）。

Answer 2

是的，您可以使用子任务调用中的任何apply_sync参数。

看到docs