我正在尝试使用 Kombu 连接到多个 RabbitMQ 主机,但是,与我发现的其他示例不同,目标不是使用多个主机作为后备,我只想能够处理相同的连接线。
我在 Kombu wiki 上使用连接池遇到了这个示例,但它没有展示如何同时使用两个连接,
from kombu import Connection
from kombu.pools import connections
c1 = Connection('amqp://')
c2 = Connection('redis://')
with connections[c1].acquire(block=True) as conn1:
with connections[c2].acquire(block=True) as conn2:
# ....
解决这个问题的正确方法是什么?