Lectura/escritura en un subproceso Popen()

Question

Estoy tratando de hablar con un proceso hijo utilizando la subproceso python.Popen() llamada. En mi código real, estoy implementando un tipo de IPC, por lo que quiero escribir algunos datos, leer la respuesta, escribir algunos datos más, leer la respuesta, etc. Debido a esto, no puedo usar Popen.communicate(), que de otra manera funciona bien para el caso simple.

Este código muestra mi problema. Nunca recibe la primera respuesta, se cuelga en el primer "resultado de lectura". ¿Por qué? ¿Cómo puedo hacer que esto funcione como espero? salida

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

me gustaría tratar de utilizar Popen().communicate() si puedes, ya que hace un montón de cosas buenas para ti, pero si es necesario utilizar Popen() exactamente como usted la describe, se tendrá que establecer sed para vaciar su memoria intermedia después de los saltos de línea con la opción -l:

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

y su código debería funcionar bien

Answer 2

sed 's se tampona y sólo da salida a sus datos hasta que suficiente se ha acumulado o el flujo de entrada está agotado y cerrado.

Prueba esto:

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() 

Tenga en cuenta que esto no puede hacerse de forma fiable que gran cantidad de datos como wriring a stdin bloques una vez que el buffer está lleno. La mejor forma de hacerlo es usando communicate().