拦截子进程的标准输出在运行时

Question

如果这是我的子过程：

import time, sys
for i in range(200):
    sys.stdout.write( 'reading %i\n'%i )
    time.sleep(.02)

和这是脚本控制和修改子过程的输出：

import subprocess, time, sys

print 'starting'

proc = subprocess.Popen(
    'c:/test_apps/testcr.py',
    shell=True,
    stdin=subprocess.PIPE,
    stdout=subprocess.PIPE  )

print 'process created'

while True:
    #next_line = proc.communicate()[0]
    next_line = proc.stdout.readline()
    if next_line == '' and proc.poll() != None:
        break
    sys.stdout.write(next_line)
    sys.stdout.flush()

print 'done'

为什么readline和communicate等到程序完成后运行？有一个简单的方式来传递（和修改）子进程标准输出实时？

顺便说一句，我已经看到此，但我不需要的日志功能（和没有带打扰理解许多的话）。

我在Windows XP上。

Answer 1

正如Charles已经提到的，问题是缓冲。我跑在以书面SNMPD一些模块时类似的问题，并且通过用一个自动冲水版本替换标准输出解决它。

我用下面的代码，对ActiveState的启发一些柱：

class FlushFile(object):
    """Write-only flushing wrapper for file-type objects."""
    def __init__(self, f):
        self.f = f
    def write(self, x):
        self.f.write(x)
        self.f.flush()

# Replace stdout with an automatically flushing version
sys.stdout = FlushFile(sys.__stdout__)

Answer 2

过程输出进行缓冲。上更UNIXy操作系统（或Cygwin的），则 Pexpect的模块是可用的，其中记载了所有必要的咒语，以避免缓冲相关的问题。然而，这些咒语需要一个工作 PTY模块，这是不提供原生（非cygwin的）的Python的win32构建。

在你控制的子流程的例子的情况下，你可以把它称之为sys.stdout.flush()在必要时 - 但对于任意的子流程，该选项不可用

另请参见的问题是“为什么不直接使用管道（POPEN（））？“在Pexpect的常见问题。