“messages_ready”从RabbitMQ队列使用Pika

np8igboo  于 8个月前  发布在  RabbitMQ
关注(0)|答案(1)|浏览(62)

我需要知道已经准备好的信息数量。队列有三种类型的消息:1.共计未确认3号,准备好了吗
就绪是指那些在队列中但尚未被消费的。

我目前使用的是requests

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

这里的问题是我必须传递用户名和密码。使用皮卡我相信你可以得到“总”的消息。有没有办法让其他两种类型(unack'd和准备好)使用皮卡?

sxpgvts3

sxpgvts31#

不,AMQP协议不支持获取未确认的消息。您仍然需要使用HTTP API来实现这一点。如果执行被动队列声明,则返回的消息计数是就绪消息的数量。

相关问题