在我的Django项目中,我实现了芹菜,它使用RabbitMQ后端运行。你知道吗
Celery
将我的任务放入队列,然后在特定条件下运行它们。也就是说,我基本上只使用Celery
python接口与RabbitMQ
消息队列进行交互。你知道吗
我只想将简单的字符串消息推入RabbitMQ
队列,第三方应用程序应该使用该队列。你知道吗
有一种方法可以使用Pika library直接连接到RabbitMQ
。然而,我会发现它有点笨重-如果我已经Celery
连接到RabbitMQ
,为什么不使用它(如果可能)发送简单的消息到一个特定的队列,而不是使用提到的Pika
库打开另一个连接。你知道吗
感谢您的真知灼见。你知道吗
不能使用芹菜向RabbitMQ服务器发送任意消息。你知道吗
但是,考虑到您已经将RabbitMQ用作代理,这意味着您已经拥有所有必要的RabbitMQ支持(py-amqp直接或通过librabbitmq支持它),您可以轻松地从芹菜任务向MQ服务器发送消息。如果你出于任何原因不喜欢py-amqp,你可以使用你已经提到的Pika。你知道吗
相关问题 更多 >
编程相关推荐