北京说明

我尽量写的简介一点，说一下背景：
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的启动或者取消消息接收；

如果按照我这里的方法不成功，看看上方提供的其他两个方法

Celery:Received and deleted unknown message. Wrong destination?!?相关推荐

puppet 认证错误:Could not request certificate: unknown message digest algorithm
puppet 认证错误:Could not request certificate: unknown message digest algorithm 错误描述: 工作期间接收到同事提出来的问题(pu ...
flexray unknown message
当起始帧中ml参数为0时,表示message为unknown message,此时发送段需要通过actuallength来判断数据是否发送完毕.
celery java_Celery详解
Celery详解 1.背景由于从事区块链钱包相关开发,对于区块链链上资源需要频繁的进行检查同步,在flask项目中,对于celery这个异步任务执行工具,使用的频率算是相当的高,今天,我就来简单总结 ...
Message Bus - 消息总线
Message Bus - 消息总线 Liferay的*消息总线(Message Bus)*是一种服务级API,组件可以用它来发送和接收消息.它提供了消息生产者(producers)和消费者(cons ...
delphi控件使用
Standard页 1- Tlistbox控件重要属性items.* 举例,界面设计如下左,执行结果如下右: 代码为 procedure TForm1.Button1Click(Sende ...
openvswitch 2.3.1 配置详解
<?xml version="1.0" encoding="utf-8"?> <database title="Open vSwit ...
CAN201-Computer Network(2)
文章目录 5. Control Plane 5.1 Routing protocols: Dijkstra 5.2 Routing protocols: Distance vector algorit ...
Objective-C错误码
NSMachErrorDomain 头文件目录:/usr/include/mach/kern_return.h #define KERN_SUCCESS 0#define KERN_INVALID_A ...
Mysql：命令选项、配置选项、（全局、会话）系统变量、状态变量：命令选项...
Server Command Options --help, -? Command Line Format -? Config File Format help Display a short hel ...

Celery:Received and deleted unknown message. Wrong destination?!?

Celery:Received and deleted unknown message. Wrong destination?!?

北京说明

分析策略（小白可跳过）

解决方法：

Celery:Received and deleted unknown message. Wrong destination?!?相关推荐

最新文章

热门文章