celery task_routes为什么不是定义echange?

creazyloser
  • 36

我是用的是celery4.3.0,根据官方文档,

from kombu import Exchange, Queue

app.conf.task_queues = (
    Queue('default', Exchange('default'), routing_key='default'),
    Queue('videos',  Exchange('media'),   routing_key='media.video'),
    Queue('images',  Exchange('media'),   routing_key='media.image'),
)
app.conf.task_default_queue = 'default'
app.conf.task_default_exchange_type = 'direct'
app.conf.task_default_routing_key = 'default'

按我的理解,上面是将queues与exchange绑定。下面是为任务指定路由,根据amqp协议,下面不是应该指定exchange吗?为什么是指定queue,既然直接指定了queue,那还要exchange干什么?

task_routes = {
    'myapp.tasks.compress_video': {
        'queue': 'video',    ***#这里为什么要指定queue?***
        'routing_key': 'video.compress',
    },
}
回复
阅读 1.8k
1 个回答
撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
宣传栏