4

我正在尝试使用 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:
        # ....

解决这个问题的正确方法是什么?

4

0 回答 0