Intercettare stdout di un sottoprocesso mentre è in esecuzione

Question

Se questo è il mio sottoprocesso:

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

E questo è lo script di controllo e modificando l'uscita del sottoprocesso:

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'

Perché è readline e communicate in attesa fino a quando il processo è fatto in esecuzione? C'è un modo semplice per passare (e modificare) il sottoprocesso stdout in tempo reale?

A proposito, ho visto questo , ma non ho bisogno le funzionalità di registrazione (e havn't infastidito capire gran parte di essa).

Sono su Windows XP.

Answer 1

Come Charles già accennato, il problema è il buffering. Mi sono imbattuto in un problema simile quando si scrive alcuni moduli per snmpd, e risolto sostituendo stdout con una versione auto-lavaggio.

Ho usato il seguente codice, ispirato da alcuni messaggi su 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

uscita di processo viene bufferizzata. Su più sistemi operativi Unixy (o Cygwin), il pexpect modulo è disponibile, che recita tutto il necessario incantesimi per evitare problemi di buffering legate. Tuttavia, questi incantesimi richiedono un lavoro pty modulo , che non è disponibile sul nativo (non cygwin) Win32 Python costruisce.

Nel caso ad esempio in cui è possibile controllare il sottoprocesso, si può solo avere chiamare sys.stdout.flush() se necessario -. Ma per sottoprocessi arbitrari, tale opzione non è disponibile

alla domanda "Perché non basta usare un tubo (popen ())? " nel pexpect FAQ.