获取 RabbitMQ 队列中的消息数

2022-01-11 00:00:00 python rabbitmq message-queue py-amqplib

问题描述

我们使用 amqplib 来发布/使用消息.我希望能够读取队列上的消息数量(理想情况下，既已确认又未确认).这将允许我向管理员用户显示一个漂亮的状态图，并检测某个组件是否跟不上负载.

We're using amqplib to publish/consume messages. I want to be able to read the number of messages on a queue (ideally both acknowledged and unacknowledged). This will allow me to show a nice status diagram to the admin users and detect if a certain component is not keeping up with the load.

我在 amqplib 文档中找不到任何关于读取队列状态的信息.

I can't find any information in the amqplib docs about reading queue status.

有人能指出正确的方向吗?

Can someone point me in the right direction?

解决方案

使用鼠兔:

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)

使用 PyRabbit:

from pyrabbit.api import Client
cl = Client('localhost:55672', 'guest', 'guest')
cl.get_messages('example_vhost', 'example_queue')[0]['message_count']

使用 HTTP

语法:

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

Note: Default vhost is / which needs to be escaped as %2f

使用 CLI:

$ sudo rabbitmqctl list_queues | grep 'my_queue'

相关文章