Me gustaría ejecutar un proceso del sistema, interceptar la salida y modificarla en tiempo real, línea por línea, en un script de Python.

Mi mejor intento, que espera a que se complete el proceso antes de imprimir, es:

#!/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()

La secuencia de comandoswaitsome.py simplemente imprime una línea cada medio segundo:

#!/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()

¿Hay una solución fácil de conseguirsubprocess ¿Permitir iterar sobre la salida en tiempo real? ¿Tengo que usar hilos?

Érase una vez, escribí en Perl, y esto fue pan comido:

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