"messages_ready" 来自使用 Pika 的 RabbitMQ 队列

Question

我需要获取已准备好的消息数。队列具有三种类型的消息：1. Total 2. Unack'd 3. Ready

Ready是在队列中但还没有消费的。

目前我使用请求

url = "http://<RABBITHOST>:15672/api/queues/%2f/{}".format(q)
res = requests.get(url, auth=("<user>","<password>")).json()
messages_in_queue = res.get("messages_ready")

这里的问题是我必须传入用户名和密码。使用鼠兔我相信你可以获得“总”信息。有什么方法可以使用 Pika 获得其他两种类型（unack'd 和 ready）？

Answer 1

不，AMQP 协议不支持获取未确认的消息。您仍然需要为此使用 HTTP API。如果你做一个被动队列声明，返回的消息计数是就绪消息的数量。

---

_{注意： RabbitMQ 团队监控 rabbitmq-users mailing list 并且有时只在 Whosebug 上回答问题。}