0
미리 감사드립니다. 다중 처리에서 새로운 점이 있습니다. 나는 토끼풀 MQueue를 동시에 소비하지만, 한 번에 하나의 프로세스 만 실행하는 프로세스를 만들었습니다.다중 처리 토끼 소비자
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)
위 코드에서 첫 번째 이벤트를 소비 한 다음 두 번째 이벤트가 시작됩니다.
감사합니다. @shashank – John