Python采集GStreamer日志触发Segmentation fault段错误的解决方法

问题根源 #

你遇到的段错误是因为高日志级别下，GStreamer的C层会频繁传递对象到Python回调，而g_object_is_floating断言失败通常是因为对象生命周期管理冲突——Python回调的执行时机或对象引用方式干扰了C层的对象状态检查。G_GNUC_NO_INSTRUMENT属性用于禁用编译插桩（比如性能分析工具的 instrumentation），避免这类插桩代码干扰GObject的状态判断，但Python直接绑定的回调无法直接添加这个属性，需要通过C扩展中转。

解决方案 #

方案一：用C扩展封装带G_GNUC_NO_INSTRUMENT的日志回调 #

通过写一个简单的C中间层，给日志回调函数加上G_GNUC_NO_INSTRUMENT属性，再把调用转发到Python函数。

1. 编写C扩展代码（文件名：gst_log_wrapper.c）

#include <Python.h>
#include <gst/gst.h>

static PyObject *py_log_handler = NULL;

// 带G_GNUC_NO_INSTRUMENT属性的回调，避免插桩干扰对象检查
G_GNUC_NO_INSTRUMENT
static void wrapped_log_handler(GstDebugCategory *category, GstDebugLevel level,
                                const gchar *file, const gchar *function,
                                gint line, GObject *object, GstDebugMessage *message,
                                gpointer user_data) {
    // 把C层参数转为Python对象，调用注册的Python回调
    PyObject *args = Py_BuildValue("(OiiOOOiO)",
                                   category, (gint)level, file, function,
                                   line, object, message, user_data);
    if (args != NULL) {
        PyObject_CallObject(py_log_handler, args);
        Py_DECREF(args);
    }
}

static PyObject *setup_log_handler(PyObject *self, PyObject *args) {
    PyObject *handler;
    if (!PyArg_ParseTuple(args, "O", &handler)) {
        return NULL;
    }
    if (!PyCallable_Check(handler)) {
        PyErr_SetString(PyExc_TypeError, "参数必须是可调用对象");
        return NULL;
    }
    // 更新Python回调引用
    Py_XINCREF(handler);
    Py_XDECREF(py_log_handler);
    py_log_handler = handler;

    // 注册带属性的C回调到GStreamer
    gst_debug_add_log_function(wrapped_log_handler, NULL, NULL);
    Py_RETURN_NONE;
}

static PyMethodDef GstLogWrapperMethods[] = {
    {"setup_log_handler", setup_log_handler, METH_VARARGS, "注册包装后的GStreamer日志回调"},
    {NULL, NULL, 0, NULL}
};

static struct PyModuleDef gstlogwrappermodule = {
    PyModuleDef_HEAD_INIT,
    "gst_log_wrapper",
    NULL,
    -1,
    GstLogWrapperMethods
};

PyMODINIT_FUNC PyInit_gst_log_wrapper(void) {
    gst_init(NULL, NULL);
    return PyModule_Create(&gstlogwrappermodule);
}

2. 编写编译脚本（文件名：setup.py）

from setuptools import setup, Extension

module = Extension('gst_log_wrapper',
                   sources=['gst_log_wrapper.c'],
                   libraries=['gstreamer-1.0'])

setup(name='gst_log_wrapper',
      version='1.0',
      ext_modules=[module])

3. 编译并安装扩展

python3 setup.py install

4. 在Python脚本中使用（修改你的test_logging.py）

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

Gst.init(None)

def my_log_handler(category, level, file, func, line, obj, message, user_data):
    # 自定义日志处理逻辑，注意不要长期持有obj/message等对象引用
    print(f"[{level}] {category.get_name()}: {message.get()}")

# 通过C扩展注册回调，替代直接调用Gst.debug_add_log_function
gst_log_wrapper.setup_log_handler(my_log_handler)

# 你的GStreamer业务代码
pipeline = Gst.parse_launch("fakesrc ! fakesink")
pipeline.set_state(Gst.State.PLAYING)

# 运行主循环（示例）
import gi.repository.GLib
loop = gi.repository.GLib.MainLoop()
loop.run()

方案二：绕开Python回调，重定向日志到文件读取 #

如果不想写C扩展，可以把GStreamer日志直接输出到文件，再用Python实时读取文件内容，避免直接绑定回调的生命周期问题。

1. 启动时指定日志文件

GST_DEBUG=3 GST_DEBUG_FILE=gst_logs.txt python3 test_logging.py

2. 在Python中实时读取日志

import threading
import time

def read_gst_logs():
    with open('gst_logs.txt', 'r') as f:
        f.seek(0, 2)  # 跳到文件末尾
        while True:
            line = f.readline()
            if line:
                # 处理日志行
                print(f"GST LOG: {line.strip()}")
            time.sleep(0.1)

# 启动日志读取线程（后台运行）
threading.Thread(target=read_gst_logs, daemon=True).start()

# 你的GStreamer业务代码
Gst.init(None)
pipeline = Gst.parse_launch("fakesrc ! fakesink")
pipeline.set_state(Gst.State.PLAYING)

# 运行主循环
import gi.repository.GLib
loop = gi.repository.GLib.MainLoop()
loop.run()

额外注意事项 #

• 方案一中，Python回调不要长期持有obj或message等GObject对象引用，避免C层对象已释放但Python还持有引用的冲突。
• 确保你的gst-python版本在1.18以上，旧版本的绑定存在更多生命周期管理bug。

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