如何解决如何通过队列名称清除python中的所有RabbitMQ队列
我使用python kombu
包与Rabbitmq服务进行交互。
我要清除所有队列。我看到有一个kombu.Queue.purge
方法,但是我不想创建kombu.Queue
对象,因为我不知道哪个交换连接到哪个队列。我只想使用队列名称。
解决方法
有一个kombu Channel
类实现了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)
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。