python - 如何按队列名称清除python中的所有rabbitmq队列
问题描述
我使用 pythonkombu
包与 rabbitmq 服务进行交互。我想清除所有队列。我看到有一种kombu.Queue.purge
方法,但我不想创建kombu.Queue
对象,因为我不知道哪些交换连接到哪些队列。我只想使用队列名称。
解决方案
有一个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)
推荐阅读
- xcode - 在模拟器中测试丰富的通知
- flutter - 我想知道为什么这个按钮不起作用。我的代码错了吗?
- docker - K8s - 不同命名空间中 pod 之间的 DNS 解析
- python-3.x - 如何在python中用for循环制作三角形
- python - Newbee 使用类和数据框
- javascript - 如何在我的代码中停止无限循环?
- string - 如何在 Dart 中替换字符串中除空格字符之外的所有字符
- ocaml - Ocaml Cmliner 如何在两组可能的参数之间进行选择
- javascript - 试图理解 JS 承诺消除竞争条件
- javascript - 如何从 chrome 网络接口 API 中提取 IP 地址?