视频移除音轨
更新时间：2026-06-15
简介
视频音轨移除处理器
功能描述
- 使用 ffmpeg subprocess 方式移除视频音轨
- 保留原始视频编码和质量（无需重编码）
- 自动下载远程文件 / 上传结果
- 支持超时控制
- 支持多种视频格式
算子参数
输入
| 输入 | 含义 |
|---|---|
| input_col | 输入视频路径列 |
| output_col | 输出视频路径列 |
输出
| 输出 | 含义 |
|---|---|
| result | 输出路径的 PyArrow Array |
参数
| 参数名称 | 类型 | 默认值 | 描述 | |
|---|---|---|---|---|
| output_format | str | None | None | 输出视频格式，如"mp4"、"avi"、"mkv"，为None时保持原格式 默认值：None |
| extra_params | list[str] | None | None | 额外的ffmpeg参数列表，如["-preset", "fast"] 默认值：None |
| timeout | int | None | None | ffmpeg执行超时时间（秒），默认为None（无超时） |
调用示例
Python
1from __future__ import annotations
2
3import os
4
5import daft
6from daft import col
7
8from daft.aihc.common.udf import aihc_udf
9from daft.aihc.functions.video.video_remove_audio import VideoRemoveAudio
10
11if __name__ == "__main__":
12 if os.getenv("DAFT_RUNNER", "native") == "ray":
13 import ray
14 ray.init(dashboard_host="0.0.0.0", ignore_reinit_error=True)
15 daft.set_runner_ray()
16 daft.set_execution_config(actor_udf_ready_timeout=6000, min_cpu_per_task=0)
17
18 # TODO: 根据实际场景准备样本数据
19 samples = {"input_col": [...], "output_col": [...]}
20 ds = daft.from_pydict(samples)
21 constructor_kwargs = {
22 "output_format": None,
23 "extra_params": None,
24 "timeout": None,
25 }
26 ds = ds.with_column(
27 "result",
28 aihc_udf(
29 VideoRemoveAudio,
30 construct_args=constructor_kwargs,
31 num_cpus=1,
32 concurrency=4,
33 batch_size=8,
34 )(col("input_col"), col("output_col")),
35 )
36 ds.show()评价此篇文章