阿里云OSS文件上传后，如何自动触发点播转码功能？

Question

在使用阿里云OSS存储媒体文件时，如何自动触发点播服务的转码功能？当文件上传至OSS后，希望通过配置事件通知或云函数，自动将新增视频提交到点播服务进行转码处理。具体问题为：如何正确设置OSS的事件通知以对接点播转码？需要明确OSS bucket的事件类型（如“Object Created”）、通知目标（如MNS队列或函数计算），以及点播API的调用方式。此外，如何确保转码任务的状态更新能被有效监控和管理？此过程涉及OSS、点播服务及可能的中间处理逻辑，需合理配置避免失败或重复触发。

Answer 1

1. 基础概念与问题概述

在阿里云环境中，OSS（对象存储服务）常用于存储媒体文件，而点播服务则提供视频转码功能。为了实现自动化工作流，当文件上传至OSS后，需通过事件通知触发点播服务的转码任务。

• OSS Bucket支持事件通知机制，例如“Object Created”类型。
• 通知目标可以是MNS队列或函数计算。
• 需要调用点播API提交转码任务并监控状态。

以下将逐步解析如何配置和实现这一流程。

2. OSS事件通知配置

首先，在OSS中设置事件通知以捕获新增文件：

1. 登录阿里云控制台，进入OSS管理页面。
2. 选择目标Bucket，点击“事件通知”选项卡。
3. 添加规则：指定事件类型为“Object Created”，并设置前缀过滤（如“videos/”）。
4. 选择通知目标，推荐使用MNS队列或函数计算。

{
  "Event": "oss:ObjectCreated:PostObject",
  "EventData": {
    "bucket": "example-bucket",
    "object": "videos/sample.mp4"
  }
}

此JSON示例展示了OSS事件通知的内容结构。

3. 点播服务转码任务提交

通过函数计算或自定义代码，接收OSS事件通知并调用点播API：

步骤	操作
1	从事件通知中提取文件路径。
2	调用点播API，传递文件URL及转码模板ID。
3	记录转码任务ID以便后续查询。

以下是Python代码示例，展示如何调用点播API：

import requests

def submit_transcoding_task(file_url, template_id):
    url = "https://vod.aliyuncs.com/transcode"
    params = {
        "Action": "SubmitTranscodeJob",
        "VideoUrl": file_url,
        "TemplateGroupId": template_id
    }
    response = requests.get(url, params=params)
    return response.json()

4. 转码任务状态监控

确保转码任务的状态更新被有效管理，避免失败或重复触发：

使用Mermaid流程图描述状态监控逻辑：

graph TD;
            A[文件上传完成] --> B{是否触发事件};
            B -- 是 --> C[调用点播API];
            C --> D[获取任务ID];
            D --> E{任务是否完成};
            E -- 否 --> F[轮询状态];
            F --> E;
            E -- 是 --> G[标记任务完成];

此外，建议结合日志系统记录每次任务的状态变化，便于排查问题。