我知道有许多库在 python 中实现 AMQP 支持。不过,我需要的是一个库,它允许我以同步方式进行 AMQP 发布,因为它将在 WSGI 应用程序中使用,因此与队列代理交互的通常异步回调驱动方式将是那里有点格格不入。
系统的其他部分使用pika来支持 AMQP,但它是异步的,即使那里存在某种“阻塞”连接,我也不想使用它。
当然,如果所有其他方法都失败了,则可以为每个 WSGI 进程维护一个 Pika 事件循环。另一个问题是我在当前稳定版本的 Pika 中发现了一些令人讨厌的 (IMO) 错误,我宁愿使用其他东西。
重申:
- 我需要做 basic.publish (有“确认”支持!这样我就知道消息什么时候没有真正发布)
- 以同步方式
- 对于 rabbitmq(显然,“纯”AMQP 也可以工作)
- 来自 python WSGI 应用程序