celery 里面有个配置时,当指定队列不存在时,创建队列
task_create_missing_queues
Default: Enabled
这么使 foo.apply_async(args=(ds.id,), queue="xxxx")
我想问这个配置和 conf 里配置的
CELERY_QUEUES = (
Queue('xxxx', Exchange('xxxx'), routing_key='xxxx'),
)
有什么区别么
比如我有很多任务,之前解决这个问题,是把不同的任务分配到定义在 conf 里的不同队列
是不是我不用显示定义,分配任务的时候 foo.apply_async(args=(ds.id,), queue="random ()")
也可以??