Haigha Gebeurtenisgestuurde AMQP-clientbibliotheek
Download nu

Haigha Rangschikking & Samenvatting

Haigha Tags

cliënt Python-bibliotheek Python Amqp AMQP-client

Haigha Beschrijving

Gebeurtenisgestuurde AMQP-clientbibliotheek Haigha is een Python-bibliotheek die een eenvoudig te gebruiken clientbibliotheek biedt voor het interactie met AMQP-makelaars. Het ondersteunt momenteel het 0.9.1-protocol en is integratie getest tegen de nieuwste Rabbitmq 2.4.1. Haigha is een afstammeling van PY-AMQPLIB en is veel te danken aan haar ontwikkelaars. De doelstellingen van Haigha zijn prestaties, eenvoud en therapietrouw aan het formulier en de functie van het AMQP-protocol. Het voegt een paar handige functies toe, zoals de Channelpool Class en Channel.Publish_Synchrone, om het gebruik van krachtige functies in Real-World-applicaties te vergemakkelijken. Door de standaardinstelling, opereert Haigha in een volledig asynchrone modus, afhankelijk van callbacks om de telefonistencode van antwoorden op te nemen de makelaar. Waar van toepassing, is er ook standaard in staat. De applicatecode is van harte welkom om een reeks methoden te bellen en Haigha zal de stapel en synchrone handdrukken in de gebeurtenislus beheren. Dit is een preview-release, ontbreekt aan de dekking en documentatie van de volledige eenheid en mogelijk, en mogelijk sommige Errata. Het is echter in productie-gebruik en verwerkt tientallen van GBS per dag van verkeer.InstallatiePip-installatie -r-vereisten.txtexamplesee De scriptsirectory voor verschillende voorbeelden, met name het stress_test-script dat u kunt gebruiken om de prestaties van Haigha tegen uw makelaar te testen. Hieronder is een eenvoudig voorbeeld van een client die verbinding maakt, verwerkt één bericht en quits.from HAIGHA.CONNECTION IMPORTUITSINGFROM HAIGHA.MESSAGE IMPORT MESSIMEIMPORT EVENCONNECTIE = Aansluiting (gebruiker = 'gast', wachtwoord = 'gasten', vhost = '/', host = 'localhost', heartbeat = geen, debug = true) Def Consumer (MSG): afdrukken MSG-verbinding. Close () Event.Timeout (2, event.abort) ch = verbinding.Channel () CH.Exchange.declare ( 'Test_exchange', 'Direct', auto_delete = true) ch.queue.declare ('Test_Quue', auto_delete = true) ch.queue.bind ('Test_Quue', 'Test_exchange', 'Test_key') ch.basic.consume ( 'Test_Quue', consument) ch.basic.publish (bericht ('lichaam', applicatie_headers = {'hallo': 'World'}), 'Test_Exchange', 'Test_Key') Event.Dispatch () Vereisten: · Python

Haigha Gerelateerde software