python Как использовать субпроцессный канал с оболочкой linux

Question

У меня есть сценарий для скриптов python для журналов, он непрерывно выводит найденные журналы и я хочу использовать linux pipe для фильтрации желаемого вывода. Пример:

$ python logsearch.py ​​| grep timeout

Проблема заключается в том, что сортировка и wc блокируются до тех пор, пока logsearch.py ​​не завершится, а logsearch.py ​​будет непрерывно выводить результат.

образец logsearch.py:

p = subprocess.Popen("ping google.com", shell=True, stdin=subprocess.PIPE, stdout=subprocess.PIPE) 
for line in p.stdout: 
    print(line) 

UPDATE:

разобрался, просто изменить стандартный вывод в подпроцесс для sys.stdout, питон будет обрабатывать трубы для вас.

p = subprocess.Popen("ping -c 5 google.com", shell=True, stdout=**sys.stdout**) 

Спасибо за помощь!

Answer 1

И зачем использовать grep? Почему бы не сделать все на Python?

from subprocess import Popen, PIPE 
p = Popen(['ping', 'google.com'], shell=False, stdin=PIPE, stdout=PIPE) 

for line in p.stdout: 
    if 'timeout' in line.split(): 
     # Process the error 
     print("Timeout error!!") 
    else: 
     print(line) 

UPDATE:
изменить линию POPEN как рекомендованное @triplee. Плюсы и минусы в Actual meaning of 'shell=True' in subprocess