包装子进程的stdout / stderr

Question

我想捕获并显示通过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

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

Answer 1

进程的Stdin，stdout和stderr必须是真实的文件描述符。（这实际上不是Python施加的限制，而是管道在OS级别上的工作方式。）因此，您将需要一个不同的解决方案。

如果你想同时跟踪stdout的stderr实时，你需要异步I / O或线程。

• 异步I / O： 使用标准的同步（=阻塞）I / O，可能会阻塞对其中一个流的读取，从而不允许实时访问另一个流。如果你是在Unix上，你可以使用非阻塞I / O中的说明这个答案。但是，在Windows上，您将无法使用这种方法。该视频介绍了更多有关Python中异步I / O的信息，以及一些替代方法。

• 线程： 处理此问题的另一种常用方法是为要实时读取的每个文件描述符创建一个线程。线程仅处理它们所分配的文件描述符，因此阻塞I / O不会造成损害。