Python读取systemd Journal日志并在GTK窗口实时展示的方案咨询

方案优先级说明 #

gobject.timeout_add()定时轮询不是最优方案，该方案存在固定响应延迟、无日志时也会空转消耗资源的问题。GLib原生提供无需轮询的IO事件监听机制，更适配GTK主循环，是更推荐的实现方式。

无轮询最优实现方案 #

你可以使用GLib.io_add_watch()监听journalctl子进程的标准输出文件描述符，当有新日志写入时GLib会自动触发回调函数，全程不阻塞GTK主循环，也没有轮询开销，效果和终端执行journalctl -f完全一致。

完整代码示例 #

import sys
from gi.repository import GLib, Gtk
import subprocess
import fcntl
import os

class JournalLogViewer(Gtk.Window):
    def __init__(self):
        super().__init__(title="Journal 日志查看器")
        self.set_default_size(800, 600)
        
        # 初始化日志展示文本框
        self.text_view = Gtk.TextView()
        self.text_view.set_editable(False)
        self.text_buffer = self.text_view.get_buffer()
        scrolled_window = Gtk.ScrolledWindow()
        scrolled_window.set_child(self.text_view)
        self.set_child(scrolled_window)

        # 启动journalctl跟随模式子进程
        self.journal_proc = subprocess.Popen(
            ["journalctl", "--user-unit=appToMonitor", "-f"],
            stdout=subprocess.PIPE,
            stderr=subprocess.DEVNULL,
            text=True,
            bufsize=1
        )

        # 将标准输出设置为非阻塞模式，避免回调卡主主循环
        fd = self.journal_proc.stdout.fileno()
        flags = fcntl.fcntl(fd, fcntl.F_GETFL)
        fcntl.fcntl(fd, fcntl.F_SETFL, flags | os.O_NONBLOCK)

        # 注册IO事件监听，监听可读和进程断开事件
        self.io_watch_id = GLib.io_add_watch(
            fd,
            GLib.PRIORITY_DEFAULT,
            GLib.IO_IN | GLib.IO_HUP,
            self.on_new_log
        )

    def on_new_log(self, fd, condition):
        # 有新日志可读
        if condition & GLib.IO_IN:
            line = self.journal_proc.stdout.readline()
            if line:
                # 将新日志插入文本框末尾
                end_iter = self.text_buffer.get_end_iter()
                self.text_buffer.insert(end_iter, line)
                # 自动滚动到最新日志位置
                self.text_view.scroll_to_iter(
                    self.text_buffer.get_end_iter(),
                    0.0, False, 0.0, 0.0
                )
            return True # 保持监听状态
        # 子进程退出，结束监听
        elif condition & GLib.IO_HUP:
            self.journal_proc.wait()
            return False # 移除当前监听

    def on_window_destroy(self, widget):
        # 窗口关闭时清理资源
        GLib.source_remove(self.io_watch_id)
        self.journal_proc.terminate()
        self.journal_proc.wait()
        Gtk.main_quit()

if __name__ == "__main__":
    win = JournalLogViewer()
    win.connect("destroy", win.on_window_destroy)
    win.show()
    Gtk.main()

若坚持使用gobject.timeout_add()轮询的实现说明 #

如果因为特殊需求必须使用轮询方案，可通过以下两种方式保证仅读取上一次之后的新增日志：

1. 维持子进程管道方案：和上面的方案一样启动带-f参数的journalctl子进程，将标准输出设为非阻塞，每次轮询时循环读取所有可用的行，直到抛出BlockingIOError说明无新内容，管道本身会缓存未读取的内容，不会漏读。
2. 定期重拉方案：每次轮询时新启动journalctl进程，传入--since "上次轮询时间"参数，仅拉取时间范围内的新增日志，该方案不需要维持常驻子进程，但日志量大时重复启动进程的开销更高。

轮询方案关键代码示例 #

# 初始化时启动常驻journalctl子进程，非阻塞配置和最优方案一致
# 每100ms轮询一次，可根据延迟需求调整间隔
self.timeout_id = GLib.timeout_add(100, self.poll_log)

def poll_log(self):
    while True:
        try:
            line = self.journal_proc.stdout.readline()
            if not line:
                break
            # 日志插入逻辑和最优方案一致
            end_iter = self.text_buffer.get_end_iter()
            self.text_buffer.insert(end_iter, line)
        except BlockingIOError:
            # 无新日志，退出本次轮询
            break
    # 自动滚动到底部
    self.text_view.scroll_to_iter(self.text_buffer.get_end_iter(), 0.0, False, 0.0, 0.0)
    return True # 继续下一次轮询

注意事项 #

• 两种方案都建议使用journalctl原生的-f跟随模式，比自己判断日志文件变化更可靠，不会遗漏系统日志轮转产生的新内容。
• 所有IO操作都要使用非阻塞模式，避免阻塞GTK主循环导致界面无响应。
• 窗口退出时必须手动终止journalctl子进程，避免产生孤儿进程占用系统资源。

内容的提问来源于stack exchange，提问作者wowpatrick