3

私は pika 0.9.13 を使用して RabbitMQ に接続する python コードを書いています。多くの子プロセス (潜在的に数千) を作成しており、各プロセスが 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 ?) ...

前もって感謝します !

4

0 に答える 0