7

Pika ライブラリはトルネード アダプターをサポートしています。非同期アダプターを使用してメッセージを発行する方法の例を次に示します。

トルネードアプリでピカピカを使いたいのですが、例として、トルネードのリクエストデータをRabbitMQに入れたいのですが、やり方がわかりません。

解き方がわからない2問。

1ピカ使用のトルネードアダプターには独自のioloopがあり、

self._connection = pika.SelectConnection(pika.URLParameters(self._url),  
                                         self.on_connection_open)  
self._connection.ioloop.start()

Tornado アプリケーションには独自の ioloop があり、

tornado.ioloop.IOLoop.instance().start()

これら 2 つの ioloop を組み合わせる方法は?

2 Pika の例では同じメッセージが何度も発行されますが、リクエスト データを発行したいのですが、リクエスト データを発行メソッドに渡すにはどうすればよいですか?

4

2 に答える 2