音频格式转换处理器
更新时间：2026-04-23
简介
音频格式转换处理器
功能描述
- 支持音频格式转换（WAV、MP3、FLAC）
- 自动选择合适的编码器
- 通过extra_params支持自定义ffmpeg参数
- 支持本地文件, BOS地址存储
算子参数
输入
| 输入 | 含义 |
|---|---|
| input_col | 包含输入音频路径的数组（支持本地路径) |
| output_col | 输出音频路径的数组（支持本地路径) |
输出
| 输出 | 含义 |
|---|---|
| convert_result | 包含转换结果路径的数组，成功返回输出路径，失败返回None |
参数
| 参数名称 | 类型 | 默认值 | 描述 |
|---|---|---|---|
| output_format | str | None | 输出音频格式，仅支持 "wav", "mp3", "flac"，默认为 "wav" |
| timeout | int or None | None | ffmpeg 执行超时时间（秒），默认为 None（无超时） |
| extra_params | list or None | None | 额外的 ffmpeg 参数列表，直接拼接到命令中 例如： - 音轨选择: ["-map", "0:a"] # 选择所有音轨 - 采样率: ["-ar", "44100"] - 比特率: ["-b:a", "192k"] # 适用于 MP3 - 压缩级别: ["-compression_level", "8"] # 适用于 FLAC |
调用示例
Plain Text
1from __future__ import annotations
2
3import os
4import daft
5from daft import col
6
7from daft.aihc.common.udf import aihc_udf
8from daft.aihc.functions.audio.audio_convert import AudioConvert
9
10if __name__ == "__main__":
11 if os.getenv("DAFT_RUNNER", "native") == "ray":
12 import ray
13 ray.init(dashboard_host="0.0.0.0", ignore_reinit_error=True)
14 daft.set_runner_ray()
15 daft.set_execution_config(actor_udf_ready_timeout=6000, min_cpu_per_task=0)
16
17 samples = {
18 "input_path": [
19 "file:///local/sample_1.wav",
20 "file:///mnt/pfs/sample_2.wav",
21 "file:///mnt/bos/sample_3.wav",
22 ]
23 "output_path": [
24 "file:///local/output/sample_1.map3",
25 "file:///mnt/pfs/output/sample_2.mp3",
26 "file:///mnt/bos/output/sample_3.mp3",
27 ],
28 }
29 ds = daft.from_pydict(samples)
30 constructor_kwargs = {
31 "output_format": "mp3",
32 "sample_rate": 44100,
33 "audio_map": "auto",
34 "extra_params": ["-c:a", "libmp3lame", "-b:a", "192k", "-q:a", "2"],
35 }
36 ds = ds.with_column(
37 "convert_result",
38 aihc_udf(
39 AudioConvert,
40 construct_args=constructor_kwargs,
41 num_cpus=1,
42 concurrency=1,
43 batch_size=1,
44 )(col("input_path"), col("output_path")),
45 )
46 ds.show()评价此篇文章