腾讯云云点播如何接收事件通知_音视频解决方案_同尘科技

云点播 2年前 (2023-07-06) 浏览 66

使用须知

Demo 功能介绍

本文以一个视频的上传、转码流程为例,向开发者展示云点播(VOD)事件通知机制 的使用方法。

架构和流程

Demo 基于云函数(SCF) 搭建了一个 HTTP 服务,用于接收来自 VOD 的事件通知请求。该服务通过对 NewFileUpload(视频上传完成事件通知)和 ProcedureStateChanged(任务流状态变更)的处理,实现发起视频转码和获取转码结果。系统主要涉及四个组成部分:控制台、API 网关、云函数和云点播,其中 API 网关和云函数即是本 Demo 的部署对象,如下图所示:
具体业务流程为:1. 在控制台上传一个视频到 VOD。2. VOD 后台发起 NewFileUpload 事件通知请求给 Demo。3. Demo 解析事件通知内容,调用 VOD 的 ProcessMedia 接口对刚上传的视频发起转码,使用的转码模板为 系统预置模板 100010和100020。4. VOD 完成转码任务后,发起 ProcedureStateChanged 事件通知请求给 Demo。5. Demo 解析事件通知内容,将转码输出文件的 URL 打印到 SCF 日志中。说明:Demo 中的 SCF 代码使用 Python3.6 进行开发,此外 SCF 还支持 Python2.7、Node.js、Golang、PHP 和 Java 等多种编程语言,开发者可以根据情况自由选择,具体请参考 SCF 开发指南。

费用

本文提供的云点播事件通知接收服务 Demo 是免费开源的,但在搭建和使用的过程中可能会产生以下费用:购买腾讯云云服务器(CVM)用于执行服务部署脚本,详见 CVM 计费。使用 SCF 提供签名派发服务,详见 SCF 计费 和 SCF 免费额度。使用腾讯云 API 网关为 SCF 提供外网接口,详见 API 网关计费。消耗 VOD 存储用于存储上传的视频,详见 存储计费 和 存储资源包。消耗 VOD 转码时长用于对视频进行转码,详见 转码计费 和 转码资源包。

避免影响生产环境

事件通知接收服务 Demo 的业务逻辑使用到 VOD 事件通知机制,因此部署过程中需要开发者配置事件通知地址。如果该账号已有基于 VOD 的生产环境,那么变更事件通知地址可能造成业务异常。操作前请务必确认不会影响生产环境,如果您无法确定,请更换一个全新账号来部署 Demo

快速部署事件通知接收服务

步骤1:准备腾讯云 CVM

部署脚本需要运行在一台腾讯云 CVM 上,要求如下:地域:任意。机型:官网最低配置(1核1GB)即可。公网:需要拥有公网 IP,带宽1Mbps或以上。操作系统:官网公共镜像Ubuntu Server 16.04.1 LTS 64位Ubuntu Server 18.04.1 LTS 64位。购买 CVM 的方法请参见 操作指南 – 创建实例。重装系统的方法请参见 操作指南 – 重装系统。注意:事件通知接收服务 Demo 本身并不依赖于 CVM,仅使用 CVM 来执行部署脚本。如果您没有符合上述条件的腾讯云 CVM,也可以在其它带外网的 Linux(如 CentOS、Debian 等)或 Mac 机器上执行部署脚本,但需根据操作系统的区别修改脚本中的个别命令,具体修改方式请开发者自行搜索。

步骤2:开通云点播

请参考 快速入门 – 步骤1 开通云点播服务。

步骤3:获取 API 密钥和 APPID

事件通知接收服务 Demo 的部署和运行过程需要使用到开发者的 API 密钥(即 SecretId 和 SecretKey)和 APPID。如果还未创建过密钥,请参见 创建密钥文档 生成新的 API 密钥;如果已创建过密钥,请参见 查看密钥文档 获取 API 密钥。在控制台 账号信息 页面可以查看 APPID,如下图所示:


步骤4:部署事件通知接收服务

登录 步骤1准备的 CVM(登录方法详见 操作指南 – 登录 Linux),在远程终端输入以下命令并运行:

ubuntu@VM-69-2-ubuntu:~$ export SECRET_ID=AKxxxxxxxxxxxxxxxxxxxxxxx; export SECRET_KEY=xxxxxxxxxxxxxxxxxxxxx;export APPID=125xxxxxxx;git clone https://github.com/tencentyun/vod-server-demo.git ~/vod-server-demo; bash ~/vod-server-demo/installer/callback_scf.sh

说明:请将命令中的 SECRET_ID、SECRET_KEY 和 APPID 赋值为 步骤3 中获取到的内容。请确保已安装 Node.js 运行环境。该命令将从 Github 下载 Demo 源码并自动执行安装脚本。安装过程需几分钟(具体取决于 CVM 网络状况),期间远程终端会打印如下示例的信息:

[2020-06-05 17:16:08]开始检查npm。[2020-06-05 17:16:12]npm 安装成功。[2020-06-05 17:16:12]开始安装 ServerLess。[2020-06-05 17:16:13]serverless 安装成功。[2020-06-05 17:16:14]开始部署云点播事件通知接收服务。[2020-06-05 17:16:24]云点播事件通知接收服务部署完成。[2020-06-05 17:16:26]服务地址:https://service-xxxxxxxx-125xxxxxxx.gz.apigw.tencentcs.com/release/callback

复制输出日志中的事件通知接收服务地址(示例中的https://service-xxxxxxxx-125xxxxxxx.gz.apigw.tencentcs.com/release/callback)。注意:如果输出日志中出现如下所示的警告,一般是由于 CVM 无法立即解析刚部署好的服务域名,可尝试忽略该警告。

[2020-04-25 17:18:44]警告:事件通知接收服务测试不通过。

步骤5:配置事件通知地址

注意:如 避免影响生产环境 一节所述,操作之前请先确认您的线上业务不依赖于 VOD 事件通知。1. 登录 云点播控制台,单击左侧导航栏应用管理,进入应用列表页。2. 找到需要处理音视频文件的应用,单击应用名称进入应用管理页。3. 在左侧导航栏单击回调设置后,再单击设置,回调模式选择“普通回调”,回调 URL 填写 步骤4 中获得的事件通知接收服务地址,回调事件全部勾选,然后单击确定。如下图所示:
注意:如果您在控制台同时看到两个回调 URL 设置(2.0版本格式和3.0版本格式),请填写3.0版本。如下图所示:


步骤6:测试 Demo

1. 按照 上传视频 – 本地上传步骤 的说明,上传一个测试视频到云点播,注意上传过程选择默认的“只上传,暂不进行视频处理”。上传完成后,在“已上传”标签页可以看到该视频的状态为“处理中”,说明 Demo 接收到了 NewFileUpload 事件通知并发起了转码请求。
2. 等待视频处理完成(状态变为“正常”)后,单击快捷查看,在页面右侧可以看到该视频有两个转码视频。如下图所示:
3. 登录 SCF 控制台 > 函数服务,单击对应函数名进入“函数管理”页,左侧导航栏选择日志查询来查看 SCF 日志记录,在最新的一条日志中,可以看到两个转码文件的 URL 已经打印出来,在实际应用场景中,开发者可以通过 SCF 将 URL 记录在自己的数据库,或者通过其它渠道发布给观众。
说明:SCF 日志可能会有些许延迟,如果在页面上没有看到日志,请耐心等待一两分钟,然后单击重置刷新。

系统设计说明

接口协议

事件通知接收云函数通过 API 网关对外提供接口,具体接口协议请参考文档 视频上传完成事件通知 和 任务流状态变更。

事件通知接收服务代码解读

1. main_handler()为入口函数。2. 调用parse_conf_file(),从config.json文件中读取配置信息。配置项说明如下:

字段 数据类型 功能
secret_id String API 密钥
secret_key String API 密钥
region String 云 API 请求地域,对于 VOD 可随意填写
definitions Array of Integer 转码模板
subappid Integer 事件通知是否来自 云点播子应用

3. 针对 NewFileUpload 类型的事件通知,调用deal_new_file_event()解析请求,从中取出新上传视频的 FileId:

        if event_type == "NewFileUpload":            fileid = deal_new_file_event(body)            if fileid is None:                return ERR_RETURN

4. 调用trans_media()发起转码,输出云 API 的回包到 SCF 日志,并回包给 VOD 的事件通知服务:

            rsp = trans_media(configuration, fileid)            if rsp is None:                return ERR_RETURN            print(rsp)

5. 在trans_media()中,调用云 API SDK 发起 ProcessMedia 请求:

     cred = credential.Credential(conf["secret_id"], conf["secret_key"])     client = vod_client.VodClient(cred, conf["region"])
method = getattr(models, API_NAME + "Request") req = method() req.from_json_string(json.dumps(params))
method = getattr(client, API_NAME) rsp = method(req) return rsp

6. 针对 ProcedureStateChanged 类型的事件通知,调用deal_procedure_event()解析请求,从中取出转码输出视频的 URL 并打印到 SCF 日志:

        elif event_type == "ProcedureStateChanged":            rsp = deal_procedure_event(body)            if rsp is None:                return ERR_RETURN



对音视频的解决方案有疑惑?想了解解决方案收费? 联系解决方案专家

腾讯云限时活动1折起,即将结束: 马上收藏

同尘科技为腾讯云授权服务中心,购买腾讯云享受折上折,更有现金返利:同意关联,立享优惠

阿里云解决方案也看看?: 点击对比阿里云的解决方案

- 0人点赞 -

发表点评 (0条)

not found

暂无评论,你要说点什么吗?