在Python中处理PIPE - Raspbian Linux

Question

Folks ....我有一个脚本在Python程序中运行，通过subprocess Popen 命令来创建一个包含脚本输出的管道。这是工作。但是我认为我将不得不使用.communicate()命令来处理来自我的程序的管道中的记录。我无法得到这个工作，但确实得到它与这个代码的工作。当我尝试使用.communicate命令时，我做错了什么？

import subprocess 
nul_f = open('/dev/null', 'w') 
try: 
    tcpdmp = subprocess.Popen(['/usr/bin/sudo /usr/sbin/tcpdump -A -n -p -l -    i eth0 -s0 -w - tcp dst port 80'], 
        stdout=subprocess.PIPE, shell=True, 
        stderr=nul_f,) 
    print 'My Records' 
    i=0 
# end_of_pipe = tcpdmp.communicate() 
    while i<10: 
    i=i+1 
    line = tcpdmp.stdout.readline() 
    print '\t --', i, line 
except KeyboardInterrupt: 
    print 'done' 
tcpdmp.terminate() 
tcpdmp.kill() 
nul_f.close() 

感谢您的任何建议和批评..... RDK

PS ......在树莓派运行Raspbian Linux的....

Answer 1

.communicate()等待子进程结束。 tcpdump并没有和平地结束，这就是为什么你的代码有except KeyboardInterrupt（来处理Ctrl + C）。

无关：你可以用这个代替while循环：

from itertools import islice 

for line in enumerate(islice(iter(tcpdump.stdout.readline, b''), 10), start=1): 
    print '\t --', i, line, #NOTE: comma at the end to avoid double newlines 

参见，Stop reading process output in Python without hang?