私は 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 ?) ...
前もって感謝します !