我想捕获并显示通过Python的子流程调用的流程的输出。

我以为我可以将文件状对象作为参数stdout和stderr传递

我可以看到它访问了fileno属性-因此它正在处理对象。但是，write()永远不会调用该方法。我的方法是否完全无效或我只是缺少什么？

class Process(object):
    class StreamWrapper(object):
        def __init__(self, stream):
            self._stream = stream
            self._buffer = []
        def _print(self, msg):
            print repr(self), msg
        def __getattr__(self, name):
            if not name in ['fileno']:
                self._print("# Redirecting: %s" % name)
            return getattr(self._stream, name)
        def write(self, data):
            print "###########"
            self._buffer.append(data)
            self._stream.write(data)
            self._stream.flush()
        def getBuffer(self):
            return self._buffer[:]
    def __init__(self, *args, **kwargs):
        print ">> Running `%s`" % " ".join(args[0])
        self._stdout = self.StreamWrapper(sys.stdout)
        self._stderr = self.StreamWrapper(sys.stderr)
        kwargs.setdefault('stdout', self._stdout)
        kwargs.setdefault('stderr', self._stderr)
        self._process = subprocess.Popen(*args, **kwargs)
        self._process.communicate()

更新：

我还想工作的是ANSI控制字符，用于移动光标并覆盖以前的输出内容。我不知道这是否是正确的术语，但这是我的意思的一个示例：我正在尝试使一些GIT自动化，在那里它们的进度会自动更新，而无需每次都写入新行。

更新2

对我而言，重要的是要立即显示子流程的输出。我尝试使用subprocess.PIPE捕获输出并手动显示，但是一旦处理完成，我只能使它显示输出。但是，我想实时查看输出。