进程运行时不断打印子流程输出

Question

进程运行时不断打印子流程输出为了从我的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)所以当我启动一个进程Process.execute("mvn clean install")，我的程序等待进程完成，只有这样，我才能得到程序的完整输出。如果我正在运行一个需要一段时间才能完成的进程，这是很烦人的。我能让我的程序逐行地写进程输出，在流程输出完成之前轮询它吗？*[编辑]对不起，在发布这个问题之前，我搜索得不太好。线程实际上是关键。在这里找到一个例子，说明如何做到这一点：*从线程打开

Answer 1

你可以用ITER若要在命令输出行时立即处理这些行，请执行以下操作：lines = iter(fd.readline, "")..下面是一个完整的示例，展示了一个典型的用例(感谢@JFS帮助)：

from __future__ import print_function # Only Python 2.ximport subprocessdef execute(cmd):
    popen = subprocess.Popen(cmd, stdout=subprocess.PIPE, universal_newlines=True)
    for stdout_line in iter(popen.stdout.readline, ""):
        yield stdout_line 
    popen.stdout.close()
    return_code = popen.wait()
    if return_code:
        raise subprocess.CalledProcessError(return_code, cmd)# Examplefor path in execute(["locate", "a"]):
    print(path, end="")

Answer 2

好的，我设法在没有线程的情况下解决了这个问题(如果建议使用线程会更好)，可以使用这个问题中的一个片段。在子进程运行时拦截子进程的stdout

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)

Answer 3

在Python 3中刷新其标准输出缓冲区后，立即逐行打印子进程的输出：

from subprocess import Popen, PIPE, CalledProcessErrorwith Popen(cmd, stdout=PIPE, bufsize=1, universal_newlines=True) as p:
    for line in p.stdout:
        print(line, end='') # process line hereif p.returncode != 0:
    raise CalledProcessError(p.returncode, p.args)

注意：你不需要p.poll()-当到达eof时，循环结束。你不需要iter(p.stdout.readline, '')-在Python 3中修复了预读错误.

也看，Python：从子流程读取流输入。Communications().