来自 Python 子进程的实时输出/流

Question

我正在使用 Python，它的子进程库使用 strace 检查调用的输出，涉及以下问题：

subprocess.check_output(["strace", str(processname)]) 

但是，这只会在调用的子进程已经完成之后给我输出，这对我的用例来说是非常有限的。

我需要进程的一种“流”或实时输出，因此我需要在进程仍在运行时读取输出，而不是仅在进程完成后读取。

有没有一种方便的方法可以使用子流程库来实现这一点？ 我正在考虑每 x 秒进行一次民意调查，但没有在文档中找到有关如何实现此功能的任何提示。

非常感谢。

Answer 1

在引用 selected answer 以从测试运行器流式输出时遇到一些问题。以下对我来说效果更好：

import subprocess
from time import sleep

def stream_process(process):
    go = process.poll() is None
    for line in process.stdout:
        print(line)
    return go

process = subprocess.Popen(cmd, shell=True, stdout=subprocess.PIPE, stderr=subprocess.STDOUT)
while stream_process(process):
    sleep(0.1)

Answer 2

根据documentation：

Popen.poll()

检查子进程是否已终止。设置并返回返回码属性。

因此，基于此，您可以：

process = subprocess.Popen('your_command_here',stdout=subprocess.PIPE)
while True:
    output = process.stdout.readline()
    if process.poll() is not None and output == '':
        break
    if output:
        print (output.strip())
retval = process.poll()

这将循环，读取标准输出，并实时显示输出。

---

这在当前版本的 python 中不起作用。 （至少）对于 Python 3.8.5 和更新版本，您应该将 output == '' 替换为 output == b''

Answer 3

从 Python 3.2 开始（当上下文管理器支持添加到 Popen 时），我发现这是从子进程连续流式输出的最直接的方法：

import subprocess


def run(args):
  with subprocess.Popen(args, stdout=subprocess.PIPE, stderr=subprocess.STDOUT) as process:
    for line in process.stdout:
      print(line.decode('utf8'))