Erste Reihe von Nachrichten in einer queue RabbitMQ

Verwenden wir amqplib zu veröffentlichen/konsumieren von Nachrichten. Ich möchte in der Lage sein zu Lesen, die Anzahl der Nachrichten in einer Warteschlange (idealerweise beide bestätigten und unbestätigten). Dies wird mir erlauben, zu zeigen, eine schöne status-Diagramm der admin-Benutzer und-ermitteln, ob eine bestimmte Komponente ist nicht zu halten mit der Last.

Ich kann nicht finden alle Informationen in den amqplib docs zu Lesen, queue status.

Kann mir jemand zeigen in die richtige Richtung?

Überprüfen Sie diese Antwort stackoverflow.com/questions/8192584/...
Danke @mike, das ist weitgehend, was ich am Ende machen, wenn ich hatte zu implementieren, einige dieser in C#. Für die Python-Ansatz, landete ich schlagen Sie den rabbitmq-admin-plugin und Abfragen, statt. In jedem Fall Schätze ich die Zeiger.

InformationsquelleAutor Basic | 2013-05-22

  1. 24

    Mit pika:

    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)

    Mit PyRabbit:

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

    Über HTTP

    Syntax:

    curl -i -u user:password http://localhost:15672/api/queues/vhost/queue

    Beispiel:

    curl -i -u guest:guest http://localhost:15672/api/queues/%2f/celery

    Hinweis: Standard-vhost ist / denen muss entgangen sein, wie %2f

    Über CLI:

    $ sudo rabbitmqctl list_queues | grep 'my_queue'
    Die PyRabbit Lösung ruft eine Nachricht aus der Warteschlange. Ich denke, das Sie verwenden möchten cl.get_queue("example_vhost", "example_queue")['messages'] statt.

    InformationsquelleAutor

  2. 6

    folgenden die Antwort von ChillarAnand Sie können den Wert abrufen, problemlos. die Daten werden in das Objekt.

    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)

    und Sie erhalten die genaue Meldung die Anzahl

    InformationsquelleAutor

  3. 0

    Mithilfe der Java-API, können Sie Folgendes tun : 

    channel.queueDeclarePassive(queueName).getMessageCount()

    Ich glaube, das ist auch mit amqplib (nach https://code.google.com/p/py-amqplib/source/browse/amqplib/client_0_8/channel.py#1356 es scheint, dass queue_declare() gibt ein Tupel mit dem message count)

    Wenn du mehr brauchst genauen Maße (besonders nack message count) verwenden, benötigen Sie rabbitmqctl oder rabbitmq_management. Rabbitmq_management ist wahrscheinlich auch eine gute Wahl wegen seiner HTTP-API. Mehr info : http://www.rabbitmq.com/management.html

    "Q: Mit Python, wie ich..." - "A: Verwendung von Java-Sie..." -> -1
    ab heute Python ist nicht erwähnt in den OP

    InformationsquelleAutor

Schreibe einen Kommentar