我们正在使用amqplib发布/使用消息。我希望能够读取队列上的消息数量(理想情况下,既已确认又未确认)。这将允许我向管理员用户显示一个漂亮的状态图,并检测某个组件是否跟不上负载。
我在 amqplib 文档中找不到有关读取队列状态的任何信息。
有人可以指出我正确的方向吗?
我们正在使用amqplib发布/使用消息。我希望能够读取队列上的消息数量(理想情况下,既已确认又未确认)。这将允许我向管理员用户显示一个漂亮的状态图,并检测某个组件是否跟不上负载。
我在 amqplib 文档中找不到有关读取队列状态的任何信息。
有人可以指出我正确的方向吗?
使用鼠兔:
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
使用命令行:
$ sudo rabbitmqctl list_queues | grep 'my_queue'
按照 ChillarAnand 的回答,您可以轻松获得价值。数据在对象中。
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(
host='localhost',
port=5672,
credentials=pika.credentials.PlainCredentials('guest', 'guest'),
)
channel = connection.channel()
print(channel.queue_declare(queue="your_queue", durable=True, exclusive=False,
auto_delete=False).method.message_count)
你会得到准确的消息号
使用 Java API,您可以执行以下操作:
channel.queueDeclarePassive(queueName).getMessageCount()
我相信这也适用于 amqplib(根据https://code.google.com/p/py-amqplib/source/browse/amqplib/client_0_8/channel.py#1356似乎queue_declare()
返回一个带有消息计数的元组)
如果您需要更精确的指标(尤其是 nack 消息计数),则需要使用 rabbitmqctl 或 rabbitmq_management。由于它的 HTTP API,Rabbitmq_management 可能是一个不错的选择。更多信息:http ://www.rabbitmq.com/management.html