Python模块-subprocess模块

Run()方法

>>> a = subprocess.run(['df','-h'])
文件系统        容量  已用  可用 已用% 挂载点
udev            468M     0  468M    0% /dev
tmpfs            98M  7.4M   91M    8% /run
/dev/sda1        39G  5.0G   32G   14% /
tmpfs           488M  216K  488M    1% /dev/shm
tmpfs           5.0M  4.0K  5.0M    1% /run/lock
tmpfs           488M     0  488M    0% /sys/fs/cgroup
tmpfs            98M   84K   98M    1% /run/user/1000
>>> a
CompletedProcess(args=['df', '-h'], returncode=0)
>>> a.returncode  # 获取命令执行结果的状态码
0
>>> a.args  # 获取命令参数列表
['df', '-h']

 直接把命令按照列表传入

 如果想要读取命令执行的结果和错误，需要通过管道

>>> a = subprocess.run(['df','-h'],stdout=subprocess.PIPE,stderr=subprocess.PIPE)
>>> a.stdout  # 如果命令执行成功就能读出执行结果
b'xe6x96x87xe4xbbxb6xe7xb3xbbxe7xbbx9f        xe5xaexb9xe9x87x8f  xe5xb7xb2xe7x94xa8  xe5x8fxafxe7x94xa8 xe5xb7xb2xe7x94xa8% xe6x8cx82xe8xbdxbdxe7x82xb9
udev            468M     0  468M    0% /dev
tmpfs            98M  7.4M   91M    8% /run
/dev/sda1        39G  5.0G   32G   14% /
tmpfs           488M  216K  488M    1% /dev/shm
tmpfs           5.0M  4.0K  5.0M    1% /run/lock
tmpfs           488M     0  488M    0% /sys/fs/cgroup
tmpfs            98M   84K   98M    1% /run/user/1000
'
>>> a.stdout.decode()
'文件系统        容量  已用  可用 已用% 挂载点
udev            468M     0  468M    0% /dev
tmpfs            98M  7.4M   91M    8% /run
/dev/sda1        39G  5.0G   32G   14% /
tmpfs           488M  216K  488M    1% /dev/shm
tmpfs           5.0M  4.0K  5.0M    1% /run/lock
tmpfs           488M     0  488M    0% /sys/fs/cgroup
tmpfs            98M   84K   98M    1% /run/user/1000
'
>>> a.stderr  # 如果命令执行成功，读取的错误就为空
b''
>>> a = subprocess.run(['df','-asdh'],stdout=subprocess.PIPE,stderr=subprocess.PIPE)
>>> a.stdout.decode()  # 如果命令执行错误，读出来的执行结果就为空
''
>>> a.stderr  # 如果命令执行错误，就能读出错误的内容
b"dfxefxbcx9axe6x97xa0xe6x95x88xe9x80x89xe9xa1xb9 -- s
Try 'df --help' for more information.
"
>>> a.stderr.decode()
"df：无效选项 -- s
Try 'df --help' for more information.
"

 stdout=subprocess.PIPE为命令执行成功返回的内容

 stderr=subprocess.PIPE为命令执行错误返回的错误内容

 因为执行一条命令就会打开一个进程，进程间数据不能通信，所以操作系统对stdout、stderr的结果进行读取，再传给程序

 subprocess.run()方法执行命令时，如果命令是错的，程序不会报错而继续运行，如果要命令错的时候程序报错停止运行的话，可以加个check参数

 check参数设置为True的时候就会检查命令是否是错的

>>> a = subprocess.run(['df','-asdh'],stdout=subprocess.PIPE,stderr=subprocess.PIPE)
>>> a.stderr.decode()
"df：无效选项 -- s
Try 'df --help' for more information.
"
>>> a = subprocess.run(['df','-asdh'],stdout=subprocess.PIPE,stderr=subprocess.PIPE,check=True)
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
  File "/usr/lib/python3.5/subprocess.py", line 708, in run
    output=stdout, stderr=stderr)
subprocess.CalledProcessError: Command '['df', '-asdh']' returned non-zero exit status 1

 执行带有管道符的命令

>>> a = subprocess.run('df -h |grep sda1',stdout=subprocess.PIPE,stderr=subprocess.PIPE,shell=True)
>>> a
CompletedProcess(args='df -h |grep sda1', returncode=0, stdout=b'/dev/sda1        39G  5.0G   32G   14% /
', stderr=b'')

Call()方法

 执行命令，返回命令执行状态

>>> retcode = subprocess.call(['df', '-h'])
文件系统        容量  已用  可用 已用% 挂载点
udev            468M     0  468M    0% /dev
tmpfs            98M  7.4M   91M    8% /run
/dev/sda1        39G  5.0G   32G   14% /
tmpfs           488M  216K  488M    1% /dev/shm
tmpfs           5.0M  4.0K  5.0M    1% /run/lock
tmpfs           488M     0  488M    0% /sys/fs/cgroup
tmpfs            98M   84K   98M    1% /run/user/1000
>>> retcode
0

 执行命令，如果命令执行状态为0，就正常返回，否则抛异常

>>> subprocess.check_call(['df', '-h'])
文件系统        容量  已用  可用 已用% 挂载点
udev            468M     0  468M    0% /dev
tmpfs            98M  7.4M   91M    8% /run
/dev/sda1        39G  5.0G   32G   14% /
tmpfs           488M  216K  488M    1% /dev/shm
tmpfs           5.0M  4.0K  5.0M    1% /run/lock
tmpfs           488M     0  488M    0% /sys/fs/cgroup
tmpfs            98M   84K   98M    1% /run/user/1000
0
>>> subprocess.check_call(['df', '-ash'])
df：无效选项 -- s
Try 'df --help' for more information.
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
  File "/usr/lib/python3.5/subprocess.py", line 581, in check_call
    raise CalledProcessError(retcode, cmd)
subprocess.CalledProcessError: Command '['df', '-ash']' returned non-zero exit status 1

 接收字符串格式命令，返回元组形式，第1个元素是执行状态，第2个是命令结果

>>> subprocess.getstatusoutput('whoami')
(0, 'sch01ar')

 接收字符串格式命令，并返回结果

>>> subprocess.getoutput('whoami')
'sch01ar'

 执行命令，并返回结果

>>> subprocess.check_output(['df','-h']).decode()
'文件系统        容量  已用  可用 已用% 挂载点
udev            468M     0  468M    0% /dev
tmpfs            98M  7.4M   91M    8% /run
/dev/sda1        39G  5.0G   32G   14% /
tmpfs           488M  216K  488M    1% /dev/shm
tmpfs           5.0M  4.0K  5.0M    1% /run/lock
tmpfs           488M     0  488M    0% /sys/fs/cgroup
tmpfs            98M   84K   98M    1% /run/user/1000
'
>>> a = subprocess.check_output(['df','-h']).decode()
>>> a
'文件系统        容量  已用  可用 已用% 挂载点
udev            468M     0  468M    0% /dev
tmpfs            98M  7.4M   91M    8% /run
/dev/sda1        39G  5.0G   32G   14% /
tmpfs           488M  216K  488M    1% /dev/shm
tmpfs           5.0M  4.0K  5.0M    1% /run/lock
tmpfs           488M     0  488M    0% /sys/fs/cgroup
tmpfs            98M   84K   98M    1% /run/user/1000
'

Popen()方法

popen()方法执行命令的进程和主程序的进程为并行

>>> subprocess.run(['sleep','10'],stdout=subprocess.PIPE,stderr=subprocess.PIPE)
CompletedProcess(args=['sleep', '10'], returncode=0, stdout=b'', stderr=b'')
>>> subprocess.Popen(['sleep','10'],stdout=subprocess.PIPE,stderr=subprocess.PIPE)
<subprocess.Popen object at 0x7f7fe17adda0>

 subprocess.run()睡眠10秒之后才返回，subprocess.Popen()直接返回

>>> a = subprocess.Popen(['sleep','10'],stdout=subprocess.PIPE,stderr=subprocess.PIPE)
>>> a.wait()
0

 wait()会等待进程结束

>>> a = subprocess.Popen(['whoami'],stdout=subprocess.PIPE,stderr=subprocess.PIPE)
>>> a.stdout.read()  # 读取命令执行成功的结果
b'sch01ar
'
>>> a.stderr.read()  # 读取命令执行错误的结果
b''
>>> a.poll()  #检查子进程是否已终止，返回返回值
0
>>> a.args  # 返回命令参数
['whoami']
>>> a.pid  # 返回当前命令的进程号
24999
>>> a.returncode  # 返回返回值
0

 terminate()：给系统发信号，终止所启动的进程，不一定会终止

 kill()：杀死所启动的进程

 communicate()：与启动的进程交互，发送数据到stdin，并从stdout接收输出，然后等待任务结束

>>> a = subprocess.Popen(['python3','test.py'],stdout=subprocess.PIPE,stderr=subprocess.PIPE)
>>> a.communicate('sch01ar')
(b"ax7fa.cco	'ch01ar')
", b'')

 communicate()只能与启动的进程交互一次

 send_signal()：发送系统信号

>>> a = subprocess.Popen(['sleep','30'],stdout=subprocess.PIPE,stderr=subprocess.PIPE)
>>> a.send_signal(signal.SIGKILL)

 preexec_fn：只在Unix平台下有效，用于指定一个函数，它将在子进程运行之前被调用

>>> def test():
...    print('This is a test')
... 
>>> a = subprocess.Popen(['whoami'],stdout=subprocess.PIPE,stderr=subprocess.PIPE,preexec_fn=test)
>>> a.stdout.read()
b'This is a test
sch01ar
'

 cwd：用于设置子进程的当前目录

>>> a = subprocess.Popen('echo $PWD',shell=True,stdout=subprocess.PIPE,stderr=subprocess.PIPE)
>>> a.stdout.read()
b'/home/sch01ar
'
>>> a = subprocess.Popen('echo $PWD',shell=True,stdout=subprocess.PIPE,stderr=subprocess.PIPE,cwd='/home/sch01ar/Desktop/')
>>> a.stdout.read()
b'/home/sch01ar/Desktop
'

 shell的作用跟subprocess.run()方法中的shell作用一样

 env：用于指定子进程的环境变量。如果env = None，子进程的环境变量将从父进程中继承