从Python中的另一个进程实时拦截标准输出

Question

我想运行一个系统进程，拦截输出，并在Python脚本中逐行实时地对其进行修改。

我的最佳尝试是等待过程完成后再打印，它是：

#!/usr/bin/env python
import subprocess

cmd = "waitsome.py"
proc = subprocess.Popen(cmd, shell=True, bufsize=256, stdout=subprocess.PIPE)
for line in proc.stdout:
    print ">>> " + line.rstrip()

该脚本waitsome.py仅每半秒打印一行：

#!/usr/bin/env python
import time
from sys import stdout

print "Starting"
for i in range(0,20):
    time.sleep(0.5)
    print "Hello, iteration", i
    stdout.flush()

是否有一个简单的解决方案可以subprocess实时迭代输出？我必须使用线程吗？

从前，我用Perl编写脚本，这真是小菜一碟：

open(CMD, "waitsome.py |");
while (<CMD>) {
    print ">>> $_";
}
close(CMD);

Answer 1

遍历文件不可避免地将大量内容缓冲-这是所有Python 2. *实现的一个已知问题。它可以按照您在Python 3.1中的预期工作，最终循环略有不同：

for line in proc.stdout:
    print(">>> " + str(line.rstrip()))

如果升级到Python 3.1是不切实际的（并且我知道通常是这样！），请换一种方式，以老式的方式编写循环-循环的以下版本确实可以在Python 2中实现。
：

while True:
    line = proc.stdout.readline()
    if not line:
        break
    print ">>> " + line.rstrip()