腾讯云点播VOD主要用于视频资源的上传和在线播放,腾讯云官方文档也有许多相关操作的介绍,但是关于Python的文档相对较少,这里我想分享一下在Python方面自己对腾讯云VOD的研究(记得看注释)。
必备知识基础:
JavaScript,Python,Django
1、上传视频到腾讯云
1.1开通腾讯云点播VOD
地址:https://console.cloud.tencent.com/vod/overview
1.2引入js
官方文档地址:https://cloud.tencent.com/document/product/266/9239
前端引入axios.js(用于向后台发送请求,如果使用ajax请求则忽略),引入vod-js-sdk-v6(用于上传视频至腾讯云)
<script src="//cdnjs.cloudflare.com/ajax/libs/axios/0.18.0/axios.js"></script>
<script src="//unpkg.com/vod-js-sdk-v6"></script>
1.3生成签名并上传视频
官方文档地址:https://cloud.tencent.com/document/product/266/9219(刚刚看了一下,今天才有Python生成签名的教程,白忙了)
前端js
const tcVod = new TcVod.default({//生成签名才能上传视频getSignature: getSignature // 前文中所述的获取上传签名的函数,这里必须是函数体,不能调用函数,即getSignature()});
const uploader = tcVod.upload({mediaFile: video_file, // 媒体文件(视频或音频或图片),类型为 File});
// 视频上传完成时uploader.on('media_upload', function(info) {// uploaderInfo.isVideoUploadSuccess = true;console.log(info);});// 视频上传进度uploader.on('media_progress', function(info) {// uploaderInfo.progress = info.percent;});// 封面上传完成时uploader.on('cover_upload', function(info) {// uploaderInfo.isCoverUploadSuccess = true;console.log(info);});// 封面上传进度uploader.on('cover_progress', function(info) {// uploaderInfo.coverProgress = info.percent;console.log(info)});//视频上传结束,返回视频详情uploader.done().then(function (doneResult) {// deal with doneResultconsole.log(doneResult);}).catch(function (err) {// deal with errorconsole.log(err);})
// 生成签名function getSignature() {return axios.post('/CreateSignature这里是你后台生成签名的url/',JSON.stringify({"Action": "GetUgcUploadSign",})).then(function (response) {// console.log(response);response是后台返回的数据return response.data.data.signature;//后台返回的签名})}
后端
官方文档:https://cloud.tencent.com/document/product/266/9221
views.py python生成签名(官方刚刚已经更新了Python签名的文档,建议使用官方文档,当然,这个方法是可行的)
#生成签名
class CreateSignatureView(View):def post(self,request):try:#currentTimeStamp:当前时间戳,expireTime:签名有效期时间戳,random:无符号32位随机数,procedure:任务流模板名(记得先开启你的任务流,在VOD首页可以找到)Original = 'secretId={}¤tTimeStamp={}&expireTime={}&random={}&procedure={}'.format(mykey.secretId, int(time.time()),int(time.time()) + 10000,random.randint(1000, 9999999),'xxx')#通过hmac加密和base64编码生成签名,需要填你的secretKeySignatureTmp = str(base64.b64encode(hmac.new(mykey.secretKey.encode('utf-8'), Original.encode('utf-8'), sha1).digest() + Original.encode('utf-8')), 'utf-8')except Exception as e:logger.error(e)return to_json_data(errno=Code.UNKOWNERR,errmsg=error_map[Code.UNKOWNERR])return to_json_data(errno=Code.OK,data={"signature":SignatureTmp})#to_json_data是自己用JsonResponse封装的类,这里直接使用JsonResponse即可,返回前端signature
生成后的签名可以在 https://video.qcloud.com/signature/ugcdecode.html?_ga=1.186305964.442939846.1570722999 校验
上面生成签名的算法通过对比签名生成工具(https://video.qcloud.com/signature/ugcgenerate.html?_ga=1.147964338.442939846.1570722999)生成的字符和自己用base64生成的字符即可知
urls.py
如果你开启csrf,请使用csrf_exempt取消单个类的csrf,让前端POST请求通过,或者在前端带上csrf(不做介绍,请参考:http://www.liujiangblog.com/course/django/179)
from django.views.decorators.csrf import csrf_exempt
path('CreateSignature/',csrf_exempt(views.CreateSignatureView.as_view()),name='CreateSignature'),
到这里就已经完成了视频上传,剩下的前端获取视频等基础操作不做介绍
2、获取上传后视频的详情
视频刚上传时,只能获取到视频原始的地址,但是我们需要更多的参数,比如:图片封面(如果你没有上传封面),图片gif,时长等等,这就需要我们通过获取视频的回调来得到这些数据
2.1开启回调
地址:https://console.cloud.tencent.com/vod/callback
在腾讯云点播VOD首页的回调设置开通回调,这里我使用可靠回调,勾上需要的回调,比如我需要截图,就勾上 视频按时间点截图完成回调
2.2设置任务流
地址:https://cloud.tencent.com/document/product/266/33819
2.3获取Python生成taskid和查询任务详情的代码
TaskId生成地址:https://console.cloud.tencent.com/api/explorer?Product=vod&Version=2018-07-17&Action=ProcessMedia&SignVersion= (选填参数参考:https://cloud.tencent.com/document/api/266/31773#AnimatedGraphicTaskInput)
任务(视频)详情生成地址:https://console.cloud.tencent.com/api/explorer?Product=vod&Version=2018-07-17&Action=DescribeTaskDetail&SignVersion= (TaskId填生成地址生成的TaskId)(参数和返回数据参考:https://cloud.tencent.com/document/product/266/33431)
2.4获取任务详情(视频处理后的数据)
前端js
let $video_id;
//获取文件iduploader.done().then(function (doneResult) {// deal with doneResultconsole.log(doneResult);// $video_url.val(doneResult.video.url);$video_id = doneResult.fileId;//获取文件id// console.log($video_id)getVideoResponse({'video_title':video_title});}).catch(function (err) {// deal with errorconsole.log(err);})
//获取回调function getVideoResponse() {console.log($video_id);console.log(extra_data['video_title']);return axios.post('/GetVideoResponse这里是后台处理回调的url/',JSON.stringify({"fileId": $video_id,//必传参数,fileId为视频上传后返回的文件id})).then(function (response) {console.log(response);//获取图片和gif,数据来自后台$return_image_url = response.data.data.result.ProcedureTask.MediaProcessResultSet[1].CoverBySnapshotTask.Output.CoverUrl;$return_image_gif_url = response.data.data.result.ProcedureTask.MediaProcessResultSet[0].AnimatedGraphicTask.Output.Url;// console.log($return_image_url);//获取时长,数据来自后台let duration = response.data.data.result.ProcedureTask.MetaData.Duration;return response.data.data.result;})}
后端
views.py
#视频回调
class GetVideoResponseView(View):def post(self,request):#获取前端传的数据json_data = request.bodyif not json_data:return to_json_data(errno=Code.UNKOWNERR,errmsg=error_map[Code.UNKOWNERR])#自己用JsonResponse写的to_json_data,无需关心,直接使用JsonResponse返回即可try:#转为字典dict_data = json.loads(json_data.decode('utf-8'))except Exception as e:logger.error(e)return to_json_data(errno=Code.UNKOWNERR,errmsg=error_map[Code.UNKOWNERR])#获取fileIdtry:fileId = dict_data['fileId']except Exception as e:logger.error('fileId错误:{}'.format(e))return to_json_data(errno=Code.UNKOWNERR,errmsg=error_map[Code.UNKOWNERR])try:task_id = getVideoTaskId(fileId) #生成TaskIdresult = json.loads(getVideoResponse(task_id)) #回调视频详情数据except Exception as e:logger.error(e)return to_json_data(errno=Code.UNKOWNERR,errmsg=error_map[Code.UNKOWNERR])return to_json_data(errno=Code.OK,data={'result':result})
getVideoTaskId生成TaskId
from tencentcloud.common import credential
from tencentcloud.common.profile.client_profile import ClientProfile
from tencentcloud.common.profile.http_profile import HttpProfile
from tencentcloud.common.exception.tencent_cloud_sdk_exception import TencentCloudSDKException
from tencentcloud.vod.v20180717 import vod_client, models
from utils.tenxunyun import mykey#生成TaskId
def getVideoTaskId(FileId):try:cred = credential.Credential(mykey.secretId, mykey.secretKey)httpProfile = HttpProfile()httpProfile.endpoint = "vod.tencentcloudapi.com"clientProfile = ClientProfile()clientProfile.httpProfile = httpProfileclient = vod_client.VodClient(cred, "", clientProfile)req = models.ProcessMediaRequest()params = '{"FileId":"%s","MediaProcessTask":{"AnimatedGraphicTaskSet":[{"Definition":20000,"StartTimeOffset":0,"EndTimeOffset":0}],"CoverBySnapshotTaskSet":[{"Definition":10,"PositionType":"Time","PositionValue":0}]}}'%FileIdreq.from_json_string(params)resp = client.ProcessMedia(req)print(resp.to_json_string())# print(resp.TaskId)# print(type(resp.TaskId))return resp.TaskIdexcept TencentCloudSDKException as err:print(err)return Noneif __name__ == '__main__':FileId = '52**8907****9726**7'#视频上传后返回的idgetVideoTaskId(FileId)
getVideoResponse回调数据
import time
from tencentcloud.common import credential
from tencentcloud.common.profile.client_profile import ClientProfile
from tencentcloud.common.profile.http_profile import HttpProfile
from tencentcloud.common.exception.tencent_cloud_sdk_exception import TencentCloudSDKException
from tencentcloud.vod.v20180717 import vod_client, models
from utils.tenxunyun import mykey
import jsondef getVideoResponse(TaskId):try:cred = credential.Credential(mykey.secretId, mykey.secretKey)#你的secretId、secretKeyhttpProfile = HttpProfile()httpProfile.endpoint = "vod.tencentcloudapi.com"clientProfile = ClientProfile()clientProfile.httpProfile = httpProfileclient = vod_client.VodClient(cred, "", clientProfile)req = models.DescribeTaskDetailRequest()params = '{"TaskId":"%s"}'%TaskIdreq.from_json_string(params)resp = client.DescribeTaskDetail(req)# print(resp.to_json_string())# print(resp.Status)#为了避免腾讯云未处理完而获取数据不全的情况,需要多次请求以获取全部数据,这里不使用递归,占内存而且多次返回,难以获取最底层的值while resp.Status != "FINISH":req.from_json_string(params)resp = client.DescribeTaskDetail(req)return resp.to_json_string()except TencentCloudSDKException as err:print(err)return Noneif __name__ == '__main__':from utils.tenxunyun.getTaskId import getVideoTaskIdFileId = '52**8907****9726**7'task_id = getVideoTaskId(FileId)print(task_id)result = getVideoResponse(task_id)print('*'*100)print(result)
urls.py
和上面相同,需要取消单个类的csrf
path('GetVideoResponse/',csrf_exempt(views.GetVideoResponseView.as_view()),name='GetVideoResponse'),
到这里,就可以拿到视频回调的详情数据了
如果上面的步骤有不懂的地方,可加Q群聊,812653899
[助力产业智慧升级,云服务器首年88元起,更有千元代金券礼包免费领!]