停止阅读Python的过程输出没有挂起?

我有一个Linux的Python程序几乎看起来像这样:

import os import time process = os.popen("top").readlines() time.sleep(1) os.popen("killall top") print process 

该程序挂在这一行:

 process = os.popen("top").readlines() 

并发生在保持更新输出的工具,如“顶”

我最好的尝试:

 import os import time import subprocess process = subprocess.Popen('top') time.sleep(2) os.popen("killall top") print process 

它比第一个(它是凯尔特人)更好,但它返回:

 <subprocess.Popen object at 0x97a50cc> 

第二次审判:

 import os import time import subprocess process = subprocess.Popen('top').readlines() time.sleep(2) os.popen("killall top") print process 

与第一个相同。 它由于“readlines()”而被吊死

它的返回应该是这样的:

 top - 05:31:15 up 12:12, 5 users, load average: 0.25, 0.14, 0.11 Tasks: 174 total, 2 running, 172 sleeping, 0 stopped, 0 zombie Cpu(s): 9.3%us, 3.8%sy, 0.1%ni, 85.9%id, 0.9%wa, 0.0%hi, 0.0%si, 0.0%st Mem: 1992828k total, 1849456k used, 143372k free, 233048k buffers Swap: 4602876k total, 0k used, 4602876k free, 1122780k cached PID USER PR NI VIRT RES SHR S %CPU %MEM TIME+ COMMAND 31735 Barakat 20 0 246m 52m 20m S 19.4 2.7 13:54.91 totem 1907 root 20 0 91264 45m 15m S 1.9 2.3 38:54.14 Xorg 2138 Barakat 20 0 17356 5368 4284 S 1.9 0.3 3:00.15 at-spi-registry 2164 Barakat 9 -11 164m 7372 6252 S 1.9 0.4 2:54.58 pulseaudio 2394 Barakat 20 0 27212 9792 8256 S 1.9 0.5 6:01.48 multiload-apple 6498 Barakat 20 0 56364 30m 18m S 1.9 1.6 0:03.38 pyshell 1 root 20 0 2880 1416 1208 S 0.0 0.1 0:02.02 init 2 root 20 0 0 0 0 S 0.0 0.0 0:00.02 kthreadd 3 root RT 0 0 0 0 S 0.0 0.0 0:00.12 migration/0 4 root 20 0 0 0 0 S 0.0 0.0 0:02.07 ksoftirqd/0 5 root RT 0 0 0 0 S 0.0 0.0 0:00.00 watchdog/0 9 root 20 0 0 0 0 S 0.0 0.0 0:01.43 events/0 11 root 20 0 0 0 0 S 0.0 0.0 0:00.00 cpuset 12 root 20 0 0 0 0 S 0.0 0.0 0:00.02 khelper 13 root 20 0 0 0 0 S 0.0 0.0 0:00.00 netns 14 root 20 0 0 0 0 S 0.0 0.0 0:00.00 async/mgr 15 root 20 0 0 0 0 S 0.0 0.0 0:00.00 pm 

并保存在variables“process”中。 任何我想法的家伙,我现在真的被卡住了?

 #!/usr/bin/env python """Start process; wait 2 seconds; kill the process; print all process output.""" import subprocess import tempfile import time def main(): # open temporary file (it automatically deleted when it is closed) # `Popen` requires `f.fileno()` so `SpooledTemporaryFile` adds nothing here f = tempfile.TemporaryFile() # start process, redirect stdout p = subprocess.Popen(["top"], stdout=f) # wait 2 seconds time.sleep(2) # kill process #NOTE: if it doesn't kill the process then `p.wait()` blocks forever p.terminate() p.wait() # wait for the process to terminate otherwise the output is garbled # print saved output f.seek(0) # rewind to the beginning of the file print f.read(), f.close() if __name__=="__main__": main() 

类似尾巴的解决scheme只打印输出的一部分

您可以在另一个线程中读取进程输出,并将所需数量的最后一行保存在队列中:

 import collections import subprocess import time import threading def read_output(process, append): for line in iter(process.stdout.readline, ""): append(line) def main(): # start process, redirect stdout process = subprocess.Popen(["top"], stdout=subprocess.PIPE, close_fds=True) try: # save last `number_of_lines` lines of the process output number_of_lines = 200 q = collections.deque(maxlen=number_of_lines) # atomic .append() t = threading.Thread(target=read_output, args=(process, q.append)) t.daemon = True t.start() # time.sleep(2) finally: process.terminate() #NOTE: it doesn't ensure the process termination # print saved lines print ''.join(q) if __name__=="__main__": main() 

这个变体需要q.append()是primefaces操作。 否则,输出可能会损坏。

signal.alarm()解决scheme

您可以使用signal.alarm()在指定的超时后调用process.terminate() ,而不是在另一个线程中读取。 虽然它可能不能很好地与subprocess模块交互。 基于@Alex Martelli的回答 :

 import collections import signal import subprocess class Alarm(Exception): pass def alarm_handler(signum, frame): raise Alarm def main(): # start process, redirect stdout process = subprocess.Popen(["top"], stdout=subprocess.PIPE, close_fds=True) # set signal handler signal.signal(signal.SIGALRM, alarm_handler) signal.alarm(2) # produce SIGALRM in 2 seconds try: # save last `number_of_lines` lines of the process output number_of_lines = 200 q = collections.deque(maxlen=number_of_lines) for line in iter(process.stdout.readline, ""): q.append(line) signal.alarm(0) # cancel alarm except Alarm: process.terminate() finally: # print saved lines print ''.join(q) if __name__=="__main__": main() 

这种方法仅适用于* nix系统。 如果process.stdout.readline()不返回,它可能会阻塞。

threading.Timer解决scheme

 import collections import subprocess import threading def main(): # start process, redirect stdout process = subprocess.Popen(["top"], stdout=subprocess.PIPE, close_fds=True) # terminate process in timeout seconds timeout = 2 # seconds timer = threading.Timer(timeout, process.terminate) timer.start() # save last `number_of_lines` lines of the process output number_of_lines = 200 q = collections.deque(process.stdout, maxlen=number_of_lines) timer.cancel() # print saved lines print ''.join(q), if __name__=="__main__": main() 

这种方法也应该在Windows上工作。 在这里我使用了process.stdout作为一个迭代器; 它可能会引入一个额外的输出缓冲,如果不需要,可以切换到iter(process.stdout.readline, "")方法。 如果进程没有在process.terminate()上终止,则脚本挂起。

没有线程,没有信号解决scheme

 import collections import subprocess import sys import time def main(): args = sys.argv[1:] if not args: args = ['top'] # start process, redirect stdout process = subprocess.Popen(args, stdout=subprocess.PIPE, close_fds=True) # save last `number_of_lines` lines of the process output number_of_lines = 200 q = collections.deque(maxlen=number_of_lines) timeout = 2 # seconds now = start = time.time() while (now - start) < timeout: line = process.stdout.readline() if not line: break q.append(line) now = time.time() else: # on timeout process.terminate() # print saved lines print ''.join(q), if __name__=="__main__": main() 

这个变种既不使用线程,也不使用信号,但在terminal中产生乱码。 它会阻止如果process.stdout.readline()块。

我build议使用“ps”,而不是使用“top”,这会给你提供相同的信息,但只有一次而不是每秒一次。

你还需要使用ps标志,我倾向于使用“ps aux”

我会做的,而不是这个方法,是检查你试图从中获取信息的程序,并确定信息的最终来源。 它可能是一个API调用或设备节点。 然后,写一些从同一个来源得到它的Python。 这消除了“刮”“熟”数据的问题和开销。

(JF塞巴斯蒂安你的代码工作很好,我认为这比我的解决scheme=))

我用另一种方式解决了它。

而不是直接在terminal上输出,我把它做成一个文件“tmp_file”:

 top >> tmp_file 

然后我使用“剪切”工具将其输出作为“最高输出”作为过程的值

 cat tmp_file 

它做了我想要的事情。这是最终的代码:

 import os import subprocess import time subprocess.Popen("top >> tmp_file",shell = True) time.sleep(1) os.popen("killall top") process = os.popen("cat tmp_file").read() os.popen("rm tmp_file") print process # Thing better than nothing =) 

非常感谢你们的帮助

事实上,如果你填充输出缓冲区,你会以一些答案结束。 所以一个解决scheme是用大量垃圾输出填充缓冲区(~6000个字符,bufsize = 1)。

让我们说,而不是顶部,你有一个python脚本写在sys.stdout上:

 GARBAGE='.\n' sys.stdout.write(valuable_output) sys.stdout.write(GARBAGE*3000) 

在启动器端,而不是简单的process.readline():

 GARBAGE='.\n' line=process.readline() while line==GARBAGE: line=process.readline() 

很确定这是有点肮脏,因为2000是依赖于subprocess的实现,但它工作正常,非常简单。 设置任何东西,但bufsize = 1使事情变得更糟。