同步AMQP发布

Question

我知道有许多库在python中实现了AMQP支持。不过，我需要的是一个库，它将允许我以同步的方式进行AMQP发布，因为它将从WSGI应用程序中使用，所以通常与队列代理的异步回调驱动的交互方式会有点不合适。

系统的其他部分使用皮卡来支持AMQP，但它是异步的，即使存在某种“阻塞”连接，我也不想使用它。

当然，如果所有其他操作都失败了，则可以为每个WSGI进程维护一个Pika事件循环。另一个问题是，我在目前稳定版的Pika中发现了一些讨厌的bug，我宁愿使用其他的东西。

重申：

• 我需要做basic.publish (与“确认”支持！)这样我才能知道消息何时没有真正发布)
• 以同步的方式
• 对于rabbitmq (显然，“纯”AMQP也可以工作)
• 来自python WSGI应用程序

Answer 1

我的理解是，您可以使用RabbitMQ的RPC进行同步调用。因为你已经准备好了，所以你不应该有太多的努力去收养它。

Answer 2

我建议您查看科姆布，它是芹菜使用的底层库。Kombu和芹菜通常都与Django和Flask (基于Werkzeug的)集成，因此您应该不会有任何问题将它集成到WSGI应用程序中。

Answer 3

您在pika文档站点测试了示例代码吗？

有一节名为:同步编程风格，没有并发http://pika.github.com/communicating.html#synchronous-programming-style-no-concurrency。

看起来，您想要的是一种RPC样式的调用。您可以在以下站点找到一个很好的同步示例：http://www.rabbitmq.com/tutorials/tutorial-six-python.html