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