Comment obtenir la sortie de subprocess.Popen()

Question

Je veux la sortie de l'exécution Test_Pipe.py, j'ai essayé le code suivant sur Linux mais cela n'a pas fonctionné.

Test_Pipe.py

import time 
while True : 
    print "Someting ..." 
    time.sleep(.1) 

Caller.py

import subprocess as subp 
import time 

proc = subp.Popen(["python", "Test_Pipe.py"], stdout=subp.PIPE, stdin=subp.PIPE) 

while True : 
    data = proc.stdout.readline() #block/wait 
    print data 
    time.sleep(.1) 

La ligne proc.stdout.readline() a été bloqué, donc pas de copies de données sur.

Answer 1

Vous pouvez évidemment utiliser subprocess.communicate mais je pense que vous recherchez une entrée et une sortie en temps réel. Readline a été bloqué car le processus attend probablement votre entrée. Vous pouvez lire le caractère par caractère pour surmonter ce comme ce qui suit:

import subprocess 
import sys 

process = subprocess.Popen(
    cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE 
) 

while True: 
    out = process.stdout.read(1) 
    if out == '' and process.poll() != None: 
     break 
    if out != '': 
     sys.stdout.write(out) 
     sys.stdout.flush() 

Answer 2

Pour éviter les nombreux problèmes qui peuvent toujours survenir avec mise en mémoire tampon pour des tâches telles que « obtenir au processus principal en temps réel de sortie du sous-processus », je recommande toujours d'utiliser pexpect pour toutes les plates-formes autres que Windows, wexpect sous Windows, au lieu de subprocess, lorsque ces tâches sont souhaitées.

Answer 3

L'extrait de Nadia fonctionne, mais appeler avec un tampon de 1 octet est fortement déconseillé. La meilleure façon de le faire serait de définir le descripteur de fichier stdout à non bloquant avec fcntl

fcntl.fcntl(
    proc.stdout.fileno(), 
    fcntl.F_SETFL, 
    fcntl.fcntl(proc.stdout.fileno(), fcntl.F_GETFL) | os.O_NONBLOCK, 
) 

puis utiliser select pour tester si les données sont prêtes

while proc.poll() == None: 
    readx = select.select([proc.stdout.fileno()], [], [])[0] 
    if readx: 
     chunk = proc.stdout.read() 
     print chunk 

Elle a eu raison de ce que votre problème doit être différent de ce que vous avez publié en tant que Caller.py et Test_Pipe.py fonctionnent comme prévu.

• https://derrickpetzold.com/p/capturing-output-from-ffmpeg-python/

Answer 4

Test_Pipe.py tampons STDOUT par défaut afin proc en Caller.py ne voient pas de sortie jusqu'à ce que la mémoire tampon de l'enfant est plein (si la taille de la mémoire tampon est 8KB alors il faut environ une minute pour remplir Tampon stdout Test_Pipe.py).

Pour que la sortie ne soit pas tamponnée (mise en mémoire tampon pour les flux de texte), vous pouvez transmettre -u flag au script enfant Python. Il permet de lire la ligne de sortie de sous-processus par ligne en « temps réel »:

import sys 
from subprocess import Popen, PIPE 

proc = Popen([sys.executable, "-u", "Test_Pipe.py"], stdout=PIPE, bufsize=1) 
for line in iter(proc.stdout.readline, b''): 
    print line, 
proc.communicate() 

Voir les liens Python: read streaming input from subprocess.communicate() sur la façon de résoudre le problème bloc-tampon pour les processus enfants non-Python.