Wie kann ich Warteschlangen in einem RabbitMQ-Austausch mithilfe von Python auflisten oder erkennen?

Brauche ich ein python-Programm, das entdecken von Warteschlangen auf einen Neustart RabbitMQ-server, exchange, und starten Sie eine Kunden-zum fortsetzen der Konsum von Nachrichten von jeder Warteschlange. Wie kann ich entdecken, Warteschlangen von einigen RabbitMQ-kompatiblen python-api/library?

InformationsquelleAutor der Frage rschramm | 2010-11-26

  1. 19

    Soweit ich weiß, gibt es keine Möglichkeit dies zu tun. Das ist nichts mit Python, aber da AMQP nicht definieren, eine Methode des queue-Entdeckung.

    In jedem Fall, in der AMQP es ist Kunden (Verbraucher), die erklären Warteschlangen: die Verlage veröffentlichen Sie Nachrichten auf einem exchange mit einem routing-Taste, und die Verbraucher bestimmen, welche Warteschlangen diejenigen, die routing-keys gehen. So macht es keinen Sinn zu reden, Warteschlangen in der Abwesenheit der Verbraucher.

    InformationsquelleAutor der Antwort Daniel Roseman

  2. 37

    Scheint es nicht zu sein, eine direkte AMQP-Weg, um den server zu verwalten, aber es ist ein Weg, können Sie es von Python. Ich würde empfehlen, mit einem Teilprozess - Modul in Kombination mit der rabbitmqctl Befehl zum überprüfen des status der queues.

    Gehe ich davon aus, dass Sie laufen unter Linux. Von einer Befehlszeile ausführen:

    rabbitmqctl list_queues

    Folge:

    Listing queues ...
pings   0
receptions      0
shoveled        0
test1   55199
...done.

    (gut, das Tat es in meinem Fall aufgrund meiner spezifischen queues)

    In Ihrem code, diesen code verwenden, um die Ausgabe von rabbitmqctl:

    import subprocess

proc = subprocess.Popen("/usr/sbin/rabbitmqctl list_queues", shell=True, stdout=subprocess.PIPE)
stdout_value = proc.communicate()[0]
print stdout_value

    Dann kommen Sie einfach mit Ihrem eigenen code analysieren stdout_value für Ihren eigenen Gebrauch.

    InformationsquelleAutor der Antwort IvanD

  3. 14

    Können Sie plugin rabbitmq_management

    sudo /usr/lib/rabbitmq/bin/rabbitmq-plugins enable rabbitmq_management
sudo service rabbitmq-server restart

    Dann verwenden die rest-api

    import requests

def rest_queue_list(user='guest', password='guest', host='localhost', port=15672, virtual_host=None):
    url = 'http://%s:%s/api/queues/%s' % (host, port, virtual_host or '')
    response = requests.get(url, auth=(user, password))
    queues = [q['name'] for q in response.json()]
    return queues

    Ich bin mit Anfragen - Bibliothek in diesem Beispiel, aber es ist nicht signifikant.

    Außerdem fand ich Bibliothek, die es für uns tun - pyrabbit

    from pyrabbit.api import Client
cl = Client('localhost:15672', 'guest', 'guest')
queues = [q['name'] for q in cl.get_queues()]

    InformationsquelleAutor der Antwort Sergey Telminov

  4. 2

    Benutze ich https://github.com/bkjones/pyrabbit. Es spricht direkt zu RabbitMQ - Management-Plug-ins API-Schnittstelle, und ist sehr praktisch für die Befragung RabbitMQ.

    InformationsquelleAutor der Antwort David Lemphers

  5. 2

    Da bin ich ein RabbitMQ-Anfänger, nehmen diese mit einem Körnchen Salz, aber es gibt eine interessante Management-Pluginwelche macht eine HTTP-Schnittstelle, um "von hier Aus können Sie verwalten exchanges, queues, Bindungen, virtuelle hosts, Benutzer und Berechtigungen. Hoffentlich wird das UI ist ziemlich selbsterklärend."

    http://www.rabbitmq.com/blog/2010/09/07/management-plugin-preview-release/

    InformationsquelleAutor der Antwort olleolleolle

  6. 1

    Management-Funktionen sind aufgrund der in einer zukünftigen version von AMQP. So jetzt musst du warten, bis eine neue version kommen wird, die mit dieser Funktionalität.

    InformationsquelleAutor der Antwort mariana soffer

  7. 0

    pyrabbit nicht mehr so gut funktioniert für mich, Aber das Management-Plugin selbst hat seine eigenen Kommandozeilen-Skript, das Sie herunterladen können von Ihrem eigenen admin-GUI und verwenden Sie später (zum Beispiel, die ich heruntergeladen habe mir von

    http://localhost:15672/cli/

    zur lokalen Verwendung)

    InformationsquelleAutor der Antwort diogobaeder

Schreibe einen Kommentar