subprocess.Popen（）からの出力の取得方法

Question

出力をTest_Pipe.pyから実行したいのですが、Linux上で次のコードを試しましたが、動作しませんでした。

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) 

線proc.stdout.readline()をブロックしたので、データなしプリントアウト。

Answer 1

あなたは明らかにsubprocess.communicateを使用できますが、私はあなたがリアルタイムの入出力を探していると思います。

readlineがブロックされていた可能性があります。あなたは次のようにこれを克服するために文字で文字を読むことができます：

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

常に、このような「リアルタイムでメインプロセスにサブプロセスの出力を取得」などのタスクのためのバッファリングに発生する可能性が多くの問題を回避するために、私はこのようなタスクが必要な場合は、subprocessではなく、Windows上のすべてのプラットフォームにpexpect、Windowsではwexpectを使用することを常にお勧めします。

Answer 3

ナディアのスニペットは機能しますが、1バイトのバッファで読み込みを呼び出すことは非常に推奨されていません。これを行うには良い方法は、fcntlの

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

を使用して非ブロッキングし、その後のデータは、彼女はその問題に正解した

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

準備ができているかどうかをテストするために選択し使用して標準出力ファイルディスクリプタを設定することですCaller.pyとTest_Pipe.pyが提供されているように機能するので、あなたが投稿したものと異なる必要があります。

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

Answer 4

Test_Pipe.pyバッファサイズが8キロバイトであれば、それは埋めるために分の周りにかかる（子供のバッファがいっぱいになるまでそうCaller.pyでprocも出力されないデフォルトでは、その標準出力をバッファリングTest_Pipe.pyのstdoutバッファ）。

出力をバッファなし（テキストストリームの場合はラインバッファ）にするには、-u flagを子Pythonスクリプトに渡すことができます。これは、 『リアルタイム』での線で出力ラインサブプロセスを読み取ることができます：

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

は非Pythonの子プロセスのためのブロック・バッファリングの問題を解決する方法についてPython: read streaming input from subprocess.communicate()のリンクを参照してください。