Zamqp AMQP-Rundfunk für Python und Zope
Jetzt downloaden

Zamqp Ranking & Zusammenfassung

Zamqp Stichworte

Mitteilungen Rundfunk- AMQP. Broadcast-Nachrichten AMQP-Rundfunk. Ereignisse auslösen

Zamqp Beschreibung

AMQP-Rundfunk für Python und Zope ZAMQP ist darauf abzielen, Nachrichten abzurufen und Ereignisse zwischen Python-Instanzen über AMQP.ZAMQP auszulösen, basiert auf AMQPlib und bietet den Implementierungen der Verbraucher- und Erzeuger sowie einen Mechanismus zur Auslösung von Zope-Ereignissen Remote.Helper-KlassenCreate-Eigenschaften für AMQP-Anschluss. >>> aus Zamqp-Import AMQPPROPS >>> Requisiten = AMQPPROPS (Host = 'localhost', ... User = 'Guest', ... Passwort = 'Gast', ... SSL = FALSE, ... Exchange = 'zamqp.broadcast.anout ', ... type =' Fanout ', ... realm =' / data ') Erstellen von AMQP-Anschluss manuell. >>> von ZAMQP-Import AMQPConnection >>> Anschluss = AMQPConnection (' zamqp_queue ', RequiSconnection (' zamqp_queue ', RequiSt) Zugriff auf Anschlusskanal. >>> connection.channelconsumer und producercreate Consumer Callback. >>> def Callback (Nachricht): >>> Consumer = AMQPConsumer ('Zamqp_Queue', Requisiten, Rückruf) >>> Thread = AMQPTHREAD (Consumer) >>> Thread.start () Erstellen Sie den Produzenten und senden Sie ein Durcheinander Alter Jedes Python-Objekt, das serialisierbar ist, kann als Nachricht verwendet werden. >>> aus Zamqp-Import AMQPProducer >>> Produzent = AMQPProducer ('zamqp_queue', Requisiten) >>> Meldung = 'Foo' >>> Produzent (Nachricht) Trigger EventsCrEate Ein Ereignis, das in der Remote-Instanz ausgelöst werden sollte. >>> Klasse MyEvent (Objekt): ... def __init __ (Selbst, Name): ... self.name = namecreate Ein Zuhörer für myEvent. Dies wird aufgerufen, wenn AMQP-Ereignisse empfangen werden. >>> def my_listener (Ereignis): Zope.Event.subscribers.Append (MY_LISTENER) Der Standard-AMQPEVENTCALLBACK ruft nur ZOUPS.Event.Notify mit der empfangenen Nutzlast an, die das serialisierte Ereignis ist, in diesem Fall ein Beispiel von myEvent.Start Unsere AMQP-Verbraucher für Events. >>> Exchange = 'zamqp.events.anout' >>> Warteschlange = 'zamqp_events' >>> von zamqp Import AMQPeventCallback >>> Requisiten = AMQPPROPS (Exchange = Exchange) >>> Callback = AMQPEVENTCallback () >>> Consumer = AMQPConsumer (Warteschlange) , Requisiten, Rückruf) >>> Thread = AMQPTHREAD (Consumer) >>> Thread.Start () Triggern Sie mich an den AMQP-Kanal. Der zuvor gestartete Ereignis-Verbraucher erhält jetzt dieses Ereignis und löst sie lokal in den eigenen Dolmetscher aus. >>> von Zamqp Import AMQPEVENT >>> Event = AMQPevent (Warteschlange, Requisiten, myEvent ('myEvent')) >>> Zope.Event. Benachrichtigen Sie (Event) Anforderungen: · Python

Zamqp Zugehörige Software