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://www.elefans.com/dongtai/1729214123a1190217.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。