Celery + RabbitMQ -使用Celery实现简单的消息传递

Question

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

芹菜的作用：

Celery将我的任务放入队列，然后在特定条件下运行它们。也就是说，我基本上只使用Celery python接口与RabbitMQ消息队列交互。

问题：

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

我尝试过的：

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

任何见解都很感谢。

Answer 1

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

但是，考虑到您已经将RabbitMQ用作代理，这意味着您已经拥有了所有必要的RabbitMQ支持(py-amqp直接支持它，或者通过librabbitmq支持它)，您可以从您的Celery任务轻松地向MQ服务器发送消息。如果你因为任何原因不喜欢py-amqp，你可以使用你已经提到的Pika。