上传至S3 Bucket的视频自动加水印高可扩展方案咨询

针对你的需求，推荐用AWS S3 + Lambda + Elemental MediaConvert的全托管事件驱动方案，彻底解决本地用fluent-ffmpeg带来的性能瓶颈和扩展性问题，全程无需维护服务器，自动弹性扩缩容。

核心流程 #

用户上传视频到S3存储桶 → S3触发事件通知 → Lambda过滤非视频文件并触发MediaConvert作业 → MediaConvert完成加水印转码 → 处理后的视频自动存回指定S3桶。

1. 前期准备 #

• 把水印图片（优先用带透明通道的PNG格式）上传到某个S3桶（可以和视频上传桶分开，也可以同桶不同前缀）
• 给AWS账号配置必要权限：创建MediaConvert的IAM角色（需具备读写目标S3桶的权限），给Lambda配置调用MediaConvert、读取上传桶元数据的权限。

2. 配置S3事件触发 #

• 进入视频上传的S3桶控制台，开启「事件通知」
• 事件类型选择「所有对象创建事件」（比如Put）
• 目标选择「Lambda函数」，关联你后续创建的Lambda函数（也可直接触发MediaConvert，但Lambda能做前置过滤更灵活）

3. 创建MediaConvert加水印模板（可选但推荐） #

MediaConvert支持预设作业模板，避免每次调用都重复配置参数：

• 进入MediaConvert控制台，新建作业模板
• 在「输出设置」中添加「Overlay（叠加层）」：
  • 指定水印图片的S3路径
  • 设置位置（比如右下角、左上角，支持坐标或百分比偏移）
  • 调整透明度（0-100）、缩放比例等参数
• 保存模板后，后续Lambda调用时直接引用模板ARN即可，简化代码。

4. 编写Lambda衔接逻辑 #

Lambda主要做3件事：过滤非视频文件、构造MediaConvert作业参数、触发转码作业。以下是Node.js示例代码：

const AWS = require('aws-sdk');
// 替换成你的MediaConvert区域端点（可在MediaConvert控制台「账户设置」中获取）
const mediaconvert = new AWS.MediaConvert({ endpoint: 'https://xxxx.mediaconvert.us-east-1.amazonaws.com' });

exports.handler = async (event) => {
  // 解析S3上传事件
  const s3Record = event.Records[0].s3;
  const inputBucket = s3Record.bucket.name;
  const inputKey = decodeURIComponent(s3Record.object.key.replace(/\+/g, ' '));
  
  // 过滤非视频文件，可根据需求扩展后缀
  const allowedExtensions = ['.mp4', '.mov', '.avi', '.mkv'];
  if (!allowedExtensions.some(ext => inputKey.toLowerCase().endsWith(ext))) {
    console.log(`Skipping non-video file: ${inputKey}`);
    return { statusCode: 200, body: 'Non-video file skipped' };
  }
  
  // 构造MediaConvert作业参数
  const jobParams = {
    // 替换成你的MediaConvert IAM角色ARN
    Role: 'arn:aws:iam::123456789012:role/MediaConvertRole',
    Settings: {
      Inputs: [{ FileInput: `s3://${inputBucket}/${inputKey}` }],
      OutputGroups: [
        {
          Name: 'Processed Videos',
          OutputGroupSettings: {
            Type: 'FILE_GROUP_SETTINGS',
            FileGroupSettings: {
              // 替换成处理后视频的存储桶路径
              Destination: `s3://your-processed-bucket/watermarked-videos/`
            }
          },
          Outputs: [
            {
              ContainerSettings: { Container: 'MP4' },
              VideoDescription: {
                CodecSettings: {
                  Codec: 'H_264',
                  H264Settings: {
                    Bitrate: 5000000, // 根据需求调整码率
                    FramerateControl: 'INITIALIZE_FROM_SOURCE'
                  }
                }
              },
              AudioDescriptions: [
                {
                  CodecSettings: {
                    Codec: 'AAC',
                    AacSettings: { Bitrate: 192000 }
                  }
                }
              ],
              // 水印配置，替换成你的水印S3路径和位置参数
              OverlaySettings: {
                ImageInserter: {
                  Input: `s3://your-watermark-bucket/watermark.png`,
                  Position: {
                    Alignment: 'BOTTOM_RIGHT',
                    XOffset: 20,
                    YOffset: 20
                  },
                  Opacity: 70 // 透明度0-100，数值越低越透明
                }
              }
            }
          ]
        }
      ]
    }
  };
  
  // 触发MediaConvert作业
  try {
    const job = await mediaconvert.createJob(jobParams).promise();
    console.log(`Started MediaConvert job: ${job.Job.Id}`);
    return { statusCode: 200, body: `Job started successfully: ${job.Job.Id}` };
  } catch (err) {
    console.error('Failed to start job:', err);
    return { statusCode: 500, body: 'Job initiation failed' };
  }
};

5. 可选优化项 #

• 给处理后的S3桶配置事件通知，触发Lambda发送邮件/推送通知给用户，告知处理完成
• 配置S3生命周期规则，自动清理原始视频或过期的处理后视频，降低存储成本
• 用MediaConvert的批量作业功能处理历史视频，不用逐个上传触发

方案优势 #

• 高扩展性：MediaConvert自动根据作业量弹性扩容计算资源，支持海量视频并行处理，完全不用你管服务器
• 低运维成本：全托管服务，无需维护EC2实例或集群，只需要关注业务逻辑
• 异步处理：上传视频后立即返回，转码在后台异步完成，不阻塞前端或后端流程

注意事项 #

• 水印图片优先用PNG格式，支持透明通道，避免出现生硬的白色背景
• MediaConvert按处理时长和输出分辨率计费，测试阶段先用短视频验证，避免不必要的开销
• 遵循最小权限原则：给IAM角色只分配必要的权限（比如MediaConvert仅能读写指定S3桶）

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