如何通过Node.js AWS Lambda实现S3视频转音频自动处理？

我明白你已经在本地用FFmpeg搞定了视频转音频，现在要把这个流程搬到Lambda上实现自动触发对吧？这其实是个很常见的媒体处理场景，我来一步步给你拆解怎么做：

1. 给Lambda装上FFmpeg #

Lambda默认的执行环境里没有FFmpeg，所以得自己提供。最方便的方式是用Lambda层（Layer），这样不用每次部署都打包FFmpeg，还能复用：

• 下载对应Lambda运行时（比如Node.js 18.x）的FFmpeg二进制文件（要选Linux x86_64或者arm64，匹配你Lambda的架构）
• 把FFmpeg放到bin/目录下，然后压缩成zip包
• 在AWS控制台创建一个Lambda层，上传这个zip包，关联到你的Lambda函数
• 如果你不想用层，也可以把FFmpeg二进制文件和代码一起打包成zip部署，注意一定要选对架构版本

2. 配置S3触发Lambda #

当有视频文件上传到S3桶时自动触发Lambda：

• 打开S3控制台，找到目标桶，进入「属性」->「事件通知」
• 创建新通知：
  • 名称随便取，比如video-to-audio-trigger
  • 事件类型选「所有对象创建事件」或者更精确的「Put」
  • 后缀设置过滤规则（比如只处理.mp4、.mov这类视频文件，填.mp4,.mov）
  • 目标选择「Lambda函数」，关联你要创建的Lambda函数

3. 编写Lambda函数代码 #

基于你本地的代码改造，加上S3文件读写逻辑，注意Lambda的可写临时目录是/tmp（最大512MB空间，大文件要留意）：

const AWS = require('aws-sdk');
const ffmpeg = require('fluent-ffmpeg');
const fs = require('fs');
const path = require('path');

// 初始化S3客户端
const s3 = new AWS.S3();

// 设置FFmpeg路径（用层的话，层文件挂载在/opt，所以路径是/opt/bin/ffmpeg）
ffmpeg.setFfmpegPath('/opt/bin/ffmpeg');

exports.handler = async (event) => {
  try {
    // 从S3事件中提取上传文件信息
    const record = event.Records[0];
    const bucketName = record.s3.bucket.name;
    const key = decodeURIComponent(record.s3.object.key.replace(/\+/g, ' '));
    
    // 过滤非视频文件，可扩展支持更多格式
    const videoExtensions = ['.mp4', '.mov', '.avi', '.mkv'];
    const fileExt = path.extname(key).toLowerCase();
    if (!videoExtensions.includes(fileExt)) {
      console.log(`跳过非视频文件: ${key}`);
      return { statusCode: 200, body: 'Skipped non-video file' };
    }

    // 定义临时文件路径
    const inputPath = `/tmp/${path.basename(key)}`;
    const outputKey = key.replace(fileExt, '.mp3');
    const outputPath = `/tmp/${path.basename(outputKey)}`;

    // 1. 从S3下载文件到Lambda临时目录
    const fileStream = s3.getObject({ Bucket: bucketName, Key: key }).createReadStream();
    await new Promise((resolve, reject) => {
      const writeStream = fs.createWriteStream(inputPath);
      fileStream.pipe(writeStream);
      writeStream.on('finish', resolve);
      writeStream.on('error', reject);
    });

    // 2. 执行视频转音频（复用你本地的转换逻辑）
    await new Promise((resolve, reject) => {
      ffmpeg(inputPath)
        .output(outputPath)
        .audioCodec('libmp3lame') // 指定MP3编码，可选优化音质
        .on('end', () => {
          console.log(`${key} 转换完成`);
          resolve();
        })
        .on('error', (err) => {
          console.error(`转换出错: ${err.message}`);
          reject(err);
        })
        .run();
    });

    // 3. 把转换后的音频上传回S3
    await s3.putObject({
      Bucket: bucketName,
      Key: outputKey,
      Body: fs.createReadStream(outputPath),
      ContentType: 'audio/mpeg'
    }).promise();

    // 清理临时文件（可选，Lambda结束后会自动清理，但养成好习惯）
    fs.unlinkSync(inputPath);
    fs.unlinkSync(outputPath);

    console.log(`成功将 ${key} 转换为 ${outputKey}`);
    return { statusCode: 200, body: 'Conversion successful' };
  } catch (error) {
    console.error('Lambda执行出错:', error);
    throw error;
  }
};

4. 配置IAM权限 #

Lambda需要具备读写S3的权限，给Lambda的执行角色添加以下权限策略：

{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Effect": "Allow",
      "Action": [
        "s3:GetObject",
        "s3:PutObject"
      ],
      "Resource": [
        "arn:aws:s3:::your-bucket-name/*"
      ]
    }
  ]
}

记得把your-bucket-name替换成你的S3桶名。

5. 关键注意事项 #

• Lambda配置：视频转换比较耗资源，建议把内存设置到至少1024MB（内存越高，CPU性能越强，转换速度越快），超时时间设置为5-15分钟（根据视频大小调整）
• 文件大小限制：Lambda的/tmp目录最大512MB，处理超大视频需要配合S3分段下载或EFS存储，小视频完全够用
• 错误处理：可以添加失败通知（比如SNS），或者把转换失败的文件移到专门的错误桶
• 依赖安装：部署前要安装fluent-ffmpeg（aws-sdk在Lambda环境已内置，可选择不打包）

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