在Python中返回连续的终端日志

问题描述

我正在创建一个小应用程序,可以在其中插入我的android手机的IP地址,然后按一下按钮。我通过ADB无线连接。这行得通,现在我想在可滚动但不可编辑的文本字段中显示adb logcat的日志。但是在这里我遇到了一个问题,我试图捕获p = os.popen("adb logcat")这样的logcat命令的输出,然后像print(p.read())这样打印它。这只会使我的应用程序(tkinter)冻结,我猜测这与打印永无止境有关。有人对如何显示logcat结果有想法吗?

功能代码

def logcatcommand():
    p = os.popen("adb logcat")
    print(p.read())

按钮:

button2 = tk.Button(text="Open logcat",width=25,height=3,command=logcatcommand)
button2.grid(row=5,column=0)

你们也对我如何实时显示此信息有想法吗?我想我必须使用这样的代码:

result = scrolledtext.ScrolledText(window,wrap = tk.WORD,width = 40,height = 10,font = ("Times New Roman",15))
result.grid(column = 1,row=0)
result.insert(tk.INSERT,output)
result.configure(state ='disabled') 

其中输出是从终端检索的实时数据。

样本行logcat:

09-10 14:10:28.479   971  3009 I WifiHAL : event received NL80211_CMD_VENDOR,vendor_id = 0x1374,subcmd = 0xd
09-10 14:10:34.779  1526  4567 I BatteryStatsService: In wakeup_callback: resumed from suspend
09-10 14:10:35.321  1526  4567 I BatteryStatsService: In wakeup_callback: suspend aborted

编辑: 感谢哈维尔·冈萨雷斯(Javier Gonzalez),我能够使用以下命令打印logcat:

def logcatcommand():
    popen = subprocess.Popen(args="adb logcat",shell=True,stdout=subprocess.PIPE)
    return iter(popen.stdout.readline,b"")


def logcatresult():
    for line in logcatcommand():
        print(line)

但是,当尝试将值设置为变量或只是做其他事情(例如尝试按另一个按钮)时,我只会看到Mac OSX上的彩虹纺车。

格里兹

解决方法

我相信这里的询问方式略有不同:Python: How to read stdout of subprocess in a nonblocking way

在您的代码中,我实际上将使用子流程模块而不是os.popen。

我第一次遇到此问题时,我使用了上面所链接问题的答案中提到的select模块。一种更现代的方法是改为使用asyncio。问题在于,可以在SO中找到各种使用异步的方法。这些是不同的,因为asyncio在不同版本中发生了显着变化。

编辑#1

您的潜在问题是您的主线程正在阻塞。现在,您有一个循环永远不会在logcatresult函数内部结束,因此它永远不会返回。 Tk循环永远不会重新获得控制权。这就是它冻结的原因。

通常来说,一个人可以做几件事:

  1. 定期进行非阻塞呼叫。 换句话说:您的主循环需要定期调用一个非阻塞函数,该函数将返回任何输出(如果有的话)。
  2. 将所有阻止代码移至单独的线程。
  3. 使用asyncio(我不会尝试举一个例子)

#1:读取日志而不阻塞的想法与#1一致。您需要实现定期调用的逻辑。

#2::如果将阅读循环移至某个线程,则可以释放主线程以执行其他操作并做出响应。然后让logcatresult线程填充您的滚动文本。在这种情况下,您甚至不需要我上面提到的内容。

以下是可能适用于您的简化版本:

from tkinter import *
from tkinter import messagebox
import threading
import subprocess

THREAD = None
PROCESS = None


def read_log(process):
    for line in iter(process.stdout.readline,b""):
        print(line.decode(),end=''),def read_log_thread():
    """ Button-Event-Handler starting the log reading. """
    global THREAD
    global PROCESS
    PROCESS = subprocess.Popen(["adb logcat"],shell=False,stdout=subprocess.PIPE)
    THREAD = threading.Thread(target=read_log,args=(PROCESS,))
    THREAD.start()


def hello():
    messagebox.showinfo(message='Hello.')


def main():
    root = Tk()
    Button(master=root,text='Start reading',command=read_log_thread).pack()
    buttonX = Button(master=root,text='Hello',command=hello).pack()
    root.mainloop()
    if PROCESS and PROCESS.poll():
        PROCESS.terminate()
    THREAD.join()

if __name__ == '__main__':
    main()

注意事项:

  • 此实现只是一个指南。它将有问题(下面会提到一些问题)。
  • 我会尽量不要使用全局变量。
  • 您需要确保所有内容都在末尾正确清理(所有子进程结束,线程结束等)
  • 没有什么可以阻止您两次按下按钮,创建多个(泄漏的)线程和进程的,因为变量是全局变量,并且不进行检查。
  • 还要注意,我使用了shell=False,所以我可以在最后PROCESS.terminate()。否则,您的程序将在该过程结束之前退出。

相关问答

错误1:Request method ‘DELETE‘ not supported 错误还原:...
错误1:启动docker镜像时报错:Error response from daemon:...
错误1:private field ‘xxx‘ is never assigned 按Alt...
报错如下,通过源不能下载,最后警告pip需升级版本 Requirem...