如何使用 Python 实时流式传输子进程输出？

来自 Subprocess.communicate() 的流式输出

当使用 subprocess.communicate() 从进程检索输出时，整个标准输出（stdout）可能会立即返回，从而妨碍对输出的实时监控。出现此问题的原因是communicate() 函数的阻塞性质。

为了解决这个问题，可以采用流式方法来打印每行可用的标准输出。这可以通过使用迭代器并操作 Popen() 的 bufsize 参数来实现。

在 Python 2 中：

from subprocess import Popen, PIPE

p = Popen(["cmd", "arg1"], stdout=PIPE, bufsize=1)
with p.stdout:
    for line in iter(p.stdout.readline, b''):
        print(line)
p.wait()

在 Python 3 中，代码变为：

from subprocess import Popen, PIPE

with Popen(["cmd", "arg1"], stdout=PIPE, bufsize=1, universal_newlines=True) as p:
    for line in p.stdout:
        print(line, end='')

bufsize=1 参数强制进程在每行之后刷新其输出缓冲区，确保立即打印每行。 iter() 允许异步读取行，从而可以流式传输输出。进程终止是通过 wait() 方法处理的。

通过使用这种流式方法，您可以实时监视长时间运行的进程的输出，而不会影响 communications() 函数的同步性质。

以上是如何使用 Python 实时流式传输子进程输出？的详细内容。更多信息请关注PHP中文网其他相关文章！