大佬教程收集整理的这篇文章主要介绍了获取RabbitMQ队列中的消息数,大佬教程大佬觉得挺不错的,现在分享给大家,也给大家做个参考。
import pika
pika_conn_params = pika.ConnectionParameters(
host='localhost', port=5672,
credentials=pika.credentials.PlainCredentials('guest', 'guest'),
)
connection = pika.blockingConnection(pika_conn_params)
chAnnel = connection.chAnnel()
queue = chAnnel.queue_declare(
queue="your_queue", durable=True,
exclusive=false, auto_delete=false
)
print(queue.method.message_count)
from pyrabbit.API import ClIEnt
cl = ClIEnt('localhost:55672', 'guest', 'guest')
cl.get_messages('example_vhost', 'example_queue')[0]['message_count']
句法:
curl -i -u user:password http://localhost:15672/API/queues/vhost/queue
curl -i -u guest:guest http://localhost:15672/API/queues/%2f/celery
注意:默认虚拟主机是/
需要转义为%2f
$ sudo rabbitmqctl List_queues | grep 'my_queue'
我们正在使用amqplib来发布/使用消息。我希望能够读取队列中的消息数(理想情况下是已确认和未确认)。这将使我能够向管理员用户显示良好的状态图,并检测某个组件是否无法满足负载需求。
我在amqplib文档中找不到有关读取队列状态的任何信息。
有人可以指出我正确的方向吗?
以上是大佬教程为你收集整理的获取RabbitMQ队列中的消息数全部内容,希望文章能够帮你解决获取RabbitMQ队列中的消息数所遇到的程序开发问题。
如果觉得大佬教程网站内容还不错,欢迎将大佬教程推荐给程序员好友。
本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。