2013-10-29 78 views
0

是否可以在apply_async()中設置子任務參數「queue」和「routing_key」。Celery中子任務的自定義路由任務集

在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) 
+0

你可能得到downvoted的「調用API」,因爲它不容易理解你的要求。 – Lycha

回答

2

這是不太清楚是什麼問題。如果您問是否可以將routing_keyqueue參數提供給子任務,則可以使用subtask()而不是s()

subtask DOC:

選項 - 附加選項Task.apply_async()。

0

是的,您可以使用子任務調用中的任何apply_sync參數。

看到docs