一. subprocess模块介绍

1. subprocess模块可以替代os模块下的os.system和os.popen等操作方法

2. subprocess模块在python2和python3上的使用上有一定的区别，本文主要介绍的是在python3.6上的使用

3. subprocess模块的作用是执行外部命令(支持同步执行和异步执行)，可以返回执行状态码，也可以返回执行内容

4. subprocess模块的方法有很多，最核心的方法为subprocess.Popen方法，python3中如果只需要同步执行，优先使用subprocess.run方法

二. subprocess.run()方法的介绍

2.1 执行代码：在windows下执行一条cmd命令

#-*- coding:utf-8 -*-#Author:chinablue

importsubprocess#在windows下执行cmd命令：echo hello dj

p = subprocess.run("echo hello dj", shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)print(f'获取返回对象: {p}')print(f'获取执行命令：{p.args}')print(f'获取返回码：{p.returncode}')print(f'获取返回数据：{p.stdout}')

2.2 执行结果：

获取返回对象: CompletedProcess(args='echo hello dj', returncode=0, stdout=b'hello dj\r\n', stderr=b'')

获取执行命令：echo hello dj

获取返回码：0

获取返回数据：b'hello dj\r\n'

2.3 分析小结：

1)subprocess.run()方法是一个同步方法，执行后会返回一个CompletedProcess对象

2)通过管道可以捕获子进程的标准输出(stdout)和标准错误(stderr)

如果使用的是python3.7及以上版本，可以使用capture_output=True参数替换stdout=subprocess.PIPE和stderr=subprocess.PIPE参数

p = subprocess.run("echo hello dj", shell=True, capture_output=True)print(f'获取返回数据：{p.stdout}')#执行结果：获取返回数据：b'hello dj\r\n'

将执行结果输出到一个文件中去

#将命令的执行结果输出到output.txt文件中

with open("output.txt", "w") as f:

p1= subprocess.run("dir", shell=True, stdout=f, universal_newlines=True, encoding="utf-8")

3) 默认情况下，获取的返回数据(stdxxx)为字节类型。

通过universal_newlines=True参数可以让返回数据以文本字符串输出

p = subprocess.run("echo hello dj", shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE, universal_newlines=True)print(f'获取返回数据：{p.stdout}')#运行结果：获取返回数据：hello dj

如果使用的是python3.7及以上版本, 可以使用text=True参数替换universal_newlines=True参数

p= subprocess.run("echo hello dj", shell=True, capture_output=True, text=True)print(f'获取返回数据：{p.stdout}')#运行结果：获取返回数据：hello dj

如果不使用universal_newlines=True参数或text=True参数，我们也可以对p.stdout进行解码转换

p = subprocess.run("echo hello dj", shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)print(f'获取返回数据：{p.stdout.decode("gbk")}') #注意：windows下需要使用gbk解码#运行结果：获取返回数据：hello dj

4) 关于返回状态码的说明

如果命令执行成功，returncode返回0; 如果命令执行失败，returncode返回负值

check=True参数会自动检查p.returncode是否返回0， 如果不是0就抛出subprocess.CalledProcessError异常

p = subprocess.run("echo1", shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE, check=True)print(f'获取返回数据：{p.stdout}')

如果不使用check=True参数，我们可以通过p.returncode来做判断条件, 进而打印出详细错误p.stderr

p = subprocess.run("echo1", shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE, universal_newlines=True)if p.returncode !=0:print(f'命令执行失败：{p.stderr}')

三. subprocess.Popen()方法的介绍

subprocess.run()是通过subprocess.Popen()来实现的

subprocess.Popen()可以异步执行

3.1 执行代码：在windows下执行一条cmd命令

#-*- coding:utf-8 -*-#Author:chinablue

importsubprocess#在windows下执行cmd命令：echo chinablue

p = subprocess.Popen("echo chinablue", shell=True,stdout=subprocess.PIPE, stderr=subprocess.PIPE, universal_newlines=True)print(f"获取返回对象: {p}")print(f"获取pid: {p.pid}")print(f"获取返回数据: {p.stdout.read()}")

p.wait()print(f"获取执行状态: {p.poll()}")

3.2 执行结果:

获取返回对象: 获取pid:5260获取返回数据: chinablue

获取执行状态: 0

3.3 分析小结：

1)subprocess.Popen()方法是一个异步方法，执行后会返回一个Popen对象

2) 获取子进程的标准输出(stdout)和标准错误(stderr)

方式1：通过p.stdout和p.stderr获取，如上例所示

方式2：通过p.communicate()获取，它返回一个元祖，元祖的第1个元素为stdout内容，元祖的第2个元素为stderr内容

p = subprocess.Popen("echo chinablue", shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE, universal_newlines=True)print(f"获取返回数据: {p.communicate()[0]}")print(f"获取返回错误: {p.communicate()[1]}")

3) 获取命令的执行状态：p.poll()

如果执行完subprocess.Popen()方法后，立即获取命令的执行状态, 则返回结果为None，因为此时子进程扔在运行中

如果我们需要等待子进程运行完毕后，再去获取命令的执行状态。那么我们可以使用p.wait()方法，这相当于将默认的异步操作改为同步操作

p = subprocess.Popen("echo chinablue", shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE, universal_newlines=True)print(p.poll()) #运行结果： None

p.wait()print(p.poll()) #运行结果： 0

四. 常见场景举例

场景1：在windows下，执行ipconfig命令并对结果进行过滤

#-*- coding:utf-8 -*-#Author:chinablue

importsubprocess#步骤1：将ipconfig命令的执行结果写入output.txt文件

with open("output.txt", "w") as f:

subprocess.run("ipconfig", shell=True, stdout=f, universal_newlines=True, encoding="utf-8")#步骤2：将p1的输出内容作为p2的输入内容

p1 = subprocess.run("type output.txt", shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE, universal_newlines=True)

p2= subprocess.run("findstr IPv4", shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE, universal_newlines=True, input=p1.stdout)print(p2.stdout)

场景2：在windows下，模拟并发执行命令

#-*- coding:utf-8 -*-#Author:chinablue

importtimeimportsubprocess#模拟一条耗时命令，此命令在windows下执行相当于sleep 2s

cmd = "ping -n 3 127.0.0.1 > nul"start_time=time.time()

p1= subprocess.Popen(cmd, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE, universal_newlines=True)

p2= subprocess.Popen(cmd, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE, universal_newlines=True)

p1.wait()

p2.wait()print(f"运行时间共计：{int(time.time() - start_time)}s")#p1和p2命令执行各需耗时2s，通过并发执行后共计耗时也是2s

场景3：自动处理命令行交互

#-*- coding: utf-8 -*-#@Author : chinablue

importsubprocess#这是一条对视频文件进行处理的命令(改变视频分辨率，同时将视频设置为倍速播放)

cmd = f'ffmpeg -i "dj_xiaomi.mp4" -s vga -filter:v "setpts=0.5*PTS" output.mp4'p= subprocess.Popen(cmd, shell=True, stdin=subprocess.PIPE, stdout=subprocess.PIPE, stderr=subprocess.STDOUT, universal_newlines=True)#命令在执行过程中,如果本地已经存在有output.mp4文件, 那么命令行处会出现提示符: File 'output.mp4' already exists. Overwrite? [y/N]

buff = ''

whileTrue:

output= p.stdout.read(1)ifoutput:

buff+=outputelse:break

#出现提示符([y/N])后,程序可以自行处理此交互行为

if buff.endswith("[y/N]"):

p.communicate(input="y")break

另外python中的pexpect模块更擅长解决命令行的自动交互问题