Zyrusbus Cyrus-Bus ist ein PUB / SUB-Messaging-System in Python
Jetzt downloaden

Zyrusbus Ranking & Zusammenfassung

Zyrusbus Stichworte

Messaging-System. Messaging Veranstaltung Bus Ereignisbus

Zyrusbus Beschreibung

Cyrus Bus ist ein Pub- / Sub-Messaging-System in Python Cyrusbus ist ein sehr leichter Abonnement- / Veröffentlichungs-Ereignisbus für Python-Anwendungen. Es ist erwähnenswert, dass Cyrusbus 100% unabhängig von anderen Bibliotheken beträgt und 100% von Tests abgedeckt ist. Wenn Sie sehen möchten, wie Sie es verwenden möchten (neben dieser Dokumentation), überprüfen Sie einfach die Tests Cyrusbussthat sollte es sein. Um es installiert zu überprüfen, öffnen Sie den Python-Interpreter und geben Sie den Typ: >>> Kyrusbus importieren >>> Cyrusbus .__ Version __ '0.1.0'using Cyrusbussing Cyrusbus ist so einfach, wie es getan wird. Der Bus in Ihrer Anwendung ist so einfach Neue Instanz des Busses: bus = bus (), dann beginnen Sie mit dem Anruf der nachfolgend erläuterten Methoden, wie dies erläutert wird. Das Screcibesubcripting ermöglicht es Ihnen, von Ereignissen mit dem Bus umzugehen, die den Bus durchlaufen. Sie können Ereignisse mithilfe dieser Syntax abonnieren: Bus.subcribe ("Event.key", Callback) Der erste Parameter ist der Ereignis-Schlüssel, dh wenn jemand ein Ereignis mit demselben Schlüssel veröffentlicht, wird dieses Abonnement ausgelöst. Der zweite Parameter wird ausgelöst. Der zweite Parameter wird ausgelöst. ist die Callback-Funktion. Dies ist die Funktion, die ausgeführt wird, wenn das angegebene Ereignis veröffentlicht wird. Diese Funktion wird mit den Argumenten aufgerufen, die der gesendete Publisher gesendet hat (die Argumente werden ausgepackt). Die Callback-Funktion erhält auch den Bus als erstes Argument. Es sollte dieses Formular haben: def my_callback (Self, Bus, was auch immer, Argumente, Ihre, Funktion, erforderlich): // tut etwas mit den Argumenten. Der Grund dafür ist wegen doppelter Rückrufe zu Ereignissen. Es ist sehr rätselhaft, fehleranfällig und schwer zu verfolgen, wenn der Nachrichtenbus Ihren Rückruf zweimal oder mehr aufruft. Wenn Sie tatsächlich Ihren Rückruf benötigen, um zwei, drei oder n-mal aufzurufen, verwenden Sie die Argumentorm, wie unten erläutert. Sie können auch einen dritten Parameter namens Force angeben. Dieser Parameter ist nützlich, wenn Sie zweimal etwas unterschreiben möchten. Dies bedeutet, dass Cyrusbus Ihre Callback-Methode so oft wie Sie abonnieren wird. Verwenden Sie einfach diese Syntax: Bus.subscribe ("Event.key", Callback, Force = TRUE), um zuzelk, um ein zuvor abonniertes Ereignis abzurufen, um ein zuvor abonniertes Ereignis abzurufen. Alles, was Sie tun müssen, ist ein Anruf an: bus.unsubscribe ('Event.key', Callback) Das Callback-Argument ist erforderlich, damit wir nur Ihren Anruf abbestellen können. Seit beiden Abonnieren und Abbestellen gibt Sie den Bus, den Sie anrufen können: bus.unsubscribe ('Event.key', Callback) .Subscribe ('my_event_reference', Callback), auch wenn dies möglich ist, ist es nicht erforderlich, da abonnieren Sie keine nachfolgenden Anrufe es mit demselben Subjekt und einem Callback.Was, wenn ich alle Abonnenten auf eine bestimmte Veranstaltung abbestellen möchte? Sie rufen Sie einfach an: bus.unsubscribe_all ('event.key') Finden Sie heraus, ob ein Ereignis abonniert ist Dies: bus.has_subscription ('Event.key', Callback) oder wenn Sie wissen möchten, ob das Ereignis Abonnenten verfügt, rufen Sie einfach an: bus.has_any_subscriptions ('Event.key'), beide Rendite true, wenn Abonnenten vorhanden sind Kriterien oder falsch ansonsten.PublishPublishing ist der Prozess, der alle Abonnements in die angegebene Nachricht auslöst. Sie können ein Ereignis mithilfe dieser Syntax veröffentlichen: bus.publish ("event.key", etwas = "Taste", hat = "einige", cool = "Wert"). Der erste Parameter ist der Ereignis-Schlüssel, dh alle Abonnements Zu diesem Schlüssel sollte ausgelöst werden. Die Argumente, die an das Ereignis übergeben werden, sollten als Argumente oder Keyword-Argumente übergeben werden. Der Bus hat den Bus in den Tests sehr nützlich erwiesen. Da es bereits implementiert ist, dokumentieren wir es hier. Das Zurücksetzen des Busses bedeutet, dass es alle Abonnements "vergisst". Sie können den Bus mithilfe dieser Syntax zurücksetzen: bus.reset (); Feature-Anforderung, Vorschläge, Feedbackel, um mit dem Projekt beitragen möchten, auch wenn es nur um etwas nicht umgesetztes Noch nicht umzutreten ist, wenden Sie sich einfach über GitHub oder erstellen Sie ein Problem hier im Repository des Projekts. Anforderungen: · Python

Zyrusbus Zugehörige Software