python - 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().

从子任务文档：

options -- Task.apply_async() 的附加选项。

Answer 2

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

请参阅文档中的“调用 API”