Haigha Ereignisgetriebene AMQP-Client-Bibliothek
Jetzt downloaden

Haigha Ranking & Zusammenfassung

Haigha Stichworte

Klient Python-Bibliothek Python AMQP. AMQP-Kunde

Haigha Beschreibung

Ereignisgetriebene AMQP-Client-Bibliothek Haigha ist eine Python-Bibliothek, die eine einfach zu bedienende Clientbibliothek zum Interagieren mit AMQP-Brokern bietet. Es unterstützt derzeit das Protokoll von 0.9.1 und ist integration von den neuesten KaninchenmQ 2.4.1 getestet. Haigha ist ein Nachkomme von Py-Amqplib und schuldet seinen Entwicklern viel. Die Ziele von Haigha sind Leistung, Einfachheit und Einhaltung der Form und Funktion des AMQP-Protokolls. Es fügt ein paar nützliche Funktionen hinzu, z. B. die Channelpool-Klasse und Kanal.Publish_Synchron, um leistungsstarke Funktionen in Real-World-Anwendungen zu erleichtern. Mit Standard-Standard arbeitet Haigha in einem vollständig asynchronen Modus, der sich auf Callbacks setzt, um den Anwendungscode von Antworten zu benachrichtigen der Broker Soweit zutreffend, treffend sind die Standardeinstellungen true. Der Anwendungscode ist herzlich eingeladen, eine Reihe von Methoden aufzurufen, und Haigha verwaltet den Stapel- und synchronisierte Händedruck in der Ereignisschleife. Dies ist eine Vorschau-Version, ohne dass eine vollständige Anteilsabdeckung und -dokumentation und möglicherweise einige Errata fehlt. Es ist jedoch in der Produktionsnutzung und verarbeitet Dutzend GBS pro Tag des Verkehrs. Nachfolgend ist ein einfaches Beispiel eines Clients, der eine Verbindung herstellt, eine Nachricht und Beenden verarbeitet. From Haigha.Connection Import ConnectionFromAufa.Message ImportnachrichtenImport EventConnection = Anschluss (Benutzer = 'Gast', Password = 'Gast', VHOST = '/', host = 'localhost', heartbeat = none, debug = true) def consumer (msg): drucken msg connection.close () Event.TimeOut (2, Event.abort) CH = connection.channel () ch.exchange.declare ( 'test_exchange', 'direkt', auto_delete = true) ch.queue.declare ('test_queue', auto_delete = true) ch.queue.bind ('test_queue', 'test_exchange', 'test_key') ch.basic.conume ( 'test_queue', consumer) ch.basic.publish (Nachricht (Body ', application_header = {' hello ':' World '}),' test_exchange ',' test_key ') Event.Dispatch () Anforderungen: · Python

Haigha Zugehörige Software