Блог

У меня довольно длительное задание, которое выполняется в течение нескольких минут, а затем перезапускается. Задача выводит различную информацию, которую я фиксирую следующим образом:

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

Дело в том, что я получу только весь вывод за раз. Я хотел бы показывать выходные данные по мере того, как программа отправляет их в стандартный вывод, все еще помещая их обратно в буфер (мне нужно проверить выходные данные на наличие некоторых строк). В Ruby я бы сделал это так:

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

Вы можете попробовать что-то вроде этого :

 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
  

Вы могли бы читать его по одной строке за раз:

 from subprocess import Popen, PIPE

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

Таким образом, вы блокируете только время, необходимое для обработки вывода одной строки.

Вы можете использовать команду «tee». Он делает именно то, что вам нужно от него.
http://www.computerhope.com/unix/utee.htm