Cyrusbus. Cyrus Bus è un sistema di messaggistica PUB / SUB in Python
Scarica ora

Cyrusbus. Classifica e riepilogo

Cyrusbus. Tag

Sistema di messaggistica messaggistica evento autobus bus evento

Cyrusbus. Descrizione

Cyrus Bus è un sistema di messaggistica PUB / SUB in Python CYRUSBUS è un autobus di eventi di pubblicazione / pubblicazione molto leggero per applicazioni Python. Vale la pena notare che Cyrusbus è indipendente dal 100% da altre biblioteche ed è coperta al 100% da test. Se vuoi vedere come usarlo (oltre a questa documentazione) basta controllare i test. Installare CyrusBusyou può installare CyrusBus da PYPI (http://pypi.python.org/pypi), utilizzando Easy_Install o PIP :: PIP Installa Cyrusbus Easy_Install CyrusBusthat dovrebbe essere. Per verificare che sia installato, aprire l'interprete di Python e digitare: >>> import cyrusbus >>> cyrusbus .__ Versione __ '0.1.0'Useling CyrusBusUSUSINUS CyrusBus è facile come Gets.import the Bus nella tua applicazione: da Cyrusbus Import Buscreate A Nuova istanza del bus: Bus = Bus () quindi inizia a chiamare i metodi come spiegato di seguito.SubscribeSubscribeing è ciò che consente di gestire eventi che attraversano il bus. È possibile iscriversi agli eventi utilizzando questa sintassi: bus.subsscribe ("event.key", richiamata) Il primo parametro è il tasto evento, il che significa che quando qualcuno pubblica un evento con lo stesso tasto, questo abbonamento verrà attivato. Il secondo parametro verrà attivato. è la funzione di callback. Questa è la funzione che verrà eseguita quando viene pubblicato l'evento dato. Questa funzione verrà chiamata con qualsiasi argomento inviato l'editore (gli argomenti saranno disimballati). La funzione di callback riceverà anche il bus come primo argomento. Dovrebbe avere questa forma: def my_callback (sé, bus, qualsiasi altra cosa, argomenti, la tua, funzione, richiede): // fa qualcosa con gli argomenti.Warningif chiamando Iscriviti due volte con la stessa callback, CyrusBus ignorerà la seconda chiamata. Il motivo per questo è a causa di duplicati callback agli eventi. È molto sconcertante, improprio e difficile da tracciare quando il bus del messaggio chiama il callback due o più. Se hai effettivamente bisogno che il tuo callback sia chiamato due, tre o n volte, usa la forza dell'argomento, come spiegato di seguito. Puoi anche fornire un terzo parametro chiamato Forza. Questo parametro è utile se si desidera sottoscrivere qualcosa due volte. Ciò significa che CyrusBus chiamerà il tuo metodo di callback tutte le volte che ti iscrivi. Basta usare questa sintassi: bus.subscribe ("event.key", callback, force = true) unsubscriscriscribein Ordine per annullare l'iscrizione a un evento precedentemente sottoscritto, tutto ciò che devi fare è chiamare: bus.unsubscribe ('event.key', Richiamata) È necessario l'argomento di callback in modo da poter annullare l'iscrizione solo la chiamata. Dal momento che sia iscriviti che annulla l'iscrizione restituire il bus che puoi chiamare: bus.unsubscribe ('event.key', callback) .subscribe ('my_event_reference', callback) Anche se questo è possibile, non è necessario come sottoscrizione ignorerà le chiamate successive Con lo stesso soggetto e callback. Quali se voglio annullare l'iscrizione a tutti gli abbonati a un determinato evento? Hai appena chiamato: Bus.unsubScribe_all ('Event.Key') Scopri se un evento è stato sottoscritto è stato sottoscritto in un evento (fare riferimento a Iscriviti per ulteriori dettagli), puoi scoprire se l'abbonamento è attivo utilizzando Has_Subscription, come Questo: bus.has_subscription ('event.key', richiamata) o se vuoi sapere se l'evento ha qualche abbonati, basta chiamare: bus.has_any_subscriptions ('event.key') entrambi restituiscono true se ci sono abbonati che soddisfano il criteri o falsi altrimenti.PublishPublishing è il processo che attiva tutti gli abbonamenti al messaggio specificato. Puoi pubblicare un evento usando questa sintassi: bus.publish ("event.key", alcuni = "tasto", ha = "alcuni", cool = "valore"); il primo parametro è il tasto evento, il che significa che tutti gli abbonamenti A tal chiave dovrebbe essere attivato. Gli argomenti che verranno passati all'evento dovrebbero essere passati come argomenti o argomenti di parole chiave. Processoresesettare l'autobus si è dimostrato molto utile nei test. Dal momento che è già implementato, lo documendiamo qui. Ripristino del bus significa "dimentica" tutti gli abbonamenti. È possibile ripristinare l'autobus utilizzando questa sintassi: Bus.reset (); Richiesta di funzionalità, suggerimenti, feedback Se vuoi contribuire con il progetto, anche se è solo per chiedere ancora qualcosa non implementato, basta contattarmi attraverso GitHub o creare un problema qui nel repository del progetto. Requisiti: · Python.

Cyrusbus. Software correlato