是否可以在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)
你可能得到downvoted的「調用API」,因爲它不容易理解你的要求。 – Lycha