celery task_routes为什么不是定义echange？

Question

我是用的是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',
    },
}

Answer 1

您好，我也有同样的疑问，请问您最后找到答案了吗？