关于 celery 的 queue 配置

2019-01-07 15:55:35 +08:00
 fanhaipeng0403
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 ()")

也可以??

  
1096 次点击
所在节点    Python
0 条回复

这是一个专为移动设备优化的页面(即为了让你能够在 Google 搜索结果里秒开这个页面),如果你希望参与 V2EX 社区的讨论,你可以继续到 V2EX 上打开本讨论主题的完整版本。

https://www.v2ex.com/t/524675

V2EX 是创意工作者们的社区,是一个分享自己正在做的有趣事物、交流想法,可以遇见新朋友甚至新机会的地方。

V2EX is a community of developers, designers and creative people.

© 2021 V2EX