Python中Gstreamer日志从stdout/stderr重定向至自定义日志处理器的问题

在Python 3环境使用GStreamer时，控制台会输出大量来自GStreamer及其底层插件的日志——这类日志直接从C子模块输出到stdout/stderr，既无法通过Python的logging模块捕获，常规的stdout/stderr重定向方法也无法拦截。

以下是几种可行的解决方法：

方法1：通过环境变量控制GStreamer日志级别 #

GStreamer原生支持通过环境变量限制日志输出，直接从源头减少或关闭底层日志：

• 仅显示错误级日志：

  export GST_DEBUG=*:error
  

• 完全关闭GStreamer日志：

  export GST_DEBUG=0
  

• 针对特定组件设置级别（例如仅让nvinfer输出警告及以上日志）：

  export GST_DEBUG=nvinfer:warning
  

也可以在Python脚本内部提前设置环境变量（必须在导入GStreamer相关模块前执行）：

import os
os.environ['GST_DEBUG'] = '*:error'  # 先配置环境变量
import gi
gi.require_version('Gst', '1.0')
from gi.repository import Gst

方法2：自定义GStreamer日志回调（转发到Python logging） #

GStreamer的Python绑定支持注册自定义日志处理函数，将C层面的日志转发到Python的logging系统：

import logging
import gi
gi.require_version('Gst', '1.0')
from gi.repository import Gst

# 初始化GStreamer
Gst.init(None)

# 配置Python日志系统
logging.basicConfig(level=logging.INFO, format='[%(asctime)s] [%(levelname)s] - %(message)s')
gst_logger = logging.getLogger('gstreamer')

# 定义GStreamer日志转Python日志的映射
def gst_log_handler(category, level, file, func, line, msg, user_data):
    level_map = {
        Gst.DebugLevel.ERROR: logging.ERROR,
        Gst.DebugLevel.WARNING: logging.WARNING,
        Gst.DebugLevel.INFO: logging.INFO,
        Gst.DebugLevel.DEBUG: logging.DEBUG,
    }
    python_level = level_map.get(level, logging.INFO)
    log_msg = f"[{category.get_name()}] {msg}"
    gst_logger.log(python_level, log_msg)

# 替换默认日志处理函数
Gst.debug_remove_default_log_function()
Gst.debug_add_log_function(gst_log_handler, None)

注意：该方法需要GStreamer Python绑定版本支持debug_add_log_function接口，部分旧版本可能不兼容。

方法3：系统层面重定向文件描述符（终极方案） #

如果上述方法无效，可以通过操作系统的管道拦截C模块直接写入stderr/stdout的内容，再转发到Python日志：

import os
import sys
import logging
import threading

# 配置应用日志
logger = logging.getLogger('app')
logger.setLevel(logging.INFO)
handler = logging.FileHandler('app.log')
logger.addHandler(handler)

# 保存原始stderr文件描述符
original_stderr = os.dup(sys.stderr.fileno())
# 创建管道并重定向stderr到管道写端
r, w = os.pipe()
os.dup2(w, sys.stderr.fileno())
os.close(w)

# 启动线程读取管道内容并转发到日志
def pipe_reader():
    while True:
        data = os.read(r, 1024)
        if not data:
            break
        for line in data.decode('utf-8', errors='ignore').splitlines():
            if line.strip():
                logger.info(line.strip())

threading.Thread(target=pipe_reader, daemon=True).start()

# 后续导入GStreamer模块
import gi
gi.require_version('Gst', '1.0')
from gi.repository import Gst

此方法通过操作系统层面的文件描述符拦截，适用于所有场景，但需注意编码兼容性和线程安全问题。

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