使用AMQP,Kombu和gevent进行异步消息传递

Mar*_*kov 5 python asynchronous amqp gevent kombu

我试图在python中使用gevents来创建异步kombu消费者.我观看了这个视频https://www.youtube.com/watch?v=nGiBdcIQiMQ应该是它,但它并不完整,那些家伙没有展示他们在开始时所承诺的内容.我也发现这个例子https://github.com/agoragames/haigha/blob/master/examples/gevent_hello.py对我很有用,但我需要使用Kombu来实现它.有人有合并Kombu和gevent的经验.任何工作问候世界的例子都会很棒.顺便说一句,我使用RabbitMQ作为MQ.