我正在编写一个实用程序,它应该充当RabbitMQ
队列的使用者。它检索消息,对它们执行某些操作,然后将它们提交给另一个系统,如f.e.Riemann
或{
现在与RabbitMQ
的通信使用异步SelectConnection
适配器,与输出(Riemann
/Statsd
)的通信使用python-riemann
/pystatsd
客户机(这是阻塞的)。在
我相信我可以通过修改python-riemann
和pystatsd
客户端来提高这个实用程序的整体性能(我必须编写一个),但我的问题是我不确定如何将其与pika的IOLoop
结合起来。在
根据我的理解,我想我可能需要找到一种方法在鼠兔IOLoop
上添加事件侦听器,当Riemann
或{IOLoop
用于线程#1
中的RabbitMQ
的连接,另一个负责线程Riemann
/Statsd
)的输出(Riemann
/Statsd
)。在
所以我的问题是:最好的做法是:多线程这个工具,并在与之交互的每个外部系统中有一个IOLoop
,或者试图找到一种方法也使用pika的IOLoop
来达到它可能没有预期的目的。在
目前没有回答
相关问题 更多 >
编程相关推荐