admin管理员组文章数量:1635678
Celery:Received and deleted unknown message. Wrong destination?!?
- 北京说明
- 分析策略(小白可跳过)
- 解决方法:
北京说明
我尽量写的简介一点,说一下背景:
celery调用rabbitmq进行消息消费,但是不作为生产者使用;
生产者:java发送(或者其他非celery发起的消息队列形式)
消费者:celery
原来的生产者:apply_async()函数
只发了消息体,发现各种celery消费不了的情况。
分析策略(小白可跳过)
(都是干货)
以下都是各个人的解决方法以及我自己的
1、从github源码处,获取了issue的解决方法1:pip uninstall librabbitmq -- 失败
2、给消息队列接受消息时,将连接从amqp改为pyamqp -- 失败
3、增加一些别的,celery的参数 -- 失败
忘了说了,我得工程是jango起的,不知道非jango有没有遇到这个问题,有的话评论区说一声;
我的分析方法:
从源码中进行日志打印(很气,有些地方加了print就没有任何反应,一启动就自动cancel)
对比celery的启动方式以及celery的消息格式;
给消息格式模拟增加各种参数、headers等;
**最终成果:**
成功
解决方法:
celery必须要指定一个task的headers参数,以提供给celery监控获取消息后,传送到对应的函数位置;
celery会有指定的消息体格式[[消息内容],{},{}],具体分析我没深入了,原因可能是为了回调能获取到参数之类的,不然就会取消celery的启动或者取消消息接收;
如果按照我这里的方法不成功,看看上方提供的其他两个方法
本文标签: deletedreceivedceleryunknowndestination
版权声明:本文标题:Celery:Received and deleted unknown message. Wrong destination?!? 内容由热心网友自发贡献,该文观点仅代表作者本人, 转载请联系作者并注明出处:https://m.elefans.com/dongtai/1729214123a1190217.html, 本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容,一经查实,本站将立刻删除。
发表评论