【问题标题】:Celery - Single AMQP queue bound to multiple exchangesCelery - 绑定到多个交易所的单个 AMQP 队列
【发布时间】:2016-09-13 10:08:53
【问题描述】:

我有一个 RabbitMQ 拓扑(独立于 celery 设置),其队列绑定到两个具有相同路由键的交换。现在,我想设置一个 celery 实例来发布到交易所,另一个从队列中消费。

我对生产者和消费者都有以下问题:

  1. 如果我在启动消费者时仅指定了apply_async 中的交换名称和路由键以及队列名称,是否首先需要设置CELERY_QUEUES?以我对AMQP的理解,这样应该就够了……

  2. 如果有必要,我只能在那里为每个队列设置一个交换。这是否意味着其他绑定将不起作用(生产者无法发布到其他交换,消费者无法接收通过其他交换路由的消息)?或者,无论CELERY_QUEUES 中的绑定如何,我都可以从其他交易所发布和接收消息吗?

【问题讨论】:

    标签: python django rabbitmq celery


    【解决方案1】:

    CELERY_QUEUES 仅用于 celery 与其工作人员的“内部”通信,而不是用于独立于 celery 的 rabbitmq 中的自定义队列。

    你想用同一个队列的两个交换来完成什么?

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 2021-09-18
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2018-03-09
      • 1970-01-01
      • 2012-05-24
      相关资源
      最近更新 更多