python - stdin は、パイプループプロセスから python を読み取ります

Question

Python でサブプロセスを生成または Popen し、その出力をリアルタイムで処理するにはどうすればよいですか? サブプロセスは、他のシステムイベントに応じて出力をランダムに出力します。

この「例」がハングします。

$./print.sh | ./echo.pyハングします。

`print.sh`

#!/bin/bash

while [ 1 ]; do
echo 'A'
sleep 1
done

#!/usr/bin/python
import sys

for line in sys.stdin:
  print line

score 2 · Accepted Answer

ハングしません。echo/シェルは、パイプへの書き込みであるため、ラインバッファモードではなくブロックバッファモードで I/O を実行することを決定します。十分に待つかsleep 1、シェルスクリプトからを削除すると、からの出力が表示されることがわかりますA。

考えられる解決策は 2 つあります。

サブプロセスのプログラムを変更して、Python プログラムが処理するのに十分な出力が書き込まれたときにバッファーをフラッシュするようにします。
パイプの代わりに疑似端末 (PTY) を使用します。pexpect複雑さのほとんどを隠します。ただし、それはのドロップイン代替品でsubprocessはありません。

score 0 · Accepted Answer

このコーディングスニペットが機能するかどうかを確認してください。

猫 ech.sh

#!/bin/bash

while [ 1 ]; do
echo -n 'A'
sleep 1
done

猫 in_read.py

#!/usr/bin/python
import sys
import os

while True:
  print os.read(0,1)