Перехват stdout в реальном времени из другого процесса в Python
Я хотел бы запустить системный процесс, перехватить вывод и изменить его в режиме реального времени, построчно, в скрипте Python.
Моя лучшая попытка, которая ожидает завершения процесса перед печатью:
#!/usr/bin/env python
import subprocess
cmd = "waitsome.py"
proc = subprocess.Popen(cmd, shell=True, bufsize=256, stdout=subprocess.PIPE)
for line in proc.stdout:
print ">>> " + line.rstrip()
Сценарийwaitsome.py
просто печатает строку каждые полсекунды:
#!/usr/bin/env python
import time
from sys import stdout
print "Starting"
for i in range(0,20):
time.sleep(0.5)
print "Hello, iteration", i
stdout.flush()
Есть ли простое решение, чтобы получитьsubprocess
разрешить перебор выходных данных в режиме реального времени? Должен ли я использовать темы?
Когда-то я писал на Perl, и это было очень просто:
open(CMD, "waitsome.py |");
while (<CMD>) {
print ">>> $_";
}
close(CMD);