Lettura/scrittura di un sottoprocesso Popen()

Question

Sto provando a parlare con un processo figlio utilizzando la chiamata subprocess.Popen() python. Nel mio codice reale, sto implementando un tipo di IPC, quindi desidero scrivere alcuni dati, leggere la risposta, scrivere altri dati, leggere la risposta e così via. Per questo motivo, non posso usare Popen.communicate(), che altrimenti funziona bene per il caso semplice.

Questo codice mostra il mio problema. Non ottiene mai la prima risposta, si blocca al primo "Risultato di lettura". Perché? Come posso fare questo lavoro come mi aspetto?

import subprocess 
p = subprocess.Popen(["sed", 's/a/x/g'], 
        stdout = subprocess.PIPE, 
        stdin = subprocess.PIPE) 

p.stdin.write("abc\n") 
print "Reading result:" 
print p.stdout.readline() 

p.stdin.write("cat\n") 
print "Reading result:" 
print p.stdout.readline() 

Answer 1

Proverei ad usare Popen().communicate() se è possibile perché fa un sacco di cose carine per te, ma se hai bisogno di usare Popen() esattamente come hai descritto, dovrai impostare sed per svuotare il suo buffer dopo newlines con l'opzione -l:

p = subprocess.Popen(['sed', '-l', 's/a/x/g'], 
        stdout=subprocess.PIPE, 
        stdin=subprocess.PIPE) 

e il codice dovrebbe funzionare bene

Answer 2

s' sed uscita bufferizzata ed emette solo i dati fino abbastanza è stato accumulato, oppure il flusso di input è esaurita e chiusa.

Prova questo:

import subprocess 
p = subprocess.Popen(["sed", 's/a/x/g'], 
        stdout = subprocess.PIPE, 
        stdin = subprocess.PIPE) 

p.stdin.write("abc\n") 
p.stdin.write("cat\n") 
p.stdin.close() 

print "Reading result 1:" 
print p.stdout.readline() 

print "Reading result 2:" 
print p.stdout.readline() 

essere consapevoli che questo non può essere fatto in modo affidabile che enormi dati come Wriring a stdin blocchi una volta che il buffer è pieno. Il modo migliore per farlo è usare communicate().