celery 广播问题

• 请不要在回答技术问题时复制粘贴 AI 生成的内容

This topic created in 2867 days ago, the information mentioned may be changed or developed.

我按官网文档上面的来添加了这段代码在 celery_config 里面

CELERY_QUEUES = (Broadcast(name='broadcast_tasks',),)

#
CELERY_ROUTES = {
    'celery_task.method.get_new_method': {
      'queue': 'broadcast_tasks',
      # 'exchange': Exchange(type='fanout')
    }
}

启动的时候会直接报错

PreconditionFailed: Exchange.declare: (406) PRECONDITION_FAILED - inequivalent arg 'type' for exchange 'broadcast_tasks' in vhost '/': received 'fanout' but current is 'direct'

环境是 py2.7+ celery4.2 + rabbitmq 3.6 是什么原因导致这个问题，搜了 stackoverflow 也没看到有好的解决方法

2 replies • 2019-08-26 17:33:30 +08:00

ray1888

Jul 7, 2018

换了使用在 app 文件中启动前加了如下配置可以启动了，但是现象比较奇怪
```
app.conf.task_queues = (Broadcast('broadcast_tasks'),)
app.conf.task_routes = {
'celery_task.method.get_new_method': {
'queue': 'broadcast_tasks',
'exchange': 'broadcast_tasks'
}
}
```
从 rabbitmq 控制台上面能够看到信息被推进了 broadcast 信道，但是无法被消费

hustlibraco

Aug 26, 2019

@ray1888 我也遇到无法被消费的问题，请问解决了吗