zamqp. transmissor de amqp para python e zope
Baixe Agora

zamqp. Classificação e resumo

zamqp. Tag

mensagens transmissão Amqp. mensagens de difusão Broadcasting AMQP. acionar eventos

zamqp. Descrição

AMQP Broadcasting for Python e Zope A Zamqp tem como objetivo transmitir mensagens e eventos de disparo entre os casos de Python via AMQP.ZAMQP, é baseado na amqplib e fornece implementações de consumidores e produtores, bem como um mecanismo para acionar eventos do Zope remotamente.Helper ClassesCreate Properties para conexão AMQP. >>> da Importação do Zamqp Amqpprops >>> props = amqpprops (host = 'localhost', ... user = 'convidado', ... Senha = 'convidado', ... SSL = Falso, ... Exchange = 'zamqp.broadcast.fanout ', ... tipo =' fanout ', ... Realm =' / Data ') Criar conexão AMQP manualmente. >>> De Zamqp Importar AMQPConnection >>> Conexão = AMQPConnection (' zamqp_queue ', adere) acesso de conexão de acesso. >>> Conexão.Canela Callback do consumidor. >>> Def ClOback (mensagem): ... PASS # Faça qualquer coisa com a mensagem recebida Herecreate e iniciar o segmento do consumidor. >>> do Zamqp Import AMQPConsumer >>> da Zamqp Import AMQtThread >>> consumidor = amqpconsumer ('zamqp_queue', adereços, retorno) >>> thread = amqthread (consumidor) >>> thread.start () crie produtor e enviar uma bagunça Idade. Cada objeto Python que é serializável pode ser usado como uma mensagem. >>> do Zamqp Import AMQPProducer >>> Produtor = AMQPPRODUCER ('Zamqp_Queue', Adereços) >>> Mensagem = 'FOO' >>> Produtor (mensagem) TriggerCreate Um evento que deve ser acionado na instância remota. >>> Classe MyEvent (objeto): ... def __init __ (auto, nome): ... auto.name = namecreate um ouvinte para myEvent. Isso é chamado quando os eventos AMQP são recebidos. >>> Def my_listener (evento): ... se não é, ISINSTANSCE (evento, myEvent): ... voltar ... # fazer algo >>> Import Zope.Event >>> Zope.Event.subscribers.apend (my_listener) o padrão amqpeventcallback apenas chama Zope.Event.Notify com a carga útil recebida, que é o evento serializado, neste caso uma instância de myevent.start Nosso consumidor AMQP para eventos. >>> troca = 'zamqp.events.fanout' >>> fila = 'zamqp_events' >>> do Zamqp Import AMQPeventCallback >>> Props = amqpprops (Exchange = Exchange) >>> Callback = AmqPeventCallback () >>> consumidor = amqpconsumer (fila , adereços, callback) >>> Thread = amqthread (consumidor) >>> thread.start () acione myEvent no canal AMQP. O consumidor de eventos anteriormente iniciado agora recebe este evento e desencadeia localmente em seu próprio intérprete. >>> do zamqp Import amqpevent >>> evento = amqpevent (fila, adereços, myEvent ('myEvent')) >>> zope.event. Notificar (evento) Requisitos: · Pitão

zamqp. Software Relacionado