Windows环境下Python如何实时获取子进程STDOUT输出？

问题根源 #

Windows环境中，当程序的输出被重定向到管道或文件时（而非直接输出到终端），会默认启用块缓冲——只有当缓冲区填满或进程终止时，才会一次性输出所有内容。这就是你在subprocess调用和CMD重定向中遇到延迟的核心原因。

针对测试用例的解决办法 #

如果子进程是你可控的Python程序，最直接的方式是强制刷新输出缓冲：

方案1：修改子进程代码，强制刷新输出 #

修改child_program.py，在print时添加flush=True参数，强制每次输出后立刻刷新缓冲区：

from time import sleep
for i in range(0,10):
    print(i, flush=True)
    sleep(1)

或者在print后手动调用刷新：

from time import sleep
import sys
for i in range(0,10):
    print(i)
    sys.stdout.flush()
    sleep(1)

此时再运行parent_program.py，就能每秒输出一个数字。

方案2：父进程无缓冲读取（无需修改子进程） #

如果无法修改子进程代码，可以在父进程中使用无缓冲模式读取输出，注意要切换到二进制模式读取后解码：

import subprocess, os, sys
program = "python "+os.path.dirname(os.path.abspath(__file__)) + "/child_program.py"

with subprocess.Popen(program, shell=True, stdout=subprocess.PIPE, bufsize=0) as p:
    while True:
        chunk = p.stdout.read(1)
        if not chunk:
            break
        sys.stdout.write(chunk.decode('utf-8'))
        sys.stdout.flush()

针对第三方Windows可执行文件的解决办法 #

如果目标是无法修改源码的第三方exe，需要模拟终端环境让程序使用行缓冲，推荐使用winpty工具：

步骤1：安装winpty #

通过Chocolatey包管理器安装（需先安装Chocolatey）：

choco install winpty

或从winpty官方仓库下载二进制文件并添加到系统PATH。

步骤2：用winpty包装子进程调用 #

修改父进程代码，用winpty包裹目标程序的调用命令，模拟终端环境：

import subprocess
import os
import time

def monitor_and_restart():
    target_exe = os.path.abspath("your_program.exe")
    # 用winpty包装，强制程序使用行缓冲
    cmd = f"winpty {target_exe}"
    
    while True:
        print("Launching program...")
        with subprocess.Popen(
            cmd,
            shell=True,
            stdout=subprocess.PIPE,
            stderr=subprocess.STDOUT,  # 合并stderr到stdout统一监控
            bufsize=1,
            text=True
        ) as proc:
            try:
                for line in proc.stdout:
                    print(line, end='')
                    # 替换为你需要识别的错误关键词
                    if "ERROR" in line.upper():
                        print("Error detected, terminating process...")
                        proc.terminate()
                        proc.wait(timeout=5)
                        break
                if proc.returncode == 0:
                    print("Program exited normally, restarting...")
            except subprocess.TimeoutExpired:
                proc.kill()
                print("Process killed after timeout")
            time.sleep(1)

if __name__ == "__main__":
    monitor_and_restart()

CMD重定向实时写入的解决办法 #

同样用winpty包装命令，就能让输出实时写入文件：

winpty python child_program.py 2>&1 > output.txt

内容的提问来源于stack exchange，提问作者Chase Roberts