如何按队列名称清除python中的所有rabbitmq

Question

我使用pythonkombu包与rabbitmq服务进行交互。我想清除所有队列。我看到有一个kombu.Queue.purge方法，但我不想创建kombu.Queue对象，因为我不知道哪些交换机连接到哪些队列。我只想使用队列名称。

Answer 1

有一个kombuChannel类实现了一个queue_purge方法，该方法可以清除给定名称的队列。

下面的代码列出了所有队列，并根据它们的名称清除它们。

from kombu import Connection
# Create a connection
mq_conn_string = 'amqp://user:password@domain:port//'  # Set the correct credentials
mq_conn = Connection(mq_conn_string)
mq_conn.connect()
# Create a channel
channel = mq_conn.channel()
# Get all queues
vhost = "/"
manager = mq_conn.get_manager()
queues = manager.get_queues(vhost)
# Purge each queue
for queue in queues:
queue_name = queue["name"]
channel.queue_purge(queue_name)