腾讯云云函数实战教程 - SCF + VOD 实现接收事件通知

云函数 SCF

简介/价格/文档

腾讯云云函数实战教程 - SCF + VOD 实现接收事件通知

文档简介：

使用须知： Demo 功能介绍：本文以一个视频的上传、转码流程为例，向开发者展示云点播（VOD）事件通知机制的使用方法。

*此产品及展示信息均由腾讯云官方提供。免费试用咨询热线：400-826-7010，为您提供专业的售前咨询，让您快速了解云产品，助您轻松上云！微信咨询

免费试用、价格特惠

文档详情

使用须知

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 中获取到的内容。

该命令将从 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 事件通知。

登录云点播控制台，单击设置，回调模式选择普通回调，回调 URL 填写步骤4 中获得的事件通知接收服务地址，回调事件全部勾选，然后单击确定。如下图所示：

注意

如果您在控制台同时看到两个回调 URL 设置（2.0版本格式和3.0版本格式），请填写3.0版本。如下图所示：

步骤6：测试 Demo

按照上传视频 - 本地上传步骤的说明，上传一个测试视频到云点播，注意上传过程选择默认的只上传，暂不进行视频处理。上传完成后，在已上传标签页可以看到该视频的状态为处理中，说明 Demo 接收到了 NewFileUpload 事件通知并发起了转码请求。

等待视频处理完成（状态变为“正常”）后，单击快捷查看，在页面右侧可以看到该视频有两个转码视频。如下图所示：

说明

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

相似文档

腾讯云云函数实战教程 - SCF + SMS 实现短信验证码功能
通过手机短信发送验证码，是最普遍、最安全验证用户真实身份的方式。目前，短信验证码广泛应用于用户注册、密码找回、登录保护、身份认证、随机密码、交易确认等应用场景。本文以使用云函数开发一个短信验证码登录注册服务为例，帮助您了解如何实现短信验证码功能。
腾讯云云函数实战教程 - SCF + ES 快速构建搜索服务
搜索服务：搜索服务广泛的存在于我们身边，例如我们生活中用的百度、工作中用的 wiki 搜索、淘宝时用的商品搜索等。这些场景的数据具有数据量大、结构化、读多写少等特点，而传统的数据库的事务特性在搜索场景并没有很好的使用空间，并且在全文检索方面速度慢（如 like 语句）。因此，Elasticsearch 应运而生。
腾讯云云函数实战教程 - 定时任务处理概述
通过云函数定时触发器，您可以快速创建定时任务，无需提前购买计算资源。云函数定时触发器依赖于 Serverless 强大的弹性扩缩容能力，可提供稳定快捷的定时任务处理能力。
腾讯云云函数实战教程 - SCF + 定时任务实现页面内容定时采集
操作场景：本文使用了云函数 SCF，并在函数中通过 puppeteer 实现定时对页面内容进行采集、数据存储等任务。用户还可以通过函数执行数据爬取、定时签到、网页巡检等复杂的 Web 定时任务。
腾讯云云函数实战教程 - SCF + 定时任务实现定时拨测并通过邮件发送告警
操作场景：在本示例中，我们用到了云函数 SCF ，并在函数中实现特定 URL 列表的拨测，对测试失败的 URL 发送告警邮件。我们可以给该函数配置一个定时触发器，按照每小时或者每天的频度定时执行。