Class FFMpegTranscoder

backend/plugins/ffmpeg_transcoder.py:32–175

# ── 插件类 ────────────────────────────────────────────────────────────

class FFMpegTranscoder(PluginBase):
    name        = "ffmpeg_transcoder"
    version     = "1.0.0"
    description = (
        "FFmpeg 转码插件（on_media_changed）。"
        "流上线时启动 FFmpeg 进程进行转码，"
        "流下线时停止 FFmpeg 进程。"
        "支持自定义命令行参数，支持 {vhost}/{app}/{stream} 变量替换。"
    )
    type          = "on_media_changed"
    interruptible = False   # 监听型：不拦截事件，继续派发后续插件
    multi_binding = True    # 支持多实例，每实例使用不同的转码参数

    def params(self) -> dict:
        return {
            "ffmpeg_cmd": {
                "type": "str",
                "description": (
                    "FFmpeg 命令行参数，支持变量：{vhost} {app} {stream}，"
                    "例如：-i rtsp://localhost:554/{app}/{stream} -c:v libx264 -c:a aac -f flv rtmp://localhost/live/{stream}_transcoded"
                ),
                "default": "",
            },
            "vhost_filter": {
                "type": "str",
                "description": "来源 vhost 过滤，支持通配符 *，默认匹配所有",
                "default": "*",
            },
            "app_filter": {
                "type": "str",
                "description": "来源 app 过滤，支持通配符 *，默认匹配所有",
                "default": "*",
            },
            "stream_filter": {
                "type": "str",
                "description": "来源 stream 过滤，支持通配符 *，默认匹配所有",
                "default": "*",
            },
            "schema_filter": {
                "type": "str",
                "description": (
                    "只对指定来源协议触发，多个用英文逗号分隔，"
                    "例如 rtsp,rtmp。空则匹配所有协议。"
                ),
                "default": "",
            },
        }

    def run(self, **kwargs) -> bool:
        is_register: bool    = kwargs.get("is_register", False)
        sender               = kwargs.get("sender")
        binding_params: dict = kwargs.get("binding_params") or {}

        if sender is None:
            return False

        # 同步获取来源流信息（sender是临时对象，不可在异步协程中引用）
        try: