Как создать новый канал из одного соединения (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?) ...

Заранее спасибо!

0 ответов

Другие вопросы по тегам