要从我的python脚本启动程序，我使用以下方法:
def execute(command):
process = subprocess.Popen(command, shell=True, stdout=subprocess.PIPE, stderr=subprocess.STDOUT)
output = process.communicate()[0]
exitCode = process.returncode
if (exitCode == 0):
return output
else:
raise ProcessException(command, exitCode, output)
所以当我启动一个进程，比如进程。执行("mvn clean install")时，我的程序会一直等待，直到进程完成，只有到那时我才能得到程序的完整输出。这是恼人的，如果我正在运行一个进程，需要一段时间才能完成。
我能让我的程序一行一行地写进程输出吗，在循环结束之前轮询进程输出什么的?
我找到了这篇文章，可能与此有关。
当前回答
对于试图回答这个问题并从Python脚本中获取标准输出的人来说，请注意Python会缓冲它的标准输出，因此可能需要一段时间才能看到标准输出。
这可以通过在目标脚本中的每个标准输出写入后添加以下内容来纠正:
sys.stdout.flush()
其他回答
在Python 3中，只要子进程的stdout缓冲区被刷新，就逐行打印子进程的输出:
from subprocess import Popen, PIPE, CalledProcessError
with Popen(cmd, stdout=PIPE, bufsize=1, universal_newlines=True) as p:
for line in p.stdout:
print(line, end='') # process line here
if p.returncode != 0:
raise CalledProcessError(p.returncode, p.args)
注意:你不需要p.poll()——当到达eof时循环结束。你不需要iter(p.s dout。readline， ")——在Python 3中修复了预读错误。
另请参阅Python:从subprocess. communication()读取流输入。
在@jfs的出色回答的基础上，这里有一个完整的工作示例供您使用。要求Python 3.7或更新版本。
sub.py
import time
for i in range(10):
print(i, flush=True)
time.sleep(1)
main.py
from subprocess import PIPE, Popen
import sys
with Popen([sys.executable, 'sub.py'], bufsize=1, stdout=PIPE, text=True) as sub:
for line in sub.stdout:
print(line, end='')
注意子脚本中使用的flush参数。
好吧，我设法解决它没有线程(任何建议，为什么使用线程会更好，感谢)使用从这个问题的一个片段拦截一个子进程的标准输出，而它正在运行
def execute(command):
process = subprocess.Popen(command, shell=True, stdout=subprocess.PIPE, stderr=subprocess.STDOUT)
# Poll process for new output until finished
while True:
nextline = process.stdout.readline()
if nextline == '' and process.poll() is not None:
break
sys.stdout.write(nextline)
sys.stdout.flush()
output = process.communicate()[0]
exitCode = process.returncode
if (exitCode == 0):
return output
else:
raise ProcessException(command, exitCode, output)
简单比复杂好。
操作系统库内置模块系统。您应该执行代码并看到输出。
import os
os.system("python --version")
# Output
"""
Python 3.8.6
0
"""
在版本之后，它也打印返回值为0。
实际上有一个非常简单的方法来做到这一点，当你只想打印输出:
import subprocess
import sys
def execute(command):
subprocess.check_call(command, shell=True, stdout=sys.stdout, stderr=subprocess.STDOUT)
在这里，我们只是将子进程指向我们自己的标准输出，并使用现有的成功或异常api。
