如何用Python持续读取Linux命令的事件流输出？

这问题我经常遇到！你用os.popen().readlines()的方式确实行不通——因为它会一直等到命令完全执行完毕才会返回所有输出，而你要的是实时捕获每一条新产生的消息对吧？别担心，用Python的subprocess模块就能完美解决这个问题，这也是官方推荐替代os.popen的方案。

基础实现：实时读取stdout #

核心思路是用subprocess.Popen启动子进程，直接绑定它的stdout管道，然后逐行迭代读取输出——这样子进程每输出一行，Python就能立刻拿到，不用等进程结束。

import subprocess

def get_live_messages(command):
    # 启动子进程，配置行缓冲和文本模式
    process = subprocess.Popen(
        command,
        shell=True,  # 如果是复杂shell命令（含管道/通配符）需要这个；简单命令建议用列表形式（见下文）
        stdout=subprocess.PIPE,
        stderr=subprocess.STDOUT,  # 可选：把stderr合并到stdout一起读取
        text=True,  # 将输出转为字符串（Python3.7+也可以用encoding="utf-8"）
        bufsize=1  # 启用行缓冲，确保输出一换行就被读取
    )

    # 实时迭代每一行输出
    for line in process.stdout:
        cleaned_line = line.strip()
        if cleaned_line:  # 跳过空行
            yield cleaned_line  # 用生成器返回，方便按需处理

    # 等待进程结束，获取返回码
    process.wait()
    return process.returncode

怎么用这个函数？ #

比如读取ping命令的实时输出（Windows用ping -t google.com，Linux/macOS用ping google.com）：

for msg in get_live_messages("ping google.com"):
    print(f"新消息: {msg}")

进阶：分开处理stdout和stderr #

如果需要分别捕获标准输出和错误输出，直接单线程读取会有阻塞风险（比如stderr缓冲区满了会卡住子进程），这时候可以用线程分别处理两个流：

import subprocess
import threading

def _read_stream(stream, handler):
    """辅助函数：读取单个流并调用处理函数"""
    for line in stream:
        cleaned_line = line.strip()
        if cleaned_line:
            handler(cleaned_line)
    stream.close()

def get_live_output_separate(command):
    process = subprocess.Popen(
        command,
        shell=True,
        stdout=subprocess.PIPE,
        stderr=subprocess.PIPE,
        text=True,
        bufsize=1
    )

    # 用线程分别处理stdout和stderr
    stdout_thread = threading.Thread(
        target=_read_stream,
        args=(process.stdout, lambda x: print(f"[OUT] {x}"))
    )
    stderr_thread = threading.Thread(
        target=_read_stream,
        args=(process.stderr, lambda x: print(f"[ERR] {x}"))
    )

    stdout_thread.start()
    stderr_thread.start()

    # 等待线程结束
    stdout_thread.join()
    stderr_thread.join()

    process.wait()
    return process.returncode

安全提示：慎用shell=True #

如果你的命令是简单的可执行文件加参数（比如ping google.com），建议不要用shell=True，而是把命令拆成列表形式，避免潜在的shell注入风险：

# 安全的非shell模式示例
process = subprocess.Popen(
    ["ping", "google.com"],  # 命令拆分为列表
    stdout=subprocess.PIPE,
    stderr=subprocess.STDOUT,
    text=True,
    bufsize=1
)

为什么os.popen不行？ #

os.popen().readlines()本质是一次性读取子进程的所有输出内容，只有当子进程终止时，这个读取操作才会完成。而subprocess.Popen直接让你访问子进程的实时输出管道，逐行迭代的方式能在输出产生的第一时间捕获到内容，完美适配持续输出的事件流场景。

内容的提问来源于stack exchange，提问作者Wojtas.Zet