rabbitmq - celery+rabbitmq 空队列

Question

我使用的是celery+rabbitmq。我找不到在 celery+rabbitmq 中清除队列的便捷方法。我通过删除并创建虚拟主机来完成此操作。

rabbitmqctl delete_vhost <vhostpath>
rabbitmqctl  add_vhost <vhostpath>

这是清除 celery 队列的更好方法吗？

Answer 1

我不太确定 celery 是如何工作的，但我怀疑您想清除 RabbitMQ 队列(您当前正在通过删除队列并让 celery 重新创建它们来模拟这一点)。

您可以安装 RabbitMQ 的 Management Plugin 。它的 WebUI 将允许您清除所需的队列。这还应该告诉您您的目标队列，因此您不需要删除所有内容。

一旦您知道它是哪个队列，您就可以以编程方式清除它。例如，使用 py-amqplib ，你会这样做:

from amqplib import client_0_8 as amqp

conn = amqp.Connection(host="localhost:5672", userid="guest", password="guest", virtual_host="/", insist=False)
conn = conn.channel()
conn.queue_purge("the-target-queue")

不过，可能有更好的方法。