Zamqp. AMQP 브로드 캐스팅 파이썬 및 Zope
지금 다운로드

Zamqp. 순위 및 요약

Zamqp. 태그

메시지 방송 amqp. 방송 메시지 AMQP 방송 트리거 이벤트

Zamqp. 설명

파이썬 및 Zope 용 Amqp 방송 ZAMQP는 AMQP.ZAMQP를 통해 파이썬 인스턴스간에 메시지를 방송하고 트리거합니다. amqplib를 기반으로하며 소비자 및 생산자 구현을 제공하고 Zope 이벤트를 트리거하는 메커니즘을 제공합니다. AMQP 연결을위한 헬기 ClassesScreate 속성. amqpprops >>> props = amqpprops (host = 'localhost', ... user = 'guest', ... password = 'guest', ... ssl = false, ... Exchange = 'zamqp.broadcast.fanout ', ... ='fanout ', ... realm ='/ data ') 수동으로 AMQP 연결을 만듭니다. >>> zamqp 가져 오기 amqpconnection >>> connection = amqpconnection ('zamqp_queue ', props) 액세스 연결 채널. >>> Connection.ChannelConsumer 및 ProduceerCreate 소비자 콜백 (메시지) : ... 패스 # 수신 된 메시지 Herecreate와 함께 무엇이든 하시고 소비자 실을 시작하십시오. >>> Zamqp Import AmqPthread >>> Consumer = AmqPConsumer ( 'ZAMQP_QUEUE', PROP, Callback) >>> 스레드 = amqpthread (소비자) >>> thread.start () 제작자를 만들고 엉망으로 보내십시오. 연령대. 직렬화 가능한 모든 파이썬 객체를 메시지로 사용할 수 있습니다. >>> ZAMQP 가져 오기 amqpproducer에서 >>> 제작자 = amqpproducer ( 'zamqp_queue', props) >>> 메시지 = 'foo'>>> 제작자 (메시지) 트리거 이벤트 create 원격 인스턴스에서 트리거되어야하는 이벤트입니다. >>> Class MyEvent (Object) : ... DEF __Init __ (자체, 이름) : ... self.name = MyEvent의 리스너를 사용합니다. 이것은 AMQP 이벤트가 수신 될 때 호출됩니다. >>> DEF MY_LISTENER (이벤트) : ... iSInstance (이벤트, MyEvent)가 아닌 경우 ... 반환 ... # 뭔가를하십시오 >>> 가져 오기 zope.event >>> zope.event.subscribers.append (my_listener) 기본 AMQPEventCallback은 zope.event.notify를 호출하기 만하면 다음과 같은 수신 된 페이로드를 사용하여 Serialized 이벤트 인 이벤트의 인스턴스입니다. = 'zamqp.events.fanout'>>> Queue = 'zamqp_events'>>> zamqp 가져 오기 amqpeventcallback >>> props = amqpprops (Exchange = Exchange) >>> 콜백 = amqpeventcallback () >>> consumer = amqpconsumer (대기열 , 소품, 콜백) >>> thread = amqpthread (consumer) >>> thread.start () myEvent에서 amqp 채널을 트리거합니다. 이전에 시작된 이벤트 소비자 가이 이벤트를 수신하고 IT 자체 인터프리터에서 로컬로 트리거합니다. >>> zamqp 가져 오기 amqpevent >>> 이벤트 = amqpevent (큐, 소품, MyEvent ( 'myEvent)) >>> zope. 알림 (이벤트) 요구 사항 : · 파이썬

Zamqp. 관련 소프트웨어