DAG 管道

rust-srec 使用 有向无环图（DAG） 系统进行后处理工作流。

什么是 DAG 管道？

DAG 管道定义一系列带依赖关系的处理步骤。步骤在可能时并行执行，但遵循依赖顺序。

管道触发器 (Pipeline Triggers)

rust-srec 的强大之处在于其自动化的触发机制。您可以根据需求在不同阶段触发管道：

1. 分段管道 (Segment Pipeline)

• 触发时机：单个视频分段（.flv, .ts）或弹幕文件（.xml, .json）下载完成后。
• 典型用途：转封装（Remux）、视频截图、弹幕格式转换。
• 输入：单个文件。

2. 配对分段管道 (Paired Segment Pipeline)

• 触发时机：当同一分段的 视频文件 和 弹幕文件 都准备好，并且相关分段处理结束后。
• 典型用途：将弹幕烧录进视频（Burn-in）、合并分段信息。
• 输入：对应的视频文件 + 弹幕文件。

3. 会话完成管道 (Session Complete Pipeline)

• 触发时机：整个直播会话结束，最终录制文件已可用，并且该会话所有前期的分段或配对处理都已结束。
• 典型用途：全会话合并、上传到云盘（如 Rclone 到 Google Drive/OneDrive）、发送最终完成通知。
• 输入：该会话产生的所有最终产物列表。

稳定性说明

如果弹幕先于最终视频文件完成，rust-srec 会等待视频文件准备好后再启动会话完成管道。这样可以避免合并、上传或清理等最终任务在缺少视频输入时过早运行。

内置处理器 (Processors)

每个管道步骤由一个专门的处理器执行：

处理器 ID	功能	核心参数
remux	转封装，不改变编码	format (mp4, mkv...)
danmaku_factory	弹幕转换	output_format (ass)
burn_in	视频+弹幕硬烧录	video_path, subtitle_path
thumbnail	提取视频关键帧作为封面	timestamp, width, height
rclone	云端同步	destination_root, operation, time_anchor, args
tdl_upload	具体的上传工具支持	args
metadata	写入元数据（nfo, json）	-
delete	自动清理中间文件	-
execute	执行自定义 Shell 脚本	command, args

预设系统 (Presets)

为了提高效率，系统提供了两种预设：

• Job Preset (任务预设)：针对单个步骤的配置模板（如“1080p 封面提取”）。
• Pipeline Preset (管道预设)：完整的 DAG 工作流定义（如“B站标准录制流程”）。

高级特性

任务并行与依赖 (Fan-in / Fan-out)

DAG 系统支持复杂的拓扑结构。例如，您可以让 remux 和 thumbnail 并行运行，而 upload 步骤则等待这两者全部成功后才开始（扇入）。

自动清理

delete 步骤删除的是其所依赖步骤产出的文件，而不是原始录制文件。在 upload 步骤之后使用是安全的（rclone 复制会把已上传的文件作为输出透传），因此添加一个 depends_on: upload 的 delete 步骤即可实现“上传成功后删除本地副本”。

请不要在 remux/转码步骤之后放置 delete 步骤：它会删除转码后的结果文件，因为那正是转码步骤的产出。若要在转码后删除原始源文件，请改为在转码步骤上启用 Remove Input on Success（remove_input_on_success）。

性能建议

重编码（如 burn_in）是极其消耗 CPU 的。建议在 cpu_pool 中限制较小的并发数，以防止系统负载过高影响下载稳定性。