首页 文章

为什么CELERY_ROUTES同时具有“队列”和“routing_key”？

提问于
浏览 次
29

我对AMQP的理解是消息只有以下组件：

  • 邮件正文

  • 路由密钥

  • 交流

队列附加到交易所 . 消息不能具有任何队列知识 . 它们只是发布到交换机，然后根据交换类型和路由密钥，消息被路由到一个或多个队列 .

在Celery中，推荐的路由任务方法是通过 CELERY_ROUTES 设置 . 从文档中， CELERY_ROUTES 是......

路由器列表，或用于将任务路由到队列的单个路由器 . http://celery.readthedocs.org/en/latest/configuration.html#message-routing

它包括一个例子......

要将任务路由到feed_tasks队列，可以在CELERY_ROUTES设置中添加条目：CELERY_ROUTES = {
'feeds.tasks.import_feed'：{
'queue'：'feed_tasks'，
'routing_key'：'feed.import'，
}，
}

但是等一下 - 根据AMQP，消息只带有路由密钥！什么是“排队”在那里做什么？

此外，有's this notion of a default queue. If you invoke a task which isn'被 CELERY_ROUTES grab ，它回落到 CELERY_DEFAULT_QUEUE . 但是再次 - 在AMQP中，消息是否是默认的路由密钥而不是？

python celery amqp

2 回答

  • 1

    在那里声明队列的要点是芹菜创建这些队列并使用RabbitMQ设置配置 .

    对于较低级别的AMQP客户端，您需要首先声明队列，然后是交换，然后最终将交换绑定到队列 . 稍后发布消息时，您只需发布到交易所 .

    似乎芹菜使用这种结构自动完成 .

    回复于
  • 16

    确实，在Celery上，当你去Queues时会有一些混乱，你必须记住的一件事是队列参数是指Celery Kombu队列对象而不是直接指向AMQP队列，你可以通过阅读这个来理解这一点extract from the docs . 当然，芹菜创建队列并使用相同名称进行交换的事实是队列参数使用混乱的根源 . 始终在文档中，您可以阅读本段：

    如果您有另一个队列，但在要添加的另一个交换机上，只需指定自定义交换和交换类型：CELERY_QUEUES =（
    队列（'feed_tasks'，routing_key ='feed . ＃'），
    队列（'regular_tasks'，routing_key ='任务 . ＃'），
    队列（'image_tasks'，exchange = Exchange（'mediatasks'，type ='direct'），
    routing_key = 'image.compress'），
    ）

    所以这样你可以在同一个交换机上绑定2个不同的队列 . 在仅使用交换机和密钥路由任务后，您可以使用Routers类

    class MyRouter(object):

    def route_for_task(self, task, args=None, kwargs=None):
        if task == 'myapp.tasks.compress_video':
            return {'exchange': 'video',
                    'exchange_type': 'topic',
                    'routing_key': 'video.compress'}
        return None

    更多这里http://celery.readthedocs.org/en/latest/userguide/routing.html#routers

    回复于

相关问题