在python（pika库）中并行运行代码

Posted 2021-05-04

我有一个pika接收器，可以接收命令并执行另一个python脚本。问题是我无法作为多进程或线程并行运行脚本。如果我通过mqtt协议收到命令，它将等待直到完成“ make.py”功能以再次执行它。我希望它可以并行运行。有人可以帮忙吗？

def call_mkdt(ch, method, properties, body):
    os.system(f"make.py {body}")


def consume():
    channel.basic_consume(queue='UploadCompleted', on_message_callback=call_mkdt, auto_ack=True)
    print(' [*] ETL')
    try:
        channel.start_consuming()
    except KeyboardInterrupt:
        channel.stop_consuming()

if __name__== "__main__":
    p1 = threading.Thread(name="Hello1", target=consume)
    p1.start()

答案

我想您不想等待make.py完成执行，您可以从python的subprocess.Popen模块中使用subprocess函数。

您可以在Popen处参考有关docs功能的更多信息>

替换：

def call_mkdt(ch, method, properties, body):
    os.system(f"make.py {body}")
With：

import subprocess

def call_mkdt(ch, method, properties, body):
    subprocess.Popen(["make.py", f"{body}"])