Как копировать поведение мишени в Python при использовании подпроцесса?

Я ищу решение Python, которое позволит мне сохранять вывод команды в файле, не скрывая его от консоли.

К вашему сведению: я спрашиваю о мишени (как утилита командной строки Unix) а не функция с тем же именем от модуля межинструментов Python.

Подробнее

• Решение Python (не вызов tee, это не доступно в соответствии с Windows),
• Я не должен предоставлять вход stdin для названного процесса
• Я не имею никакого контроля над названной программой. Все, что я знаю, - то, что это произведет что-то к stdout и stderr и возвратится с кодом выхода.
• Работать при вызове внешних программ (подпроцесс)
• Работать на обоих stderr и stdout
• Способность дифференцироваться между stdout и stderr, потому что я могу хотеть отобразить только один из к консоли или я мог попытаться произвести stderr использование другого цвета - это означает это stderr = subprocess.STDOUT не будет работать.
• Живой (прогрессивный) вывод - процесс может работать в течение долгого времени, и я не могу ожидать его для окончания.
• Python 3 совместимый (важный) код

Ссылки

Вот некоторые неполные решения, которые я нашел до сих пор:

• http://devlishgenius.blogspot.com/2008/10/logging-in-real-time-in-python.html (mkfifo работает только над Unix),
• http://blog.kagesenshi.org/2008/02/teeing-python-subprocesspopen-output.html (не работает вообще),

Схема http://blog.i18n.ro/wp-content/uploads/2010/06/Drawing_tee_py.png

Текущий код (вторая попытка)

#!/usr/bin/python
from __future__ import print_function

import sys, os, time, subprocess, io, threading
cmd = "python -E test_output.py"

from threading import Thread
class StreamThread ( Thread ):
    def __init__(self, buffer):
        Thread.__init__(self)
        self.buffer = buffer
    def run ( self ):
        while 1:
            line = self.buffer.readline()
            print(line,end="")
            sys.stdout.flush()
            if line == '':
                break

proc = subprocess.Popen(cmd, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
stdoutThread = StreamThread(io.TextIOWrapper(proc.stdout))
stderrThread = StreamThread(io.TextIOWrapper(proc.stderr))
stdoutThread.start()
stderrThread.start()
proc.communicate()
stdoutThread.join()
stderrThread.join()

print("--done--")

#### test_output.py ####

#!/usr/bin/python
from __future__ import print_function
import sys, os, time

for i in range(0, 10):
    if i%2:
        print("stderr %s" % i, file=sys.stderr)
    else:
        print("stdout %s" % i, file=sys.stdout)
    time.sleep(0.1)

Реальный вывод

stderr 1
stdout 0
stderr 3
stdout 2
stderr 5
stdout 4
stderr 7
stdout 6
stderr 9
stdout 8
--done--

Ожидаемому выводу состоял в том, чтобы заказать строки. Комментарий, изменяя Popen для использования только одного КАНАЛА не позволяется, потому что в реальной жизни я захочу сделать разные вещи с stderr и stdout.

Также даже во втором случае я не смог получить в реальном времени как, на самом деле все результаты были получены когда законченный процесс. По умолчанию Popen не должен использовать буферы (bufsize=0).