Jak mogę przechwytywać dane wyjściowe i wyświetlać je w tym samym czasie w Pythonie?

Question

Mam dość długo działającą pracę, która działa przez kilka minut, a następnie zostaje ponownie uruchomiona. Zadanie generuje różne informacje, które przechwytuję w ten sposób:

output = subprocess.Popen(cmd,stdout=subprocess.PIPE).communicate() 

Chodzi o to, że otrzymam tylko całą produkcję na raz. Chciałbym wyświetlać dane wyjściowe, ponieważ program wysyła je na standardowe wyjście, a jednocześnie przesyła je z powrotem do bufora (muszę sprawdzić dane wyjściowe pod kątem obecności niektórych ciągów znaków). W Ruby chciałbym zrobić to tak:

IO.popen(cmd) do |io| 
    io.each_line do |line| 
    puts line 
    buffer << line 
    end 
end 

Answer 1

Można spróbować czegoś takiego:

cmd = ["./my_program.sh"] 
p = subprocess.Popen(cmd, shell=False, stdout=subprocess.PIPE) # launch the process 
while p.poll() is None:   # check if the process is still alive 
    out = p.stdout.readline() # if it is still alive, grab the output 
    do_something_with(out)  # do what you want with it 

Answer 2

Można ją przeczytać jeden wiersz naraz:

from subprocess import Popen, PIPE 

p = Popen('grep -ir graph .', stdout=PIPE) 
while not p.returncode: 
    s = p.stdout.readline() 
    print s 
    p.poll() 

w ten sposób , blokujesz tylko czas potrzebny do przetworzenia, aby wyprowadzić pojedynczą linię.

Answer 3

Możesz użyć polecenia "tee". Robi dokładnie to, czego potrzebujesz.
http://www.computerhope.com/unix/utee.htm