Überblick

Meine Motivation war, dass ich den Inhalt der Warteschlange "gucken" wollte, um den aktuellen Status der Warteschlange im Dienst anzuzeigen.

Wird über die Web-API abgerufen, um den Inhalt der Warteschlange von Rabbit MQ, einem AMQP-Broker, zu überprüfen. Das ist alles, was Sie mit pika.basic_consume () oder pika.consume () erreichen können. Verwenden Sie jedoch die Verwaltungs-API, um andere Verbraucher nicht zu beeinträchtigen.

Hinweis

Wenn Sie sich die [HTTP-API-Dokumentation] von RabbitMQ (https://cdn.rawgit.com/rabbitmq/rabbitmq-management/rabbitmq_v3_6_0/priv/www/api/index.html) ansehen, können Sie sehen, dass das Element get ist

Please note that the get path in the HTTP API is intended for diagnostics etc - it does not implement reliable delivery and so should be treated as a sysadmin's tool rather than a general API for messaging.

Es kann ein wenig subtil sein, weil es sagt

Funktionsprüfung

Die Funktionsprüfung wurde unten durchgeführt.

CentOS 6.7
Python 2.6.6 (CentOS-Standard) --RabbitMQ 3.6.0 (RPM- und Erlang-Lösungs-Repository auf der RabbitMQ-Site)

Vorbereitung

Verwaltungs-Plugin aktivieren

Das RabbitMQ Management Plugin muss aktiviert sein.

sudo rabbitmq-plugins enable rabbitmq_management

Speichern Sie Nachrichten in der Warteschlange

Senden Sie eine Nachricht zur Bestätigung an die Warteschlange.

`publish.py`


#!/usr/bin/env python
import pika
conn = pika.BlockingConnection(pika.ConnectionParameters())
ch = conn.channel()
ch.queue_declare(queue="hello")
ch.basic_publish(exchange="", routing_key="hello", body="Message 1")
ch.basic_publish(exchange="", routing_key="hello", body="Message 2")
conn.close()

Mit Web-API erhalten

Holen Sie es sich einfach mit httplib.

`view_messages.py`


from base64 import b64encode
import httplib, json

API_HOST = "localhost"  #Hostname des Verbindungsziels
API_PORT = 15672        #Verbindungsport

def view_messages(vhost, queue, count=1):
    #Montage von URI etc.
    uri = "/queues/%(vhost)s/%(queue)s/get" % {"vhost": vhost, "queue": queue}
    auth = "guest:guest"
    headers = {
        "Authorization" : "Basic %s" % b64encode(auth),
        "Content-Type"  : "application/json",
    }
    opt = {"count": count, "requeue": "true", "payload_file": None, "encoding": "auto"}

    #Stellen Sie eine Verbindung zu Rabbit MQ Management her, um Nachrichten zu erhalten
    conn = httplib.HTTPConnection(API_HOST, API_PORT)
    body = json.dumps(opt)
    conn.request("POST", "/api%s" % uri, body, headers)
    response = conn.getresponse()
    return json.loads(response.read())

if __name__ == "__main__":
    msgs = view_messages("%2F", "hello", count=100)
    for msg in msgs:
        print msg["payload"]

Versuch es

Ich werde es versuchen.

./publish.py
./view_messages.py
Message 1
Message 2

Referenz

Is it possible to view RabbitMQ message contents directly from the command line?
- http://stackoverflow.com/questions/10709533/is-it-possible-to-view-rabbitmq-message-contents-directly-from-the-command-line
RabbitMQ Management Plugin
- https://www.rabbitmq.com/management.html

[PYTHON] Zeigen Sie den Inhalt der Warteschlange mithilfe der RabbitMQ Management-Web-API an