Celery + RabbitMQ - 使用 Celery 进行简单的消息传递

Question

在我的 Django 项目中，我实现了 Celery，它使用 RabbitMQ 后端运行。

芹菜的作用：

Celery 将我的任务放入队列中，然后在某些条件下运行它们。话虽如此，我基本上只使用Celery python 接口与RabbitMQ 消息队列交互。

问题：

我只想将简单的字符串消息推送到RabbitMQ 队列中，该队列应该由第 3 方应用程序使用。

我尝试了什么：

有一种方法可以使用Pika library 直接连接到RabbitMQ。但是我会觉得它有点笨拙——如果我已经将Celery 连接到RabbitMQ，为什么不使用它（如果可能）将简单消息发送到特定队列，而是使用提到的Pika 库打开另一个连接。

感谢任何见解。

Answer 1

您不能使用 Celery 向您的 RabbitMQ 服务器发送任意消息。

但是，考虑到您已经使用 RabbitMQ 作为代理，这意味着您已经拥有所有必要的 RabbitMQ 支持（py-amqp 直接或通过librabbitmq 支持它），您可以轻松地将消息发送到 MQ 服务器从你的芹菜任务。如果您出于某种原因不喜欢 py-amqp，您可以使用前面提到的 Pika。