我正在编写一个 Django 应用程序,我想从 rabbitMQ 读取消息并将一些更改应用到我的数据库中。我的问题是生产者没有使用 celery,我从 celery 收到错误消息,因为消息无效。错误是:
[2017-02-16 08:31:11,416: WARNING/MainProcess] Received and deleted unknown message. Wrong destination?!?
The full contents of the message body was: body: {'value': '4', 'type': 'edit', 'rate': 1} (39b)
我该如何处理?我也试过kombu,但问题是它不像芹菜那么容易;它不能在后台运行,因此很难与 Django 应用程序集成。