我需要知道已经准备好的信息数量。队列有三种类型的消息: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和准备好)使用皮卡?
1条答案
按热度按时间sxpgvts31#
不,AMQP协议不支持获取未确认的消息。您仍然需要使用HTTP API来实现这一点。如果执行被动队列声明,则返回的消息计数是就绪消息的数量。