GStreamer Python动态管道构建异常：无文件接收器消息

• 核心问题：静态管道里GStreamer会自动处理rtspsrc的动态pad连接，但手动构建动态管道时，必须自己监听pad-added信号完成链路对接——rtspsrc的src pad不是初始化就有的，得等收到媒体流后才会动态创建。你看到的GstRtpPtDemux无输出pad，本质是rtspsrc的输出没连上rtph264depay，后续链路断流，multifilesink自然发不出消息。

• 修复步骤：

  1. 先把所有元素（rtspsrc、rtph264depay、mpegtsmux、multifilesink）创建好，添加到管道里，参数和静态管道设置完全一致。
  2. 先连固定pad的元素：rtph264depay → mpegtsmux → multifilesink，这些元素的pad是固定存在的，直接用gst_element_link_many就能连。
  3. 给rtspsrc注册pad-added信号回调，在回调里处理动态pad的连接：

     // C语言示例回调（Python/其他语言逻辑一致）
     static void pad_added_handler (GstElement *src, GstPad *new_pad, gpointer user_data) {
       GstElement *depay = GST_ELEMENT(user_data);
       GstPad *sink_pad = gst_element_get_static_pad(depay, "sink");
       GstPadLinkReturn ret;
     
       // 校验pad类型是否为视频RTP流
       GstCaps *caps = gst_pad_get_current_caps(new_pad);
       GstStructure *struct = gst_caps_get_structure(caps, 0);
       const gchar *type = gst_structure_get_name(struct);
     
       if (!g_str_has_prefix(type, "application/x-rtp") || 
           !g_strstr_len(gst_structure_get_string(struct, "media"), -1, "video")) {
         g_print("跳过非视频RTP pad: %s\n", type);
         goto cleanup;
       }
     
       if (gst_pad_is_linked(sink_pad)) {
         g_print("depay的sink pad已连接，无需重复操作\n");
         goto cleanup;
       }
     
       ret = gst_pad_link(new_pad, sink_pad);
       if (GST_PAD_LINK_FAILED(ret)) {
         g_print("Pad连接失败，错误码: %d\n", ret);
       } else {
         g_print("成功连接动态pad: %s → %s\n", GST_ELEMENT_NAME(src), GST_ELEMENT_NAME(depay));
       }
     
     cleanup:
       if (caps != NULL) gst_caps_unref(caps);
       gst_object_unref(sink_pad);
     }
     
     // 绑定信号
     g_signal_connect(rtspsrc, "pad-added", G_CALLBACK(pad_added_handler), rtph264depay);
     

  4. 确认multifilesink的post-messages参数设为true，并且已经通过gst_bus_add_watch或对应方式监听总线消息。

• 验证注意事项：

  • 启动管道后，检查回调是否触发，确认rtspsrc的动态pad成功连到rtph264depay。
  • 如果流里包含音频，要在回调里过滤掉，避免错误连接到视频解封装器。
  • 核对所有元素参数和静态管道完全一致，比如rtph264depay的wait-for-keyframe、multifilesink的max-file-duration等。

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