Как создать новый канал из одного соединения (pika/rabbitmq)?
Я пишу код на Python, используя pika 0.9.13 для подключения к RabbitMQ. Я создаю много дочерних процессов (потенциально 1000) и хочу, чтобы каждый процесс мог отправлять их в RabbitMQ. Читая вокруг, кажется, что лучший способ - создать одно соединение, а затем создать каналы внутри этого соединения.
Кто-нибудь может посоветовать, как лучше всего это сделать? Обычно код будет выглядеть так:
from multiprocessing import Process
def f(connection):
# pass the pika connection somehow ...
# create the channel ...
channel = connection.channel()
# .... rest of process code
if __name__ == '__main__':
#
# pika code here to establish the MQ connection ...
# connection = ....
p = Process(target=f, args=(connection,))
p.start()
Какой тип адаптера я должен использовать (BlockingConnection?) ...
Заранее спасибо!