如何在 Python 中实时流处理输出？

进程执行过程中的连续输出显示

在Python脚本中，我们经常利用子进程来执行外部程序。虽然这是一个强大的功能，但在检索其输出之前等待进程完成可能会令人沮丧。为了解决这个问题，让我们探索一种在进程运行时连续流式传输进程输出的方法。

传统上，我们使用 subprocess.communicate() 来捕获进程完成后的整个输出。但是，这种方法要求在显示任何输出之前完全完成该过程。

为了启用连续输出，我们可以将 iter 函数与 fd.readline() 结合使用。这允许我们迭代进程的 stdout 流，捕获可用的行：

<code class="python">import subprocess

def 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)</code>

在此增强版本中，我们在 stdout 可用时生成每一行。这允许脚本在流程生成时连续显示输出。

这是一个说明性示例：

<code class="python">for path in execute(["locate", "a"]):
    print(path, end="")</code>

使用这种方法，我们可以连续显示与搜索查询匹配的路径“a”，因为它们是通过“locate”命令找到的，提供有关过程进度的实时反馈。

此技术允许连续输出监控，增强脚本的交互性和用户体验启动外部进程。

以上是如何在 Python 中实时流处理输出？的详细内容。更多信息请关注PHP中文网其他相关文章！