进程运行时流式传输子进程输出
在 Python 中,execute() 方法通常用于执行外部命令。但是,默认情况下,它会等待进程完成,然后再返回组合的 stdout 和 stderr 输出。对于长时间运行的进程来说,这可能是不受欢迎的。
要启用进程输出的实时打印,您可以利用迭代器和 Python 的 universal_newlines 选项的强大功能。考虑这个例子:
<code class="python">from __future__ import print_function # Only Python 2.x 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>
这个增强的execute()函数使用Popen启动进程,确保stdout通过管道传输并自动处理换行符(universal_newlines=True)。然后,它使用迭代器 (iter(popen.stdout.readline, '')) 逐行遍历 stdout。
这种方法允许您在循环内可用时从进程中流式输出,从而使您可以显示实时进度或相应地响应中间输出。
以上是如何在 Python 中实时传输子进程输出?的详细内容。更多信息请关注PHP中文网其他相关文章!