我们可以用Python在RabbitMQ中创建队列吗
我正在做一个项目,需要通过代码来控制发送队列。所以我很好奇,有没有人用Python/Django代码在RabbitMQ中创建队列呢? :)
2 个回答
3
在AMQP中,你并不是直接创建一个队列,而是要先声明一个队列。如果这个队列还不存在,那么系统就会为你创建一个。
有时候,你只需要在处理消息的程序中声明这个队列就可以了。不过,如果你想要一个持久且可靠的队列,最好是在使用脚本或者在消息发布者中提前声明它。即使消息发布者不对这个队列做任何操作,它仍然可以声明这个队列,以确保来自交换器的消息不会丢失。
5
一般来说,使用Python的客户端应该从Django开始(不过要注意,当你在运行AMQP命令时,可能需要阻止请求)。可以看看RabbitMQ的教程。
至少有三个Python客户端:python-amqplib、pika和puka。
另外,你可能会觉得www.celeryproject.org很有用。