0
Merci d'avance. Je suis nouveau en multitraitement. J'ai créé un processus par le biais duquel je veux consommer les données par le biais de Rabbit MQueue en même temps mais il exécute un processus à la fois.consommateur de lapin multiprocess
def start_consum(queue_name):
channel.basic_consume(func, queue=queue_name)
channel.start_consuming()
def process_start(number):
from multiprocessing import Process
events = ["ev1","ev2","ev3"]
for process in range(number):
for event in events:
proc = Process(target= start_consum(event))
proc.daemon = True
proc.start()
process_start(10)
Dans le code ci-dessus, il commence à consommer le premier événement, puis il commence le deuxième.
merci @shashank – John