Lecture/écriture à un Popen() sous-processus

Je suis en train de parler à un enfant de processus à l'aide de python sous-processus.Popen (). Dans mon code, je me suis mise en œuvre d'un type de l'IPC, donc je veux écrire des données, lire la réponse, écrire un peu plus de données, de lire la réponse, et ainsi de suite. De ce fait, je ne peux pas utiliser Popen.communiquer(), qui fonctionne bien pour les cas les plus simples.

Ce code montre mon problème. Il n'a jamais obtient la première réponse, se bloque lors de la première "Lecture de résultat". Pourquoi? Comment puis-je faire ce travail que je m'attendre?

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

OriginalL'auteur Mats Ekberg | 2012-04-28

  1. 4

    Je voudrais essayer d'utiliser Popen().communicate() si vous le pouvez car il fait beaucoup de belles choses pour vous, mais si vous avez besoin d'utiliser Popen() exactement comme vous l'avez décrit, vous aurez besoin de mettre en sed pour vider sa mémoire tampon après les retours à la ligne avec le -l option:

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

    et votre code devrait fonctionner correctement

    En effet, il fonctionne! Mon sed pour quelque raison utilise -u pour le "non", pas -l, mais il fonctionne tout de même. Cela résout mon exemple de code, mais malheureusement pas mon vrai code, en tant que la commande n'est pas sed, mais d'un autre programme en python. La bonne réponse si, vous avez identifié le problème.
    Yup, le problème est résolu. Le problème a été le tampon de sortie de la suite. Faisant une simple sortie standard (stdout).flush() dans mon sous-processus résolu le problème. Merci!

    OriginalL'auteur gnr

  2. 4

    sed's de sortie est mis en mémoire tampon et sorties seulement ses données jusqu'à ce que suffisamment a été cumulées ou le flux d'entrée est épuisé et fermé.

    Essayez ceci:

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

    Être conscient que cela ne peut être fait de façon fiable qui énorme de données comme wriring à stdin blocs une fois que le tampon est plein. La meilleure façon de le faire est d'utiliser communiquer().

    Mais sed ne pas agir de cette façon lors de l'exécution de la commande dans le shell directement. Si vous faites cela, la réponse vient après chaque ligne. Et le problème reste le même si je l'appelle p.stdin.flush() après avoir écrit. Aussi, dans la vraie vie, j'ai écrit le programme ainsi, il n'y a pas de mise en mémoire tampon et il se comporte de la même manière. Je ne suis pas convaincu que la mise en mémoire tampon est le problème ici.
    Ah, vous avez eu raison, de mise en mémoire tampon a été en effet le problème.

    OriginalL'auteur glglgl