如何使用GStreamer在文件处理完成后重命名输出文件？

GStreamer 没有原生插件直接实现「先写入临时文件，处理完成后重命名为最终文件」的功能，但你可以通过以下两种方式轻松实现需求：

方法一：监听管道消息触发重命名（编程场景） #

继续使用filesink写入临时文件，在代码中监听管道的EOS（流结束）消息，收到消息后执行文件重命名操作。以下是Python实现的核心逻辑：

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

Gst.init(None)

# 构建处理管道，输出到临时文件
pipeline = Gst.parse_launch(
    "filesrc location=my-video-file.mp4 ! decodebin ! videoscale ! x264enc ! mp4mux ! filesink location=my-scaled-video-file.mp4.temp"
)

def handle_pipeline_message(bus, message):
    if message.type == Gst.MessageType.EOS:
        # 流处理完成，重命名临时文件
        os.rename("my-scaled-video-file.mp4.temp", "my-video-file-processed.mp4")
        pipeline.set_state(Gst.State.NULL)
    elif message.type == Gst.MessageType.ERROR:
        err, debug_info = message.parse_error()
        print(f"处理出错: {err.message}")
        # 出错时可选择删除临时文件
        if os.path.exists("my-scaled-video-file.mp4.temp"):
            os.remove("my-scaled-video-file.mp4.temp")
        pipeline.set_state(Gst.State.NULL)

# 绑定消息监听
bus = pipeline.get_bus()
bus.add_signal_watch()
bus.connect("message", handle_pipeline_message)

# 启动管道
pipeline.set_state(Gst.State.PLAYING)

# 启动主循环
main_loop = GObject.MainLoop()
main_loop.run()

方法二：Shell脚本封装（命令行场景） #

如果用命令行执行GStreamer管道，可通过Shell脚本封装逻辑：先执行管道写入临时文件，待管道正常退出后再重命名；若执行失败则清理临时文件。

#!/bin/bash

TEMP_FILE="my-scaled-video-file.mp4.temp"
FINAL_FILE="my-video-file-processed.mp4"

# 执行GStreamer处理管道
gst-launch-1.0 filesrc location=my-video-file.mp4 ! decodebin ! videoscale ! x264enc ! mp4mux ! filesink location="$TEMP_FILE"

# 根据管道执行结果处理文件
if [ $? -eq 0 ]; then
    mv "$TEMP_FILE" "$FINAL_FILE"
    echo "处理完成，文件已保存为 $FINAL_FILE"
else
    rm -f "$TEMP_FILE"
    echo "处理失败，已清理临时文件"
    exit 1
fi

两种方案都能实现你想要的效果：处理过程中仅存在临时文件，用户可通过临时文件判断处理状态；完成后自动替换为最终文件名，逻辑与youtube-dl一致。

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