 | ザムちゃんPythonとZOPEのAMQP放送 |
| 今すぐダウンロード | |
ザムちゃん ランキングとまとめ
広告
ザムちゃん タグ
ザムちゃん 説明
PythonとZopeのためのAMQP放送 ZAMQPは、AMQP.ZAMQPを介してPythonインスタンス間のイベントをブロードキャーし、ZOPEイベントをトリガーするメカニズムを提供し、ZOPEイベントをトリガーするメカニズムを提供します。AMQP接続のプロパティをrelper classescreateのプロパティを提供します。AMQP接続のプロパティを提供します。>>> AMQPPROPS >>> PROPS = AMQPPROPS（host = 'localhost'、... user = 'guest'、... password = 'guest'、... ssl = false、... Exchange = 'zamqp.broadcast.fanout '、... type =' fanout '、... realm =' / data '）手動でAMQP接続を作成します。>>> zamqp import amqpconnection >>> connection = amqpconnection（' zamqp_queue '、props）アクセス接続チャネル。 >>> Connection.ChannelConsumerとProducErcreateコンシューマコールバック。>>> Def Callback（メッセージ）：... PASS＃受信したメッセージが何でも、消費者のスレッドを起動します。>>> from Zamqp Import AmqpConsumer >>> zamppthread >>>コンシューマ= AMQPCONSUMER（ 'ZAMQP_QUEUE'、PROP、コールバック）>>>スレッド= AMQPTHREAD（コンシューマ）>>> thread.start（）プロデューサを作成して混乱を送る年齢シリアライズ可能なすべてのPythonオブジェクトをメッセージとして使用できます。>>> Zampp Import AmqpProducer >>> Producer = AMQPProducer（ 'zamqp_queue'、props）>>> message = 'foo' >>>プロデューサ（メッセージ）トリガーイベント作成リモートインスタンスでトリガーされるべきイベント>>> Class MyEvent（オブジェクト）：... DEF __init __（self、name）：... self.name = nameCreate MyEventのリスナー。これはAMQPイベントが受信されたときに呼び出されます。>>> def my_listener（イベント）：... iSinstance（イベント、MyEvent）：... Return ...＃何かをする>>>インポートZope.event >>> zope.event.subscriber.append（my_listener）デフォルトのAMQPeventCallbackは、シリアル化されたイベントで、この場合はMyEvent.Startのインスタンスで、イベントのためのAMQPコンシューマのインスタンスでZope.Event.Notifyを呼び出します。>>> Exchange = 'zamqp.events.fanout' >>> queue = 'zamqp_events' >>> amqpeventcallback >>> props = amqpprops（Exchange = Exchange）>>> callback = amqpeventCallback（）>>> consucemer = amqpconsumer（キュー、Props、Callback）>>> thread = amqpthread（コンシューマ）>>> thread.start（）trigger myEventをAMQPチャネルにトリガします。以前に開始されたイベントコンシューマはこのイベントを受け取り、それ自身のインタプリタでそれをローカルにトリガします。通知（イベント）の要件： ・Python
ザムちゃん 関連ソフトウェア
