1.本发明实施例涉及数据处理技术领域,具体涉及一种直播审核文件的生成方法、系统、调度节点及计算设备。
背景技术:2.随着科技及社会的不断发展,直播产品的出现极大丰富了人们的工作与生活。为了保障直播合法合规,以及提升用户体验,直播产品需要对直播流进行审核。在对直播流进行审核之前,需先生成直播流的直播审核文件,例如生成直播流的录制视频或截图图像等等。然而,发明人在实施过程中发现,现有技术中存在如下缺陷:直播产品在生成直播流的直播审核文件过程中,其运维成本较高,并且直播审核文件的生成效率低下。
技术实现要素:3.鉴于现有技术中存在的直播产品运维成本高以及直播审核文件生成效率低下的技术问题,提出了本发明实施例,以便提供一种克服上述问题或者至少部分地解决上述问题的直播审核文件的生成方法、系统、调度节点及计算设备。
4.根据本发明实施例的第一方面,提供了一种直播审核文件的生成方法,包括:主播端向第一边缘计算节点推送直播流;第一边缘计算节点接收直播流,向调度节点发送转推请求;调度节点接收转推请求,确定能够提供直播审核文件生成服务的目标集群,获取目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息,根据处理能力参考信息从至少一个边缘计算节点中确定第二边缘计算节点;将第二边缘计算节点的节点信息发送至第一边缘计算节点;第一边缘计算节点基于节点信息,将直播流转推至第二边缘计算节点;第二边缘计算节点对直播流进行处理,以生成直播流对应的直播审核文件。
5.在一种可选的方式中,确定能够提供直播审核文件生成服务的目标集群包括:确定部署有直播审核文件生成服务的目标集群;或者,确定部署有直播审核文件生成服务,并且直播审核文件生成服务的负荷低于最大负荷的目标集群。
6.在一种可选的方式中,确定部署有直播审核文件生成服务,并且直播审核文件生成服务的负荷低于最大负荷的目标集群包括:获取预先生成的配置文件;配置文件中包含有任一集群是否部署有直播审核文件生成服务的信息,以及包含有集群部署的直播审核文件生成服务的最大负荷;基于配置文件,确定部署有直播审核文件生成服务,并且直播审核文件生成服务的负荷低于最大负荷的目标集群。
7.在一种可选的方式中,配置文件通过如下方式生成:针对于任一集群,若该集群中至少一个边缘计算节点部署有直播审核文件生成服务,则确定该集群部署有直播审核文件生成服务;若该集群中的边缘计算节点均未部署直播审核文件生成服务,则确定该集群未部署直播审核文件生成服务;和/或,针对于部署有直播审核文件生成服务的任一集群,对该集群的直播审核文件生成服务进行压力测试,以获得该集群的直播审核文件生成服务的最大负荷;其中,最大负荷包括:cpu最大使用率和/或处理的直播流的数量上限。
8.在一种可选的方式中,处理能力参考信息基于如下数据中的至少一种获得:是否部署有直播审核文件生成服务、cpu利用率、尚未处理完成的直播流的数目、以及内存剩余容量。
9.在一种可选的方式中,处理能力参考信息包括处理能力参考值;获取目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息进包括:针对于目标集群包含的任一边缘计算节点,判断该边缘计算节点是否部署有直播审核文件生成服务;若否,则确定该边缘计算节点的直播审核文件生成服务的处理能力参考值为预设值;若是,则获取该边缘计算节点当前的预设性能指标值,根据预设性能指标值,确定该边缘计算节点的直播审核文件生成服务的处理能力参考值;根据预设性能指标值确定的直播审核文件生成服务的处理能力参考值大于预设值;其中,预设性能指标包括以下指标中的至少一种:cpu利用率、尚未处理完成的直播流的数目、以及内存剩余容量。
10.在一种可选的方式中,根据处理能力参考信息从至少一个边缘计算节点中确定出第二边缘计算节点包括:从至少一个边缘计算节点中识别出候选边缘计算节点;候选边缘计算节点的处理能力参考值高于第一边缘计算节点的处理能力参考值;从候选边缘计算节点中确定出第二边缘计算节点。
11.在一种可选的方式中,从候选边缘计算节点中确定出第二边缘计算节点包括:从候选边缘计算节点中选取处理能力参考最高的边缘计算节点,作为第二边缘计算节点。
12.在一种可选的方式中,在主播端向第一边缘计算节点推送直播流之前方法还包括:主播端向调度节点发送推流请求,调度节点接收推流请求;则确定能够提供直播审核文件生成服务的目标集群在调度节点接收推流请求之后执行;在确定能够提供直播审核文件生成服务的目标集群之后方法还包括:从目标集群中至少一个边缘计算节点中确定出第一边缘计算节点,将第一边缘计算节点的节点信息发送至主播端;主播端向第一边缘计算节点推送直播流包括主播端基于第一边缘计算节点的节点信息,向第一边缘计算节点推送直播流。
13.在一种可选的方式中,在主播端向调度节点发送推流请求之前,方法还包括:主播端向dns服务节点发送推流请求;dns服务节点接收推流请求,向主播端反馈调度节点的节点信息;主播端向调度节点发送推流请求包括主播端基于调度节点的节点信息,向调度节点发送推流请求。
14.在一种可选的方式中,确定能够提供直播审核文件生成服务的目标集群包括:获取主播端的地理位置信息和/或运营商信息;确定与主播端的地理位置信息和/或运营商信息匹配的集群;判断匹配的集群是否能够提供直播审核文件生成服务;若是,则将匹配的集群作为目标集群;若否,从能够提供直播审核文件生成服务的集群中确定出目标集群。
15.在一种可选的方式中,从目标集群中至少一个边缘计算节点中确定出第一边缘计算节点包括:根据任一边缘计算节点当前的预设信息,从目标集群中至少一个边缘计算节点中确定出第一边缘计算节点;其中,预设信息包括:与主播端的距离信息和/或网络状态信息。
16.在一种可选的方式中,调度节点接收转推请求,确定能够提供直播审核文件生成服务的目标集群包括:判断第一边缘计算节点隶属的集群是否能够提供直播审核文件生成服务;若是,将第一边缘计算节点隶属的集群确定为目标集群,并执行获取目标集群中至少
一个边缘计算节点的直播审核文件生成服务的处理能力参考信息,并根据处理能力参考信息从至少一个边缘计算节点中确定出第二边缘计算节点的步骤。
17.在一种可选的方式中,若第一边缘计算节点隶属的集群无法提供直播审核文件生成服务,则方法还包括:调度节点从能够提供直播审核文件生成服务的集群中确定目标集群,并从目标集群的上行边缘计算节点中确定出第三边缘计算节点,向第一边缘计算节点反馈第三边缘计算节点的节点信息;第一边缘计算节点基于第三边缘计算节点的节点信息,将直播流转推至第三边缘计算节点;第三边缘计算节点向调度节点发送转推请求;调度节点接收转推请求,执行获取目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息,并根据处理能力参考信息从至少一个边缘计算节点中确定出第二边缘计算节点的步骤,并将第二边缘计算节点的节点信息发送至第三边缘计算节点;第三边缘计算节点基于第二边缘计算节点的节点信息,将直播流转推至第二边缘计算节点。
18.在一种可选的方式中,在主播端向第一边缘计算节点推送直播流之前,方法还包括:主播端向dns服务节点发送推流请求;dns服务节点向主播端反馈第一边缘计算节点的节点信息;则主播端向第一边缘计算节点推送直播流包括:主播端基于第一边缘计算节点的节点信息,向第一边缘计算节点推送直播流。
19.在一种可选的方式中,方法还包括:针对于任一集群,获取该集群的直播审核文件生成服务的供需数据;基于供需数据,生成边缘计算节点部署优化方案;其中,供需数据包括:集群中部署有直播审核文件生成服务的边缘计算节点的数目,集群在预设时间窗口内接收到的需提供直播审核文件生成服务的直播流的数目,集群的直播审核文件生成服务的最大负荷,集群的带宽配置量、和/或集群的带宽使用量。
20.根据本发明实施例的第二方面,提供了一种直播审核文件的生成方法,包括:接收第一边缘计算节点发送的转推请求,确定能够提供直播审核文件生成服务的目标集群;其中,第一边缘计算节点接收主播端推送的直播流;获取目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息;根据处理能力参考信息从至少一个边缘计算节点中确定出第二边缘计算节点;将第二边缘计算节点的节点信息发送至第一边缘计算节点,以供第一边缘计算节点将直播流转推至第二边缘计算节点后,第二边缘计算节点对直播流进行处理,以生成直播流对应的直播审核文件。
21.在一种可选的方式中,确定能够提供直播审核文件生成服务的目标集群包括:确定部署有直播审核文件生成服务的目标集群;或者,确定部署有直播审核文件生成服务,并且直播审核文件生成服务的负荷低于最大负荷的目标集群。
22.在一种可选的方式中,确定部署有直播审核文件生成服务,并且直播审核文件生成服务的负荷低于最大负荷的目标集群包括:获取预先生成的配置文件;配置文件中包含有任一集群是否部署有直播审核文件生成服务的信息,以及包含有集群部署的直播审核文件生成服务的最大负荷;基于配置文件,确定部署有直播审核文件生成服务,并且直播审核文件生成服务的负荷低于最大负荷的目标集群。
23.在一种可选的方式中,配置文件通过如下方式生成:针对于任一集群,若该集群中至少一个边缘计算节点部署有直播审核文件生成服务,则确定该集群部署有直播审核文件生成服务;若该集群中的边缘计算节点均未部署直播审核文件生成服务,则确定该集群未部署直播审核文件生成服务;和/或,针对于部署有直播审核文件生成服务的任一集群,对
该集群的直播审核文件生成服务进行压力测试,以获得该集群的直播审核文件生成服务的最大负荷;其中,最大负荷包括:cpu最大使用率和/或处理的直播流的数量上限。
24.在一种可选的方式中,处理能力参考信息基于如下数据中的至少一种获得:是否部署有直播审核文件生成服务、cpu利用率、尚未处理完成的直播流的数目、以及内存剩余容量。
25.在一种可选的方式中,处理能力参考信息包括:处理能力参考值;获取目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息包括:针对于目标集群包含的任一边缘计算节点,判断该边缘计算节点是否部署有直播审核文件生成服务;若否,则确定该边缘计算节点的直播审核文件生成服务的处理能力参考值为预设值;若是,则获取该边缘计算节点当前的预设性能指标值,根据预设性能指标值,确定该边缘计算节点的直播审核文件生成服务的处理能力参考值;根据预设性能指标值确定的直播审核文件生成服务的处理能力参考值大于预设值;其中,预设性能指标包括以下指标中的至少一种:cpu利用率、尚未处理完成的直播流的数目、以及内存剩余容量。
26.在一种可选的方式中,根据处理能力参考信息从至少一个边缘计算节点中确定出第二边缘计算节点包括:从至少一个边缘计算节点中识别出候选边缘计算节点;候选边缘计算节点的处理能力参考值高于第一边缘计算节点的处理能力参考值;
27.在一种可选的方式中,从候选边缘计算节点中确定出第二边缘计算节点包括:从候选边缘计算节点中选取处理能力参考值最高的边缘计算节点,作为第二边缘计算节点。
28.在一种可选的方式中,在第一边缘计算节点接收主播端推送的直播流之前,方法还包括:接收主播端发起的推流请求,确定能够提供直播审核文件生成服务的目标集群,从目标集群中至少一个边缘计算节点中确定出第一边缘计算节点,并将第一边缘计算节点的节点信息发送至主播端。
29.在一种可选的方式中,确定能够提供直播审核文件生成服务的目标集群包括:获取主播端的地理位置信息和/或运营商信息;确定与主播端的地理位置信息和/或运营商信息匹配的集群;判断匹配的集群是否能够提供直播审核文件生成服务;若是,将匹配的集群作为目标集群;若否,从能够提供直播审核文件生成服务的集群中确定出目标集群。
30.在一种可选的方式中,从目标集群中至少一个边缘计算节点中确定出第一边缘计算节点包括:根据任一边缘计算节点当前的预设信息,从目标集群中至少一个边缘计算节点中确定出第一边缘计算节点;其中,预设信息包括:与主播端的距离信息和/或网络状态信息。
31.在一种可选的方式中,确定能够提供直播审核文件生成服务的目标集群包括:判断第一边缘计算节点隶属的集群是否能够提供直播审核文件生成服务;若是,将第一边缘计算节点隶属的集群确定为目标集群,并执行获取目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息,根据处理能力参考信息从至少一个边缘计算节点中确定出第二边缘计算节点的步骤。
32.在一种可选的方式中,若第一边缘计算节点隶属的集群无法提供直播审核文件生成服务,则方法还包括:从能够提供直播审核文件生成服务的集群中确定目标集群,并从目标集群的上行边缘计算节点中确定出第三边缘计算节点,向第一边缘计算节点反馈第三边缘计算节点的节点信息,以供第一边缘计算节点将直播流转推至第三边缘计算节点;接收
第三边缘计算节点发送的转推请求,执行获取目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息,并根据处理能力参考信息从至少一个边缘计算节点中确定出第二边缘计算节点的步骤;将第二边缘计算节点的节点信息发送至第三边缘计算节点,以供第三边缘计算节点将直播流转推至第二边缘计算节点。
33.根据本发明实施例第三方面,提供了一种直播审核文件的生成方法,包括:接收主播端推送的直播流;向调度节点发送转推请求,以供调度节点从能够提供直播审核文件生成服务的目标集群中确定出第二边缘计算节点;第二边缘计算节点基于目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息确定;将直播流转推至第二边缘计算节点,以供第二边缘计算节点对直播流进行处理,以生成直播流对应的直播审核文件。
34.根据本发明实施例第四方面,提供了一种直播审核文件的生成方法,包括:接收第一边缘计算节点转推的直播流;第一边缘计算节点接收主播端推送的直播流;对直播流进行处理,以生成直播流对应的直播审核文件。
35.根据本发明实施例第五方面,提供了一种直播审核文件的生成系统,包括:主播端,用于向第一边缘计算节点推送直播流;第一边缘计算节点,用于接收直播流,并向调度节点发送转推请求,以及将直播流转推至第二边缘计算节点;调度节点,用于接收转推请求,确定能够提供直播审核文件生成服务的目标集群;以及获取目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息,并根据处理能力参考信息从至少一个边缘计算节点中确定出第二边缘计算节点;将第二边缘计算节点的节点信息发送至第一边缘计算节点;第二边缘计算节点,用于对直播流进行处理,以生成直播流对应的直播审核文件。
36.根据本发明实施例第六方面,提供了一种调度节点,包括:接收模块,用于接收第一边缘计算节点发送的转推请求;第一确定模块,用于确定能够提供直播审核文件生成服务的目标集群;第一边缘计算节点接收主播端推送的直播流;获取模块,用于获取目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息;第二确定模块,用于根据处理能力参考信息从至少一个边缘计算节点中确定出第二边缘计算节点;发送模块,用于将第二边缘计算节点的节点信息发送至第一边缘计算节点,以供第一边缘计算节点将直播流转推至第二边缘计算节点后,第二边缘计算节点对直播流进行处理,以生成直播流对应的直播审核文件。
37.根据本发明实施例第七方面,提供了一种边缘计算节点,包括:接收模块,用于接收主播端推送的直播流;请求模块,用于向调度节点发送转推请求,以供调度节点从能够提供直播审核文件生成服务的目标集群中确定出第二边缘计算节点;第二边缘计算节点基于目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息确定;转推模块,用于将直播流转推至第二边缘计算节点,以供第二边缘计算节点对直播流进行处理,以生成直播流对应的直播审核文件。
38.根据本发明实施例第八方面,提供了一种边缘计算节点,包括:接收模块,用于接收第一边缘计算节点转推的直播流;第一边缘计算节点接收主播端推送的直播流;处理模块,用于对直播流进行处理,以生成直播流对应的直播审核文件。
39.根据本发明实施例第九方面,提供了一种计算设备,包括:处理器、存储器、通信接
口和通信总线,处理器、存储器和通信接口通过通信总线完成相互间的通信;存储器用于存放至少一可执行指令,可执行指令使处理器执行上述直播审核文件的生成方法对应的操作。
40.根据本发明实施例第十方面,提供了一种计算机存储介质,存储介质中存储有至少一可执行指令,可执行指令使处理器执行上述直播审核文件的生成方法对应的操作。
41.本发明实施例中,第一边缘计算节点在接收到主播端推送的直播流之后,并未将直播流推送给第三方cdn节点,而是向调度节点发送转推请求,由调度节点确定出第二边缘计算节点,由第二边缘计算节点生成直播流的直播审核文件,从而节约直播产品的运维成本;而且,本发明实施例是基于目标集群中边缘计算节点的直播审核文件服务处理能力参数确定第二边缘计算节点,由此能够提升直播审核文件的生成效率。
42.本发明实施例中,确定部署有直播审核文件生成服务的目标集群;或者,确定部署有直播审核文件生成服务,并且直播审核文件生成服务的负荷低于最大负荷的目标集群,由此提升目标集群的确定精度以及提升直播审核文件的处理效率。
43.本发明实施例中,获取预先生成的配置文件,配置文件中包含有任一集群是否部署有直播审核文件生成服务的信息,以及包含有集群部署的直播审核文件生成服务的最大负荷;基于配置文件,确定目标集群,由此提升目标集群的确定效率。
44.本发明实施例中,针对于任一集群,若该集群中至少一个边缘计算节点部署有直播审核文件生成服务,则确定该集群部署有直播审核文件生成服务;若该集群中的边缘计算节点均未部署直播审核文件生成服务,则确定该集群未部署直播审核文件生成服务;和/或,针对于部署有直播审核文件生成服务的任一集群,对该集群的直播审核文件生成服务进行压力测试,以获得该集群的直播审核文件生成服务的最大负荷;其中,最大负荷包括:cpu最大使用率和/或处理的直播流的数量上限,由此提升配置文件的精准度
45.本发明实施例中,根据是否部署有直播审核文件生成服务、cpu利用率、尚未处理完成的直播流的数目、和/或内存剩余容量能够准确地评估直播审核文件生成服务的处理能力,提升处理能力参考信息的精准度。
46.本发明实施例中,针对于目标集群包含的任一边缘计算节点,判断该边缘计算节点是否部署有直播审核文件生成服务;若否,则确定该边缘计算节点的直播审核文件生成服务的处理能力参考值为预设值;若是,则获取该边缘计算节点当前的预设性能指标值,根据预设性能指标值,确定该边缘计算节点的直播审核文件生成服务的处理能力参考值;根据预设性能指标值确定的直播审核文件生成服务的处理能力参考信息大于预设值,由此能够通过处理能力参考值准确评估边缘计算节点的直播审核文件生成服务的处理能力。而且,本发明实施例中预设性能指标包括以下指标中的至少一种:cpu利用率、尚未处理完成的直播流的数目、以及内存剩余容量,进一步提升处理能力参考信息的精准度。
47.本发明实施例中,识别处理能力参考值高于第一边缘计算节点的候选边缘计算节点,从候选计算节点中确定出第二边缘计算节点,相较于由第一边缘计算节点直接生成直播审核文件,采用该种方式能够提升直播审核文件的生成效率。
48.本发明实施例中,将处理能力参考值最高的边缘计算节点,确定为第二边缘计算节点,由此能够提升直播审核文件的生成效率。
49.本发明实施例中,主播端向调度节点发送推流请求,调度节点接收推流请求,确定
能够提供直播审核文件生成服务的目标集群,并从目标集群中至少一个边缘计算节点中确定出第一边缘计算节点,将第一边缘计算节点的节点信息发送至主播端,由此能够使得第一边缘计算节点与第二边缘计算节点位于同一集群中,提升直播流的转推效率以及提升直播审核文件的生成效率。
50.本发明实施例中,主播端向dns服务节点发送推流请求,dns服务节点接收推流请求,向主播端反馈调度节点的节点信息,主播端基于调度节点的节点信息,向调度节点发送推流请求,由此能够由调度节点来为主播端分配第一边缘计算节点,由此提升直播流的推流效率。
51.本发明实施例中,获取主播端的地理位置信息和/或运营商信息;确定与主播端的地理位置信息和/或运营商信息匹配的集群;判断匹配的集群是否能够提供直播审核文件生成服务;若是,则将匹配的集群作为目标集群;若否,从能够提供直播审核文件生成服务的集群中确定出目标集群。采用该种方式,能够优先由与主播端信息匹配的边缘计算节点作为直播流的推流及转推节点,由此提升直播流的推流及转推效率。
52.本发明实施例中,根据任一边缘计算节点当前的预设信息,从目标集群中至少一个边缘计算节点中确定出第一边缘计算节点;其中,预设信息包括:与主播端的距离信息和/或网络状态信息。采用该种方式能够提升直播流的推流效率。
53.本发明实施例中,判断第一边缘计算节点隶属的集群是否能够提供直播审核文件生成服务;若是,将第一边缘计算节点隶属的集群确定为目标集群,并执行获取目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息,并根据处理能力参考信息从至少一个边缘计算节点中确定出第二边缘计算节点的步骤。采用该种方式,第一边缘计算节点与第二边缘计算节点处于同一集群,由此提升直播流的转推效率以及提升直播审核文件的生成效率。
54.本发明实施例中,若第一边缘计算节点隶属的集群无法提供直播审核文件生成服务,则调度节点从能够提供直播审核文件生成服务的集群中确定目标集群,并从目标集群的上行边缘计算节点中确定出第三边缘计算节点,由第三边缘计算节点将直播流转推至第二边缘计算节点,由此保障直播审核文件的顺利生成。
55.本发明实施例中,主播端向dns服务节点发送推流请求,dns服务节点向主播端反馈第一边缘计算节点的节点信息,由此提升第一边缘计算节点的确定效率。
56.本发明实施例中,针对于任一集群,获取该集群的直播审核文件生成服务的供需数据;基于供需数据,生成边缘计算节点部署优化方案;其中,供需数据包括:集群中部署有直播审核文件生成服务的边缘计算节点的数目,集群在预设时间窗口内接收到的需提供直播审核文件生成服务的直播流的数目,集群的直播审核文件生成服务的最大负荷,集群的带宽配置量、和/或集群的带宽使用量。采用该种方式,能够优化当前的边缘计算节点的部署,提升系统整体的处理能力,提升用户体验。
57.上述说明仅是本发明实施例技术方案的概述,为了能够更清楚了解本发明实施例的技术手段,而可依照说明书的内容予以实施,并且为了让本发明实施例的上述和其它目的、特征和优点能够更明显易懂,以下特举本发明实施例的具体实施方式。
附图说明
58.通过阅读下文优选实施方式的详细描述,各种其他的优点和益处对于本领域普通技术人员将变得清楚明了。附图仅用于示出优选实施方式的目的,而并不认为是对本发明实施例的限制。而且在整个附图中,用相同的参考符号表示相同的部件。在附图中:
59.图1示出了本发明实施例提供的一种直播审核文件的生成系统的架构示意图;
60.图2示出了本发明实施例提供的一种直播审核文件的生成方法的流程示意图;
61.图3示出了本发明实施例提供的一种第二边缘计算节点的确定方法的流程示意图;
62.图4示出了本发明实施例提供的一种直播审核文件生成服务的处理能力参考信息的确定方法的流程示意图;
63.图5示出了本发明实施例提供的另一种直播审核文件的生成方法的流程示意图;
64.图6示出了本发明实施例提供的一种基于httpdns调度的第一边缘计算节点的节点信息获取方式示意图;
65.图7示出了本发明实施例提供的一种直播流的流向示意图;
66.图8示出了本发明实施例提供的又一种直播审核文件的生成方法的流程示意图;
67.图9示出了本发明实施例提供的一种基于dns调度的第一边缘计算节点的节点信息获取方式示意图;
68.图10示出了本发明实施例提供的再一种直播审核文件的生成方法的流程示意图;
69.图11示出了本发明实施例提供的另一种直播流的流向示意图;
70.图12示出了本发明实施例提供的又一种直播审核文件的生成方法的流程示意图;
71.图13示出了本发明实施例提供的再一种直播审核文件的生成方法的流程示意图;
72.图14示出了本发明实施例提供的又一种直播审核文件的生成方法的流程示意图;
73.图15示出了本发明实施例提供的一种直播审核文件的生成系统的结构示意图;
74.图16示出了本发明实施例提供的一种调度节点的结构示意图;
75.图17示出了本发明实施例提供的一种边缘计算节点的结构示意图;
76.图18示出了本发明实施例提供的另一种边缘计算节点的结构示意图;
77.图19示出了本发明实施例提供的一种计算设备的结构示意图。
具体实施方式
78.下面将参照附图更详细地描述本发明实施例的示例性实施例。虽然附图中显示了本发明实施例的示例性实施例,然而应当理解,可以以各种形式实现本发明实施例而不应被这里阐述的实施例所限制。相反,提供这些实施例是为了能够更透彻地理解本发明实施例,并且能够将本发明实施例的范围完整的传达给本领域的技术人员。
79.本技术发明人分析发现,图1为一种可选的直播审核文件的生成系统的架构方式。该种架构方式是由主播端将直播流推送至一个边缘计算节点,该边缘计算节点再将所有的直播流转推至第三方cdn(content delivery network,内容分发网络)节点,第三方cdn节点是直播产品之外的其他cdn节点。第三方cdn节点对直播流进行截图、录制,以生成直播流的直播审核文件。观众端可以从该第三方cdn节点进行拉流观看。发明人通过对图1所示架构仔细分析发现,图1所示架构中需要第三方cdn节点进行截图、录制,从而会增加直播产品
的运维成本;边缘计算节点在将直播流转推至第三方cdn节点时,需要传输格式、协议等适配,导致直播审核文件生成效率低下。基于此,本发明实施例通过后续实施例优化来解决直播产品运维成本高及直播审核文件生成效率低下的技术问题。
80.图2示出了本发明实施例提供的一种直播审核文件的生成方法的流程示意图。本实施例中的流程图不用于对执行步骤的顺序进行限定。根据需要还可以对该流程图中的部分步骤进行添加或删减。下面以直播审核文件的生成系统作为执行主体对该方法进行说明。如图2所示,该方法具体包括如下步骤:
81.步骤s210,主播端向第一边缘计算节点推送直播流。
82.本发明实施例中,直播流可以为音频流、视频流、图片流和/或文字流等数据流。主播端可以是指主播所使用的终端设备,该主播端又可以称为直播流的生产端,即直播流源自于主播端产出的数据。边缘计算节点为直播产品部署的直播服务器,其一般为分布于不同地区、地理上接近主播用户和/或观众用户的直播服务器。主播端将产出的直播流推送至直播产品部署的一个边缘计算节点,接收主播端推送的直播流的边缘计算节点,便是本发明实施例的第一边缘计算节点。
83.步骤s220,第一边缘计算节点接收直播流,并向调度节点发送转推请求。
84.第一边缘计算节点接收到主播端推送的直播流后,向调度节点发送转推请求,以便于确定该直播流的直播审核文件的生成节点。其中,调度节点可以是直播产品部署的计算设备。
85.步骤s230,调度节点接收转推请求,确定能够提供直播审核文件生成服务的目标集群;以及获取目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息,并根据处理能力参考信息从至少一个边缘计算节点中确定出第二边缘计算节点。
86.调度节点接收到第一边缘计算节点发送的转推请求后,确定出生成该直播流的直播审核文件的边缘计算节点,该用于生成该直播流的直播审核文件的边缘计算节点便是第二边缘计算节点。在此应当理解的是,本发明实施例中第一边缘计算节点和第二边缘计算节点是与直播流相对应的,即一个直播流对应于一个第一边缘计算节点以及一个第二边缘计算节点,该第一边缘计算节点是该直播流的推流节点,该第二边缘计算节点是该直播流的直播审核文件生成节点。具体地,直播流的第二边缘计算节点可以通过图3所示步骤s231-步骤s233确定。其中,步骤s231-步骤s233如下方所示:
87.步骤s231,确定能够提供直播审核文件生成服务的目标集群。
88.直播产品通常会部署多个边缘计算节点,每个边缘计算节点隶属于相应的集群。例如,在实际的实施过程中,根据边缘计算节点所处的地理位置范围和/或所属的运营商的不同,将边缘计算节点划归为相应的集群,该集群可以为“华北电信”等等。本发明实施例是先确定出第二边缘计算节点所处的集群,该第二边缘计算节点所处的集群便是目标集群。具体地,从能够提供直播审核文件生成服务的集群中筛选出目标集群。直播审核文件生成服务是用于对直播流进行处理以生成直播审核文件的服务。
89.在一种可选的目标集群确定方式中,确定部署有直播审核文件生成服务的目标集群。其中,若集群中有至少一个边缘计算节点部署有直播审核文件生成服务,则表明该集群部署有直播审核文件生成服务。采用该种方式,能够快速地确定出目标集群。
90.在另一种可选的目标集群确定方式中,确定部署有直播审核文件生成服务,并且
直播审核文件生成服务的负荷低于最大负荷的目标集群,即目标集群不仅部署有直播审核文件生成服务,而且该直播审核文件生成服务当前的负荷低于该集群的直播审核文件生成服务的最大负荷,由此表明目标集群当前仍然有提供直播审核文件生成服务的能力。采用该种方式,能够避免因目标集群中直播审核文件生成服务负荷高,而无法对当前直播流进行处理的技术弊端,从而提升直播流的直播审核文件的生成效率。
91.进一步可选的,获取预先生成的配置文件;配置文件中包含有任一集群是否部署有直播审核文件生成服务的信息,以及包含有集群部署的直播审核文件生成服务的最大负荷;基于配置文件,确定部署有直播审核文件生成服务,并且直播审核文件生成服务的负荷低于最大负荷的目标集群。本方式中,通过预先生成的配置文件能够快速地确定出集群是否部署有直播审核文件生成服务,并能够快速地确定出部署有直播审核文件生成服务的集群该服务的最大负荷,由此提升目标集群的确定效率。
92.进一步可选的,该配置文件具体通过如下方式确定:针对于任一集群,若该集群中至少一个边缘计算节点部署有直播审核文件生成服务,则确定该集群部署有直播审核文件生成服务;若该集群中的边缘计算节点均未部署直播审核文件生成服务,则确定该集群未部署直播审核文件生成服务;和/或,针对于部署有直播审核文件生成服务的任一集群,对该集群的直播审核文件生成服务进行压力测试,以获得该集群的直播审核文件生成服务的最大负荷;其中,最大负荷包括:cpu最大使用率和/或处理的直播流的数量上限。本发明实施例对具体的压力测试方式不作限定,例如,压力测试的具体过程可以为:利用压测脚本不断地增加该集群的直播审核文件生成服务的负荷,并采集该集群的相关信息,该相关信息包括但不限于:集群中边缘计算节点整体的cpu利用率、内存使用量、直播审核文件生成速率、和/或当前处理的直播流数量。继而根据该相关信息确定该集群的直播审核文件生成服务的最大负荷。由于当达到磁盘的读写性能瓶颈或者cpu使用率过高时,文件会因为无法及时写入磁盘而报错,也会因为集群处理的直播流的数量流过大,而导致直播审核文件生成速率较低或接近于0。基于此,本发明实施例在直播审核文件生成速率低于预设速率,和/或、内存使用量超过预设容量,和/或,产生文件写入报错时,确定当前集群中边缘计算节点整体的cpu利用率,并将该cpu利用率作为该集群的直播审核文件生成服务的cpu最大使用率,将当前该集群处理的直播流的数量作为该集群的直播审核文件生成服务的处理的直播流的数量上限。在此应当理解的是,该集群的直播审核文件生成服务的最大负荷是集群能够承载的直播审核文件生成服务的最大负荷,换言之,是该集群中所有边缘计算节点整体能够承载的直播审核文件生成服务的最大负荷。此外,该配置文件还可以包括集群中部署有直播审核文件生成服务的边缘计算节点的数量等信息。
93.步骤s232,获取目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息。
94.目标集群部署有直播审核文件生成服务,并且,目标集群包含有至少一个边缘计算节点,每个边缘计算节点当前对应于一个直播审核文件生成服务的处理能力参考信息,该直播审核文件生成服务的处理能力参考信息是能够表征该边缘计算节点当前提供的直播审核文件生成服务的处理能力情况的信息。该处理能力参考信息具体可以为处理能力参考值,该参考值越高,表明该边缘计算节点当前直播审核文件生成服务的能力越高,该参数值越低,表明该边缘计算节点当前直播审核文件生成服务的能力越低。可选的,处理能力参
考信息基于如下数据中的至少一种获得:是否部署有直播审核文件生成服务、cpu利用率、尚未处理完成的直播流的数目、以及内存剩余容量。
95.在一种可选的方式中,为了能够准确地评估出边缘计算节点的直播审核文件生成服务处理能力,边缘计算节点的直播审核文件生成服务的处理能力参考信息可以通过图4所示步骤s2321-步骤s2323确定。其中,步骤s2321-步骤s2323具体实施过程如下:
96.步骤s2321,针对于目标集群包含的任一边缘计算节点,判断该边缘计算节点是否部署有直播审核文件生成服务;若否,则执行步骤s2322;若是,则执行步骤s2323。
97.在目标集群部署直播审核文件生成服务时,可以将目标集群中所有边缘计算节点均部署直播审核文件生成服务,也可以将目标集群中部分边缘计算节点部署直播审核文件生成服务。则本步骤需判断任一边缘计算节点是否部署有直播审核文件生成服务。
98.步骤s2322,确定该边缘计算节点的直播审核文件生成服务的处理能力参考值为预设值。若边缘计算节点并未部署直播审核文件生成服务,则确定该边缘计算节点的直播审核文件生成服务的处理能力参考值为预设值。该预设值可以为0。
99.步骤s2323,获取该边缘计算节点当前的预设性能指标值,根据预设性能指标值,确定该边缘计算节点的直播审核文件生成服务的处理能力参考值。
100.本步骤根据预设性能指标值确定的直播审核文件生成服务的处理能力参考信息大于步骤s2322所述的预设值。可选的,预设性能指标值包括以下指标中的至少一种:cpu利用率、尚未处理完成的直播流的数目、以及内存剩余容量。其中,直播审核文件生成服务的处理能力参考值负相关于cpu利用率,和/或,直播审核文件生成服务的处理能力参考值负相关于尚未处理完成的直播流的数目,直播审核文件生成服务的处理能力参考值正相关于内存剩余容量,即该边缘计算节点当前的cpu利用率越低,尚未处理完成的直播流的数目越少、内存剩余容量越高,则直播审核文件生成服务的处理能力参考值越高。采用上述指标能够准确地评估出边缘计算节点的直播审核文件生成服务处理能力,有利于后续直播审核文件生成效率的提升。
101.步骤s233,根据处理能力参考信息从至少一个边缘计算节点中确定出第二边缘计算节点。
102.具体地,从至少一个边缘计算节点中识别出候选边缘计算节点,该候选边缘计算节点的处理能力参考值高于第一边缘计算节点的处理能力参考值,从候选边缘计算节点中确定出第二边缘计算节点。由此后续由处理能力参考值高的边缘计算节点生成直播审核文件。可选的,可以从候选边缘计算节点中选取处理能力参考值最高的边缘计算节点,作为第二边缘计算节点,从而能够利用当前直播审核文件生成服务处理能力最优的边缘计算节点生成当前直播流的直播审核文件,从而提升直播审核文件的生成效率;还可以随机获取一个候选边缘计算节点作为第二边缘计算节点,等等。
103.步骤s240,调度节点将第二边缘计算节点的节点信息发送至第一边缘计算节点。
104.其中,第二边缘计算节点的节点信息具体是能够唯一确定出第二边缘计算节点的信息,该节点信息包括但不限于ip地址、域名。
105.步骤s250,第一边缘计算节点基于节点信息,将直播流转推至第二边缘计算节点。
106.步骤s260,第二边缘计算节点对直播流进行处理,以生成直播流对应的直播审核文件。
107.具体地,第二边缘计算节点对直播流进行录制和/或截图,以生成直播流对应的录制视频和/或截图图像。即,本发明实施例所述的直播审核文件包括:录制视频和/或截图图像。由此,后续审核端可以基于生成的直播审核文件进行直播流合规性、合法性等审核。更具体地,第二边缘计算节点部署有直播审核文件生成服务,则第二边缘计算节点具体是利用直播审核文件生成服务生成直播流对应的直播审核文件。
108.由此可见,本发明实施例第一边缘计算节点在接收到主播端推送的直播流之后,并未将直播流推送给第三方cdn节点,而是向调度节点发送转推请求,由调度节点确定出第二边缘计算节点,由第二边缘计算节点生成直播流的直播审核文件,从而节约直播产品的运维成本;而且,本发明实施例是基于目标集群中边缘计算节点的直播审核文件服务处理能力参数确定第二边缘计算节点,由此能够提升直播审核文件的生成效率。
109.图5示出了本发明实施例提供的另一种直播审核文件的生成方法的流程示意图。其中,本实施例中的流程图不用于对执行步骤的顺序进行限定。根据需要,还可以对该流程图中的部分步骤进行添加或删减。下面以直播审核文件的生成系统作为执行主体对该方法进行说明。如图5所示,该方法具体包括如下步骤:
110.步骤s510,主播端向调度节点发送推流请求。
111.在一种可选的方式中,本实施例是基于httpdns调度机制实施的。如图6所示,主播端向调度节点发送推流请求之前,主播端向dns服务节点发送推流请求,该dns服务节点是dns计算设备,其负责接收主播端的推流请求,并可以提供推流地址或域名解析服务等等。在httpdns调度机制中,dns服务节点向主播端反馈的是一个调度地址,本实施例中,dns服务节点接收推流请求,向主播端反馈调度节点的节点信息。则本步骤主播端基于调度节点的节点信息,向调度节点发送推流请求,并后续接收调度节点反馈的第一边缘计算节点的节点信息。
112.步骤s520,调度节点接收推流请求,确定能够提供直播审核文件生成服务的目标集群,从目标集群包含的至少一个边缘计算节点中确定出第一边缘计算节点。
113.调度节点接收到推流请求之后,首先确定目标集群。该目标集群的确定方式可以参照图2实施例中的描述,在此不作赘述。另外,在本实施例中,目标集群还可以通过如下方式确定:获取主播端的地理位置信息和/或运营商信息,并确定与主播端的地理位置信息和/或运营商信息匹配的集群;进一步判断该匹配的集群是否部署有直播审核文件生成服务;若是,则将该匹配的集群作为目标集群;若否,从部署有直播审核文件生成服务的集群中确定出目标集群。其中,可以通过对主播端ip地址的解析获得主播端的地理位置信息以及运营商信息。示例说明,若确定出主播端地理位置信息为“华北”,运营商信息为“电信”,则从各个集群中确定出与地理位置信息“华北”以及运营商信息“电信”匹配的“华北电信”集群。进一步判断“华北电信”集群是否部署有直播审核文件生成服务,若是,则将“华北电信”集群确定为目标集群;若否,则从其他部署有直播审核文件生成服务的集群中确定目标集群。其中,若其他部署有直播审核文件生成服务的集群有多个,则从该多个集群中获取与主播端的地理位置信息和/或运营商信息相似度最高的集群作为目标集群。采用该种方式,可以优先将能够提供直播审核文件生成服务以及与主播端的地理位置信息和/或运营商信息匹配的集群确定为目标集群,由此能够提升直播流的推流速度,提升用户体验以及进一步提高直播审核文件的生成效率。
114.在确定出目标集群之后,进一步从目标集群包含的至少一个边缘计算节点中确定出第一边缘计算节点。具体地,可以根据任一边缘计算节点当前的预设信息,从目标集群包含的至少一个边缘计算节点中确定出第一边缘计算节点;其中,预设信息包括:与主播端的距离信息和/或网络状态信息。例如,可以从目标集群中选取与主播端的距离最近,网络状态良好的边缘计算节点作为第一边缘计算节点,从而提升直播流的推流效率。
115.步骤s530,调度节点将第一边缘计算节点的节点信息发送至主播端。
116.步骤s540,主播端基于第一边缘计算节点的节点信息,向第一边缘计算节点推送直播流。
117.步骤s550,第一边缘计算节点向调度节点发送转推请求。
118.步骤s560,调度节点接收转推请求,从目标集群中确定出第二边缘计算节点。
119.本实施例中,由于第一边缘计算节点是从能够提供直播审核文件生成服务的目标集群中获取,由此本步骤在执行时直接将第一边缘计算节点隶属的集群作为目标集群,并从目标集群中确定出第二边缘计算节点。
120.步骤s570,调度节点将第二边缘计算节点的节点信息发送至第一边缘计算节点。
121.步骤s580,第一边缘计算节点基于第二边缘计算节点的节点信息,将直播流转推至第二边缘计算节点。
122.步骤s590,第二边缘计算节点对直播流进行处理,以生成直播流对应的直播审核文件。
123.以图7为例,主播端将直播流推流至第一边缘计算节点,第一边缘计算节点将直播流转推至同属于目标集群的第二边缘计算节点,由第二边缘计算节点对直播流进行处理,以生成直播审核文件。回源cdn可以进行回源,从第一边缘计算节点中获取直播流,观众端从回源cdn拉流观看。
124.由此可见,本发明实施例在能够节约直播产品的运维成本以及提升直播审核文件的生成效率的基础上,从部署有直播审核文件生成服务的目标集群中确定出第一边缘计算节点,从而后续确定出的第二边缘计算节点与第一边缘计算节点隶属同一集群,由此提升直播流的转推效率,继而提升直播审核文件的生成效率。
125.图8示出了本发明实施例提供的又一种直播审核文件的生成方法的流程示意图。其中,本实施例中的流程图不用于对执行步骤的顺序进行限定。根据需要,还可以对该流程图中的部分步骤进行添加或删减。下面以直播审核文件的生成系统作为执行主体对该方法进行说明。如图8所示,该方法具体包括如下步骤:
126.步骤s810,主播端向第一边缘计算节点推送直播流。
127.在一种可选的方式中,本实施例是基于dns调度机制实施的。如图9所示,主播端向第一边缘计算节点推送直播流之前,主播端向dns服务节点发送推流请求,在dns调度机制中,dns服务节点直接向主播端反馈的是第一边缘计算节点的节点信息,则主播端基于第一边缘计算节点的节点信息,向第一边缘计算节点推送直播流。
128.步骤s820,调度节点接收推流请求,判断第一边缘计算节点隶属的集群是否能够提供直播审核文件生成服务;若是,则执行步骤s830。
129.与图5所示实施例不同的是,本实施例调度节点接收推流请求,先判断第一边缘计算节点隶属的集群是否能够提供直播审核文件生成服务。若是,将第一边缘计算节点隶属
的集群确定为目标集群,并执行后续步骤s830-步骤s860。
130.步骤s830,调度节点将第一边缘计算节点隶属的集群确定为目标集群,并从目标集群中确定出第二边缘计算节点。
131.若第一边缘计算节点隶属的集群能够提供直播审核文件生成服务,则直接将该集群确定为目标集群,从而后续从目标集群中确定的第二边缘计算节点于第一边缘计算节点能够同属于同一集群,由此提升第一边缘计算节点与第二边缘计算节点间的数据传输路径以及传输效率,由此提升转推效率及提高直播审核文件的生成效率。本步骤具体是将第一边缘计算节点隶属的集群确定为目标集群,并获取目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息,并根据直播审核文件生成服务的处理能力参考信息从至少一个边缘计算节点中确定出第二边缘计算节点。
132.步骤s840,调度节点将第二边缘计算节点的节点信息发送至第一边缘计算节点。
133.步骤s850,第一边缘计算节点基于第二边缘计算节点的节点信息,将直播流转推至第二边缘计算节点。
134.步骤s860,第二边缘计算节点对直播流进行处理,以生成直播流对应的直播审核文件。
135.本实施例中直播流的流向可参照图7,在此不做赘述。
136.由此可见,发明实施例在能够节约直播产品的运维成本以及提升直播审核文件的生成效率的基础上,调度节点判断第一边缘计算节点隶属的集群是否能够提供直播审核文件生成服务,若是,将第一边缘计算节点隶属的集群确定为目标集群,从而使得第二边缘计算节点与第一边缘计算节点隶属同一集群,由此提升直播流的转推效率,继而提升直播审核文件的生成效率。
137.图10示出了本发明实施例提供的再一种直播审核文件的生成方法的流程示意图。其中,本实施例中的流程图不用于对执行步骤的顺序进行限定。根据需要,还可以对该流程图中的部分步骤进行添加或删减。下面以直播审核文件的生成系统作为执行主体对该方法进行说明。如图10所示,该方法具体包括如下步骤:
138.步骤s1000,主播端向第一边缘计算节点推送直播流。
139.步骤s1010,调度节点接收推流请求,判断第一边缘计算节点隶属的集群是否能够提供直播审核文件生成服务;若否,则执行步骤s1020。
140.本实施例与图8所示实施例不同的是,在判断第一边缘计算节点隶属的集群无法提供直播审核文件生成服务后,通过后续步骤s1020-s1090实施。
141.步骤s1020,调度节点从能够提供直播审核文件生成服务的集群中确定目标集群,并从目标集群的上行边缘计算节点中确定出第三边缘计算节点。
142.其中,上行边缘计算节点是指能够提供外网ip的节点。由于直播审核文件生成服务通常为内网服务,部署有直播审核文件生成服务的边缘计算节点的ip通常为内网ip。由此若直接将第二边缘计算节点的节点信息反馈给第一边缘计算节点,由于第二边缘计算节点与第一边缘计算节点分属于不同的集群,由此会出现第一边缘计算节点无法向第二边缘计算节点推流的弊端。鉴于此,本发明实施例在确定出目标集群之后,先从目标集群的上行边缘计算节点中确定出第三边缘计算节点,由于第三边缘计算节点具有外网ip,由此目标集群以外的集群中第一边缘计算节点能够准确地向该第三边缘计算节点转推直播流。
143.步骤s1030,调度节点向第一边缘计算节点反馈目标集群中第三边缘计算节点的节点信息。
144.步骤s1040,第一边缘计算节点基于第三边缘计算节点的节点信息,将直播流转推至第三边缘计算节点。
145.步骤s1050,第三边缘计算节点向调度节点发送转推请求。
146.步骤s1060,调度节点接收转推请求,从目标集群中确定出第二边缘计算节点。
147.具体地,调度节点接收转推请求,获取目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息,并根据直播审核文件生成服务的处理能力参考信息从至少一个边缘计算节点中确定出第二边缘计算节点。
148.步骤s1070,调度节点向第三边缘计算节点反馈第二边缘计算节点的节点信息。
149.步骤s1080,第三边缘计算节点基于第二边缘计算节点的节点信息,将直播流转推至第二边缘计算节点。
150.步骤s1090,第二边缘计算节点对直播流进行处理,以生成直播流对应的直播审核文件。
151.本实施例中直播流的流向可参照图11。如图11所示,主播端将直播流推流至第一边缘计算节点,第一边缘计算节点将直播流转推至目标集群的第三边缘计算节点,该第三边缘计算节点与第一边缘计算节点分属于不同的集群。继而第三边缘计算节点将直播流转推至同属于目标集群的第二边缘计算节点,由第二边缘计算节点对直播流进行处理,以生成直播审核文件。回源cdn可以进行回源,从第一边缘计算节点中获取直播流,观众端从回源cdn拉流观看。
152.由此可见,发明实施例在能够节约直播产品的运维成本以及提升直播审核文件的生成效率的基础上,调度节点判断第一边缘计算节点隶属的集群是否能够提供直播审核文件生成服务,若第一边缘计算节点隶属的集群无法提供直播审核文件生成服务,则将其他能够提供直播审核文件生成服务的集群中确定目标集群,从而保障直播审核文件的顺利生成。
153.此外,作为本发明一个可选的实施例,还可以针对于任一集群,获取该集群的直播审核文件生成服务供需数据;基于该供需数据,生成边缘计算节点部署优化方案,从而便于对边缘计算节点的部署进行优化。其中,供需数据包括:集群中部署有直播审核文件生成服务的边缘计算节点的数目,集群在预设时间窗口内接收到的需提供直播审核文件生成服务的直播流的数目,集群的直播审核文件生成服务的最大负荷,集群的带宽配置量、和/或集群的带宽使用量。举例来说,若集群中带宽使用量与带宽配置量的比值超过预设阈值,则确定需在该集群中部署新的边缘计算节点;若集群中边缘计算节点的数目小于预设数目,则确定需在该集群中增设部署直播审核文件生成服务的边缘计算节点;若集群在预设时间窗口内接收到的需提供直播审核文件生成服务的直播流的数目大于集群的直播审核文件生成服务的最大负荷,则确定需在该集群中增设部署有直播审核文件生成服务的边缘计算节点。若集群的带宽使用量与带宽配置量的比值超过预设阈值,则确定需在该集群中部署新的边缘计算节点。
154.图12示出了本发明实施例提供的又一种直播审核文件的生成方法的流程示意图。其中,本实施例中的流程图不用于对执行步骤的顺序进行限定。根据需要还可以对该流程
图中的部分步骤进行添加或删减。下面以调度节点作为执行主体对该方法进行说明。如图12所示,该方法具体包括如下步骤:
155.步骤s1210,接收第一边缘计算节点发送的转推请求,确定能够提供直播审核文件生成服务的目标集群;其中,第一边缘计算节点接收主播端推送的直播流。
156.步骤s1220,获取目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息。
157.步骤s1230,根据处理能力参考信息从至少一个边缘计算节点中确定出第二边缘计算节点。
158.步骤s1240,将第二边缘计算节点的节点信息发送至第一边缘计算节点,以供第一边缘计算节点将直播流转推至第二边缘计算节点后,第二边缘计算节点对直播流进行处理,以生成直播流对应的直播审核文件。
159.在一种可选的方式中,确定能够提供直播审核文件生成服务的目标集群包括:确定部署有直播审核文件生成服务的目标集群;或者,确定部署有直播审核文件生成服务,并且直播审核文件生成服务的负荷低于最大负荷的目标集群。
160.在一种可选的方式中,确定部署有直播审核文件生成服务,并且直播审核文件生成服务的负荷低于最大负荷的目标集群包括:获取预先生成的配置文件;配置文件中包含有任一集群是否部署有直播审核文件生成服务的信息,以及包含有集群部署的直播审核文件生成服务的最大负荷;基于配置文件,确定部署有直播审核文件生成服务,并且直播审核文件生成服务的负荷低于最大负荷的目标集群。
161.在一种可选的方式中,配置文件通过如下方式生成:针对于任一集群,若该集群中至少一个边缘计算节点部署有直播审核文件生成服务,则确定该集群部署有直播审核文件生成服务;若该集群中的边缘计算节点均未部署直播审核文件生成服务,则确定该集群未部署直播审核文件生成服务;和/或,针对于部署有直播审核文件生成服务的任一集群,对该集群的直播审核文件生成服务进行压力测试,以获得该集群的直播审核文件生成服务的最大负荷;最大负荷包括:cpu最大使用率和/或处理的直播流的数量上限。
162.在一种可选的方式中,处理能力参考信息基于如下数据中的至少一种获得:是否部署有直播审核文件生成服务、cpu利用率、尚未处理完成的直播流的数目、以及内存剩余容量。
163.在一种可选的方式中,处理能力参考信息包括:处理能力参考值;获取目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息包括:针对于目标集群包含的任一边缘计算节点,判断该边缘计算节点是否部署有直播审核文件生成服务;若否,则确定该边缘计算节点的直播审核文件生成服务的处理能力参考值为预设值;若是,则获取该边缘计算节点当前的预设性能指标值,根据预设性能指标值,确定该边缘计算节点的直播审核文件生成服务的处理能力参考值;根据预设性能指标值确定的直播审核文件生成服务的处理能力参考值大于预设值;其中,预设性能指标包括以下指标中的至少一种:cpu利用率、尚未处理完成的直播流的数目、以及内存剩余容量。
164.在一种可选的方式中,根据处理能力参考信息从至少一个边缘计算节点中确定出第二边缘计算节点包括:从至少一个边缘计算节点中识别出候选边缘计算节点;候选边缘计算节点的处理能力参考值高于第一边缘计算节点的处理能力参考值;从候选边缘计算节
点中确定出第二边缘计算节点。
165.在一种可选的方式中,从候选边缘计算节点中确定出第二边缘计算节点包括:从候选边缘计算节点中选取处理能力参考值最高的边缘计算节点,作为第二边缘计算节点。
166.在一种可选的方式中,在第一边缘计算节点接收主播端推送的直播流之前,方法还包括:接收主播端发起的推流请求,确定能够提供直播审核文件生成服务的目标集群,从目标集群中至少一个边缘计算节点中确定出第一边缘计算节点,并将第一边缘计算节点的节点信息发送至主播端。
167.在一种可选的方式中,确定能够提供直播审核文件生成服务的目标集群包括:获取主播端的地理位置信息和/或运营商信息;确定与主播端的地理位置信息和/或运营商信息匹配的集群;判断匹配的集群是否能够提供直播审核文件生成服务;若是,则将匹配的集群作为目标集群;若否,从能够提供直播审核文件生成服务的集群中确定出目标集群。
168.在一种可选的方式中,从目标集群中至少一个边缘计算节点中确定出第一边缘计算节点包括:根据任一边缘计算节点当前的预设信息,从目标集群中至少一个边缘计算节点中确定出第一边缘计算节点;预设信息包括:与主播端的距离信息和/或网络状态信息。
169.在一种可选的方式中,确定能够提供直播审核文件生成服务的目标集群包括:判断第一边缘计算节点隶属的集群是否能够提供直播审核文件生成服务;若是,将第一边缘计算节点隶属的集群确定为目标集群,并执行获取目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息,根据处理能力参考信息从至少一个边缘计算节点中确定出第二边缘计算节点的步骤。
170.在一种可选的方式中,若第一边缘计算节点隶属的集群无法提供直播审核文件生成服务,则方法还包括:从能够提供直播审核文件生成服务的集群中确定目标集群,并从目标集群的上行边缘计算节点中确定出第三边缘计算节点,向第一边缘计算节点反馈第三边缘计算节点的节点信息,以供第一边缘计算节点将直播流转推至第三边缘计算节点;接收第三边缘计算节点发送的转推请求,执行获取目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息,并根据处理能力参考信息从至少一个边缘计算节点中确定出第二边缘计算节点的步骤;将第二边缘计算节点的节点信息发送至第三边缘计算节点,以供第三边缘计算节点将直播流转推至第二边缘计算节点。
171.由此可见,本发明实施例能够取得降低直播产品运维成本,以及提升直播审核文件生成效率的技术效果。
172.图13示出了本发明实施例提供的再一种直播审核文件的生成方法的流程示意图。其中,本实施例中的流程图不用于对执行步骤的顺序进行限定。根据需要还可以对该流程图中的部分步骤进行添加或删减。下面以第一边缘计算节点作为执行主体对该方法进行说明。如图13所示,该方法具体包括如下步骤:
173.步骤s1310,接收主播端推送的直播流。
174.步骤s1320,向调度节点发送转推请求,以供调度节点从能够提供直播审核文件生成服务的目标集群中确定出第二边缘计算节点;其中,第二边缘计算节点基于目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息确定。
175.步骤s1330,将直播流转推至第二边缘计算节点,以供第二边缘计算节点对直播流进行处理,以生成直播流对应的直播审核文件。
176.由此可见,本发明实施例能够取得降低直播产品运维成本,以及提升直播审核文件生成效率的技术效果。
177.图14示出了本发明实施例提供的又一种直播审核文件的生成方法的流程示意图。其中,本实施例中的流程图不用于对执行步骤的顺序进行限定。根据需要,还可以对该流程图中的部分步骤进行添加或删减。下面以第二边缘计算节点作为执行主体对该方法进行说明。如图14所示,该方法具体包括如下步骤:
178.步骤s1410,接收第一边缘计算节点转推的直播流;其中,第一边缘计算节点接收主播端推送的直播流。
179.步骤s1420,对直播流进行处理,以生成直播流对应的直播审核文件。
180.由此可见,本发明实施例能够取得降低直播产品运维成本,以及提升直播审核文件生成效率的技术效果。
181.其中,不同执行主体所对应的方法实施例可以互相参照,在此不作赘述。
182.图15示出了本发明实施例提供的一种直播审核文件的生成系统的结构示意图。如图15所示,该系统1500包括:主播端1510,用于向第一边缘计算节点推送直播流;第一边缘计算节点1520,用于接收直播流,并向调度节点发送转推请求,以及将直播流转推至第二边缘计算节点;调度节点1530,用于接收转推请求,确定能够提供直播审核文件生成服务的目标集群;以及获取目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息,并根据处理能力参考信息从至少一个边缘计算节点中确定出第二边缘计算节点;将第二边缘计算节点的节点信息发送至第一边缘计算节点;第二边缘计算节点1540,用于对直播流进行处理,以生成直播流对应的直播审核文件。
183.在一种可选的方式中,调度节点用于确定部署有直播审核文件生成服务的目标集群;或者,确定部署有直播审核文件生成服务,并且直播审核文件生成服务的负荷低于最大负荷的目标集群。
184.在一种可选的方式中,调度节点用于获取预先生成的配置文件;配置文件中包含有任一集群是否部署有直播审核文件生成服务的信息,以及包含有集群部署的直播审核文件生成服务的最大负荷;基于配置文件,确定部署有直播审核文件生成服务,并且直播审核文件生成服务的负荷低于最大负荷的目标集群。
185.在一种可选的方式中,该系统还包括配置节点,配置节点用于根据如下方式生成配置文件:针对于任一集群,若该集群中至少一个边缘计算节点部署有直播审核文件生成服务,则确定该集群部署有直播审核文件生成服务;若该集群中的边缘计算节点均未部署直播审核文件生成服务,则确定该集群未部署直播审核文件生成服务;和/或,针对于部署有直播审核文件生成服务的任一集群,对该集群的直播审核文件生成服务进行压力测试,以获得该集群的直播审核文件生成服务的最大负荷;最大负荷包括:cpu最大使用率和/或处理的直播流的数量上限。
186.在一种可选的方式中,调度节点用于处理能力参考信息基于如下数据中的至少一种获得:是否部署有直播审核文件生成服务、cpu利用率、尚未处理完成的直播流的数目、以及内存剩余容量。
187.在一种可选的方式中,调度节点用于针对于目标集群包含的任一边缘计算节点,判断该边缘计算节点是否部署有直播审核文件生成服务;若否,则确定该边缘计算节点的
直播审核文件生成服务的处理能力参考信息为预设值;若是,则获取该边缘计算节点当前的预设性能指标值,根据预设性能指标值,确定该边缘计算节点的直播审核文件生成服务的处理能力参考值;根据预设性能指标值确定的直播审核文件生成服务的处理能力参考值大于预设值;其中,预设性能指标包括以下指标中的至少一种:cpu利用率、尚未处理完成的直播流的数目、以及内存剩余容量。
188.在一种可选的方式中,调度节点用于从至少一个边缘计算节点中识别出候选边缘计算节点;候选边缘计算节点的处理能力参考值高于第一边缘计算节点的处理能力参考值;从候选边缘计算节点中确定出第二边缘计算节点。
189.在一种可选的方式中,调度节点用于从候选边缘计算节点中选取处理能力参考值最高的边缘计算节点,作为第二边缘计算节点。
190.在一种可选的方式中,主播端用于向调度节点发送推流请求,以及基于第一边缘计算节点的节点信息,向第一边缘计算节点推送直播流;调度节点用于接收推流请求,确定能够提供直播审核文件生成服务的目标集群,从目标集群中至少一个边缘计算节点中确定出第一边缘计算节点,并将第一边缘计算节点的节点信息发送至主播端。
191.在一种可选的方式中,该系统还包括dns服务节点,主播端用于向dns服务节点发送推流请求,以及基于调度节点的节点信息向调度节点发送推流请求;dns服务节点用于接收推流请求,向主播端反馈调度节点的节点信息。
192.在一种可选的方式中,调度节点用于获取主播端的地理位置信息和/或运营商信息;确定与主播端的地理位置信息和/或运营商信息匹配的集群;判断匹配的集群是否能够提供直播审核文件生成服务;若是,则将匹配的集群作为目标集群;若否,从能够提供直播审核文件生成服务的集群中确定出目标集群。
193.在一种可选的方式中,调度节点用于根据任一边缘计算节点当前的预设信息,从目标集群中至少一个边缘计算节点中确定出第一边缘计算节点;预设信息包括与主播端的距离信息和/或网络状态信息。
194.在一种可选的方式中,调度节点用于判断第一边缘计算节点隶属的集群是否能够提供直播审核文件生成服务;若是,将第一边缘计算节点隶属的集群确定为目标集群,并执行获取目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息,根据处理能力参考信息从至少一个边缘计算节点中确定出第二边缘计算节点的步骤。
195.在一种可选的方式中,调度节点用于:若第一边缘计算节点隶属的集群无法提供直播审核文件生成服务,从能够提供直播审核文件生成服务的集群中确定目标集群,并从目标集群的上行边缘计算节点中确定出第三边缘计算节点,向第一边缘计算节点反馈第三边缘计算节点的节点信息;以及,接收第三边缘计算节点的转推请求,执行获取目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息,并根据处理能力参考信息从至少一个边缘计算节点中确定出第二边缘计算节点的步骤,并将第二边缘计算节点的节点信息发送至第三边缘计算节点;第一边缘计算节点用于基于第三边缘计算节点的节点信息,将直播流转推至第三边缘计算节点;该系统还包括第三边缘计算节点,其用于向调度节点发送转推请求,以及将直播流转推至第二边缘计算节点。
196.在一种可选的方式中,主播端用于向dns服务节点发送推流请求;dns服务节点用于向主播端反馈第一边缘计算节点的节点信息。
197.在一种可选的方式中,该系统还包括部署优化模块,用于针对于任一集群,获取该集群的直播审核文件生成服务的供需数据;基于供需数据,生成边缘计算节点部署优化方案;其中,供需数据包括:集群中部署有直播审核文件生成服务的边缘计算节点的数目,集群在预设时间窗口内接收到的需提供直播审核文件生成服务的直播流的数目,集群的直播审核文件生成服务的最大负荷,集群的带宽配置量、和/或集群的带宽使用量。
198.由此可见,本本发明实施例能够降低直播产品运维成本,以及提升直播审核文件生成效率。
199.图16示出了本发明实施例提供的一种调度节点的结构示意图。如图16所示,调度节点1530包括:接收模块1531,用于接收第一边缘计算节点发送的转推请求;第一确定模块1532,用于确定能够提供直播审核文件生成服务的目标集群;第一边缘计算节点接收主播端推送的直播流;获取模块1533,用于获取目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息;第二确定模块1534,用于根据处理能力参考信息从至少一个边缘计算节点中确定出第二边缘计算节点;发送模块1535,用于将第二边缘计算节点的节点信息发送至第一边缘计算节点,以供第一边缘计算节点将直播流转推至第二边缘计算节点后,第二边缘计算节点对直播流进行处理,以生成直播流对应的直播审核文件。
200.在一种可选的方式中,第一确定模块用于确定部署有直播审核文件生成服务的目标集群;或者,确定部署有直播审核文件生成服务,直播审核文件生成服务的负荷低于最大负荷的目标集群。
201.在一种可选的方式中,第一确定模块用于:获取预先生成的配置文件;配置文件中包含有任一集群是否部署有直播审核文件生成服务的信息,以及包含有集群部署的直播审核文件生成服务的最大负荷;基于配置文件,确定部署有直播审核文件生成服务,并且直播审核文件生成服务的负荷低于最大负荷的目标集群。
202.在一种可选的方式中,配置文件通过如下方式生成:针对于任一集群,若该集群中至少一个边缘计算节点部署有直播审核文件生成服务,则确定该集群部署有直播审核文件生成服务;若该集群中的边缘计算节点均未部署直播审核文件生成服务,则确定该集群未部署直播审核文件生成服务;和/或,针对于部署有直播审核文件生成服务的任一集群,对该集群的直播审核文件生成服务进行压力测试,以获得该集群的直播审核文件生成服务的最大负荷;其中,最大负荷包括:cpu最大使用率和/或处理的直播流的数量上限。
203.在一种可选的方式中,处理能力参考信息基于如下数据中的至少一种获得:是否部署有直播审核文件生成服务、cpu利用率、尚未处理完成的直播流的数目、及内存剩余容量。
204.在一种可选的方式中,获取模块用于针对于目标集群包含的任一边缘计算节点,判断该边缘计算节点是否部署有直播审核文件生成服务;若否,确定该边缘计算节点的直播审核文件生成服务的处理能力参考信息为预设值;若是,获取该边缘计算节点当前的预设性能指标值,根据预设性能指标值,确定该边缘计算节点的直播审核文件生成服务的处理能力参考值;根据预设性能指标值确定的直播审核文件生成服务的处理能力参考值大于预设值;预设性能指标包括以下指标中的至少一种:cpu利用率、尚未处理完成的直播流的数目、以及内存剩余容量。
205.在一种可选的方式中,第二确定模块用于从至少一个边缘计算节点中识别出候选
边缘计算节点;候选边缘计算节点的处理能力参考值高于第一边缘计算节点的处理能力参考值;从候选边缘计算节点中确定出第二边缘计算节点。
206.在一种可选的方式中,第二确定模块用于从候选边缘计算节点中选取处理能力参考值最高的边缘计算节点,作为第二边缘计算节点。
207.在一种可选的方式中,调度节点还包括接收模块,用于接收主播端发起的推流请求;第三确定模块,用于确定能够提供直播审核文件生成服务的目标集群,从目标集群中至少一个边缘计算节点中确定出第一边缘计算节点;发送模块用于并将第一边缘计算节点的节点信息发送至主播端。
208.在一种可选的方式中,第一确定模块用于获取主播端的地理位置信息和/或运营商信息;确定与主播端的地理位置信息和/或运营商信息匹配的集群;判断所述匹配的集群是否能够提供直播审核文件生成服务;若是,将匹配的集群作为所述目标集群;若否,从能够提供直播审核文件生成服务的集群中确定出目标集群。
209.在一种可选的方式中,第三确定模块用于根据任一边缘计算节点当前的预设信息,从目标集群中至少一个边缘计算节点中确定出第一边缘计算节点;其中,所述预设信息包括:与主播端的距离信息和/或网络状态信息。
210.在一种可选的方式中,第一确定模块用于判断第一边缘计算节点隶属的集群是否能够提供直播审核文件生成服务;若是,将第一边缘计算节点隶属的集群确定为目标集群。
211.在一种可选的方式中,第一确定模块用于若第一边缘计算节点隶属的集群无法提供直播审核文件生成服务,从能够提供直播审核文件生成服务的集群中确定目标集群;调度节点还包括:第四确定模块用于从目标集群的上行边缘计算节点中确定出第三边缘计算节点;则发送模块进一步用于向第一边缘计算节点反馈第三边缘计算节点的节点信息,以供第一边缘计算节点将直播流转推至第三边缘计算节点;以及将第二边缘计算节点的节点信息发送至第三边缘计算节点,以供第三边缘计算节点将直播流转推至第二边缘计算节点。则接收模块进一步用于:接收第三边缘计算节点发送的转推请求。
212.由此可见,本本发明实施例能够降低直播产品运维成本,以及提升直播审核文件生成效率。
213.图17示出了本发明实施例提供的一种边缘计算节点的结构示意图。如图17所示,该边缘计算节点1520包括:接收模块1521,用于接收主播端推送的直播流;请求模块1522,用于向调度节点发送转推请求,以供调度节点从能够提供直播审核文件生成服务的目标集群中确定出第二边缘计算节点;其中,第二边缘计算节点基于目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息确定;转推模块1523,用于将直播流转推至第二边缘计算节点,以供第二边缘计算节点对直播流进行处理,以生成直播流对应的直播审核文件。
214.由此可见,本本发明实施例能够降低直播产品运维成本,以及提升直播审核文件生成效率。
215.图18示出了本发明实施例提供的另一种边缘计算节点的结构示意图。如图18所示,该边缘计算节点1540包括:接收模块1541,用于接收第一边缘计算节点转推的直播流;第一边缘计算节点接收主播端推送的直播流;处理模块1542,用于对直播流进行处理,以生成直播流对应的直播审核文件。
216.由此可见,本本发明实施例能够降低直播产品运维成本,以及提升直播审核文件生成效率。
217.图19示出了本发明实施例提供的一种计算设备的结构示意图。本发明实施例具体实施例并不对计算设备的具体实现做限定。如图19所示,该计算设备可以包括:处理器(processor)1902、通信接口(communications interface)1904、存储器(memory)1906及通信总线1908。处理器1902、通信接口1904及存储器1906通过通信总线1908完成相互间的通信。通信接口1904用于与其它设备比如客户端或其它服务器等的网元通信。处理器1902用于执行程序1910,具体可以执行上述用于直播审核文件的生成方法实施例中的相关步骤。具体地,程序1910可以包括程序代码,该程序代码包括计算机操作指令。处理器1902可能是中央处理器cpu,或者是特定集成电路asic(application specific integrated circuit),或者被配置成本发明实施例的一个或多个集成电路。计算设备包括的一个或多个处理器,可以是同一类型的处理器,如一个或多个cpu;也可以是不同类型的处理器,如一个或多个cpu以及一个或多个asic。存储器1906用于存放程序1910。存储器1906可能包含高速ram存储器,也可能还包括非易失性存储器(non-volatile memory),例如至少一个磁盘存储器。程序1910可以用于使得处理器1902执行上述任一方法实施例中的方法。
218.本发明实施例提供了一种非易失性计算机存储介质,计算机存储介质存储有至少一可执行指令,该计算机可执行指令可执行上述任意方法实施例中的直播审核文件的生成方法。
219.在此提供的算法或显示不与任何特定计算机、虚拟系统或者其它设备固有相关。各种通用系统也可以与基于在此的示教一起使用。根据上面的描述,构造这类系统所要求的结构是显而易见的。此外,本发明实施例也不针对任何特定编程语言。应当明白,可以利用各种编程语言实现在此描述的本发明实施例的内容,并且上面对特定语言所做的描述是为了披露本发明实施例的最佳实施方式。在此处所提供的说明书中,说明了大量具体细节。然而,能够理解,本发明实施例的实施例可以在没有这些具体细节的情况下实践。在一些实例中,并未详细示出公知的方法、结构和技术,以便不模糊对本说明书的理解。类似地,应当理解,为了精简本发明实施例并帮助理解各个发明方面中的一个或多个,在上面对本发明实施例的示例性实施例的描述中,本发明实施例的各个特征有时被一起分组到单个实施例、图、或者对其的描述中。然而,并不应将该公开的方法解释成反映如下意图:即所要求保护的本发明实施例要求比在每个权利要求中所明确记载的特征更多的特征。更确切地说,如下面的权利要求书所反映的那样,发明方面在于少于前面公开的单个实施例的所有特征。因此,遵循具体实施方式的权利要求书由此明确地并入该具体实施方式,其中每个权利要求本身都作为本发明实施例的单独实施例。本领域那些技术人员可以理解,可以对实施例中的设备中的模块进行自适应性地改变并且把它们设置在与该实施例不同的一个或多个设备中。可以把实施例中的模块或单元或组件组合成一个模块或单元或组件,以及此外可以把它们分成多个子模块或子单元或子组件。除了这样的特征和/或过程或者单元中的至少一些是相互排斥之外,可以采用任何组合对本说明书(包括伴随的权利要求、摘要和附图)中公开的所有特征以及如此公开的任何方法或者设备的所有过程或单元进行组合。除非另外明确陈述,本说明书(包括伴随的权利要求、摘要和附图)中公开的每个特征可以由提供相同、等同或相似目的的替代特征来代替。
220.此外,本领域的技术人员能够理解,尽管在此的一些实施例包括其它实施例中所包括的某些特征而不是其它特征,但是不同实施例的特征的组合意味着处于本发明实施例的范围之内并且形成不同的实施例。例如,在下面的权利要求书中,所要求保护的实施例的任意之一都可以以任意的组合方式来使用。本发明实施例的各个部件实施例可以以硬件实现,或者以在一个或者多个处理器上运行的软件模块实现,或者以它们的组合实现。本领域的技术人员应当理解,可以在实践中使用微处理器或者数字信号处理器(dsp)来实现根据本发明实施例的一些或者全部部件的一些或者全部功能。本发明实施例还可以实现为用于执行这里所描述的方法的一部分或者全部的设备或者装置程序(例如,计算机程序和计算机程序产品)。这样的实现本发明实施例的程序可以存储在计算机可读介质上,或者可以具有一个或者多个信号的形式。这样的信号可以从因特网网站上下载得到,或者在载体信号上提供,或者以任何其他形式提供。应该注意的是上述实施例对本发明实施例进行说明而不是对本发明实施例进行限制,并且本领域技术人员在不脱离所附权利要求的范围的情况下可设计出替换实施例。在权利要求中,不应将位于括号之间的任何参考符号构造成对权利要求的限制。单词“包含”不排除存在未列在权利要求中的元件或步骤。位于元件之前的单词“一”或“一个”不排除存在多个这样的元件。本发明实施例可以借助于包括有若干不同元件的硬件以及借助于适当编程的计算机来实现。在列举了若干装置的单元权利要求中,这些装置中的若干个可以是通过同一个硬件项来具体体现。单词第一、第二、以及第三等的使用不表示任何顺序。可将这些单词解释为名称。上述实施例中的步骤,除有特殊说明外,不应理解为对执行顺序的限定。
技术特征:1.一种直播审核文件的生成方法,其特征在于,包括:主播端向第一边缘计算节点推送直播流;所述第一边缘计算节点接收所述直播流,并向调度节点发送转推请求;所述调度节点接收所述转推请求,确定能够提供直播审核文件生成服务的目标集群;以及获取所述目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息,并根据所述处理能力参考信息从所述至少一个边缘计算节点中确定出第二边缘计算节点;将所述第二边缘计算节点的节点信息发送至所述第一边缘计算节点;所述第一边缘计算节点基于所述节点信息,将所述直播流转推至所述第二边缘计算节点;所述第二边缘计算节点对所述直播流进行处理,以生成所述直播流对应的直播审核文件。2.根据权利要求1所述的方法,其特征在于,所述确定能够提供直播审核文件生成服务的目标集群进一步包括:确定部署有直播审核文件生成服务的目标集群;或者,确定部署有直播审核文件生成服务,并且所述直播审核文件生成服务的负荷低于最大负荷的目标集群。3.根据权利要求2所述的方法,其特征在于,所述确定部署有直播审核文件生成服务,并且所述直播审核文件生成服务的负荷低于最大负荷的目标集群进一步包括:获取预先生成的配置文件;所述配置文件中包含有任一集群是否部署有直播审核文件生成服务的信息,以及包含有集群部署的直播审核文件生成服务的最大负荷;基于所述配置文件,确定部署有直播审核文件生成服务,并且所述直播审核文件生成服务的负荷低于最大负荷的目标集群。4.根据权利要求3所述的方法,其特征在于,所述配置文件通过如下方式生成:针对于任一集群,若该集群中至少一个边缘计算节点部署有直播审核文件生成服务,则确定该集群部署有直播审核文件生成服务;若该集群中的边缘计算节点均未部署直播审核文件生成服务,则确定该集群未部署直播审核文件生成服务;和/或,针对于部署有直播审核文件生成服务的任一集群,对该集群的直播审核文件生成服务进行压力测试,以获得该集群的直播审核文件生成服务的最大负荷;其中,所述最大负荷包括:cpu最大使用率和/或处理的直播流的数量上限。5.根据权利要求1-4中任一项所述的方法,其特征在于,所述处理能力参考信息基于如下数据中的至少一种获得:是否部署有直播审核文件生成服务、cpu利用率、尚未处理完成的直播流的数目、以及内存剩余容量。6.根据权利要求5所述的方法,其特征在于,所述处理能力参考信息包括:处理能力参考值;所述获取所述目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息进一步包括:针对于所述目标集群包含的任一边缘计算节点,判断该边缘计算节点是否部署有直播审核文件生成服务;
若否,则确定该边缘计算节点的直播审核文件生成服务的处理能力参考值为预设值;若是,则获取该边缘计算节点当前的预设性能指标值,根据所述预设性能指标值,确定该边缘计算节点的直播审核文件生成服务的处理能力参考值;根据所述预设性能指标值确定的直播审核文件生成服务的处理能力参考值大于所述预设值;其中,所述预设性能指标包括以下指标中的至少一种:cpu利用率、尚未处理完成的直播流的数目、以及内存剩余容量。7.根据权利要求6所述的方法,其特征在于,所述根据所述处理能力参考信息从所述至少一个边缘计算节点中确定出第二边缘计算节点进一步包括:从所述至少一个边缘计算节点中识别出候选边缘计算节点;所述候选边缘计算节点的处理能力参考值高于所述第一边缘计算节点的处理能力参考值;从所述候选边缘计算节点中确定出第二边缘计算节点。8.根据权利要求7所述的方法,其特征在于,所述从所述候选边缘计算节点中确定出第二边缘计算节点进一步包括:从所述候选边缘计算节点中选取处理能力参考值最高的边缘计算节点,作为所述第二边缘计算节点。9.根据权利要求1-8中任一项所述的方法,其特征在于,在所述主播端向第一边缘计算节点推送直播流之前,所述方法还包括:所述主播端向所述调度节点发送推流请求,所述调度节点接收所述推流请求;则所述确定能够提供直播审核文件生成服务的目标集群在所述调度节点接收所述推流请求之后执行;并且,在所述确定能够提供直播审核文件生成服务的目标集群之后,所述方法还包括:从所述目标集群中至少一个边缘计算节点中确定出第一边缘计算节点,并将所述第一边缘计算节点的节点信息发送至所述主播端;则所述主播端向第一边缘计算节点推送直播流进一步包括:所述主播端基于所述第一边缘计算节点的节点信息,向第一边缘计算节点推送直播流。10.根据权利要求9所述的方法,其特征在于,在所述主播端向所述调度节点发送推流请求之前,所述方法还包括:所述主播端向dns服务节点发送推流请求;所述dns服务节点接收所述推流请求,向主播端反馈所述调度节点的节点信息;则所述主播端向所述调度节点发送推流请求进一步包括:所述主播端基于所述调度节点的节点信息,向所述调度节点发送推流请求。11.根据权利要求9或10所述的方法,其特征在于,所述确定能够提供直播审核文件生成服务的目标集群进一步包括:获取所述主播端的地理位置信息和/或运营商信息;确定与所述主播端的地理位置信息和/或运营商信息匹配的集群;判断所述匹配的集群是否能够提供直播审核文件生成服务;若是,则将所述匹配的集群作为所述目标集群;若否,从能够提供直播审核文件生成服务的集群中确定出所述目标集群。12.根据权利要求9-11中任一项所述的方法,其特征在于,所述从所述目标集群中至少一个边缘计算节点中确定出第一边缘计算节点进一步包括:根据任一所述边缘计算节点当前的预设信息,从所述目标集群中至少一个边缘计算节
点中确定出第一边缘计算节点;其中,所述预设信息包括:与所述主播端的距离信息和/或网络状态信息。13.根据权利要求1-8中任一项所述的方法,其特征在于,所述调度节点接收所述转推请求,确定能够提供直播审核文件生成服务的目标集群进一步包括:判断所述第一边缘计算节点隶属的集群是否能够提供直播审核文件生成服务;若是,将所述第一边缘计算节点隶属的集群确定为所述目标集群,并执行所述获取所述目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息,并根据所述处理能力参考信息从所述至少一个边缘计算节点中确定出第二边缘计算节点的步骤。14.根据权利要求13所述的方法,其特征在于,若所述第一边缘计算节点隶属的集群无法提供直播审核文件生成服务,则所述方法还包括:调度节点从能够提供直播审核文件生成服务的集群中确定目标集群,并从所述目标集群的上行边缘计算节点中确定出第三边缘计算节点,向所述第一边缘计算节点反馈所述第三边缘计算节点的节点信息;所述第一边缘计算节点基于所述第三边缘计算节点的节点信息,将所述直播流转推至所述第三边缘计算节点;所述第三边缘计算节点向所述调度节点发送转推请求;所述调度节点接收所述转推请求,执行所述获取所述目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息,并根据所述处理能力参考信息从所述至少一个边缘计算节点中确定出第二边缘计算节点的步骤,并将所述第二边缘计算节点的节点信息发送至所述第三边缘计算节点;所述第三边缘计算节点基于所述第二边缘计算节点的节点信息,将所述直播流转推至所述第二边缘计算节点。15.根据权利要求13或14所述的方法,其特征在于,在所述主播端向第一边缘计算节点推送直播流之前,所述方法还包括:所述主播端向dns服务节点发送推流请求;所述dns服务节点向所述主播端反馈所述第一边缘计算节点的节点信息;则所述主播端向第一边缘计算节点推送直播流进一步包括:主播端基于所述第一边缘计算节点的节点信息,向第一边缘计算节点推送直播流。16.根据权利要求1-15中任一项所述的方法,其特征在于,所述方法还包括:针对于任一集群,获取该集群的直播审核文件生成服务的供需数据;基于所述供需数据,生成边缘计算节点部署优化方案;其中,所述供需数据包括:集群中部署有直播审核文件生成服务的边缘计算节点的数目,集群在预设时间窗口内接收到的需提供直播审核文件生成服务的直播流的数目,集群的直播审核文件生成服务的最大负荷,集群的带宽配置量、和/或集群的带宽使用量。17.一种直播审核文件的生成方法,其特征在于,包括:接收第一边缘计算节点发送的转推请求,确定能够提供直播审核文件生成服务的目标集群;其中,所述第一边缘计算节点接收主播端推送的直播流;获取所述目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参
考信息;根据所述处理能力参考信息从所述至少一个边缘计算节点中确定出第二边缘计算节点;将所述第二边缘计算节点的节点信息发送至所述第一边缘计算节点,以供所述第一边缘计算节点将所述直播流转推至第二边缘计算节点后,所述第二边缘计算节点对所述直播流进行处理,以生成所述直播流对应的直播审核文件。18.根据权利要求17所述的方法,其特征在于,所述确定能够提供直播审核文件生成服务的目标集群进一步包括:确定部署有直播审核文件生成服务的目标集群;或者,确定部署有直播审核文件生成服务,并且所述直播审核文件生成服务的负荷低于最大负荷的目标集群。19.根据权利要求18所述的方法,其特征在于,所述确定部署有直播审核文件生成服务,并且所述直播审核文件生成服务的负荷低于最大负荷的目标集群进一步包括:获取预先生成的配置文件;所述配置文件中包含有任一集群是否部署有直播审核文件生成服务的信息,以及包含有集群部署的直播审核文件生成服务的最大负荷;基于所述配置文件,确定部署有直播审核文件生成服务,并且所述直播审核文件生成服务的负荷低于最大负荷的目标集群。20.根据权利要求19所述的方法,其特征在于,所述配置文件通过如下方式生成:针对于任一集群,若该集群中至少一个边缘计算节点部署有直播审核文件生成服务,则确定该集群部署有直播审核文件生成服务;若该集群中的边缘计算节点均未部署直播审核文件生成服务,则确定该集群未部署直播审核文件生成服务;和/或,针对于部署有直播审核文件生成服务的任一集群,对该集群的直播审核文件生成服务进行压力测试,以获得该集群的直播审核文件生成服务的最大负荷;其中,所述最大负荷包括:cpu最大使用率和/或处理的直播流的数量上限。21.根据权利要求17-20中任一项所述的方法,其特征在于,所述处理能力参考信息基于如下数据中的至少一种获得:是否部署有直播审核文件生成服务、cpu利用率、尚未处理完成的直播流的数目、以及内存剩余容量。22.根据权利要求21所述的方法,其特征在于,所述处理能力参考信息包括:处理能力参考值;所述获取所述目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息进一步包括:针对于所述目标集群包含的任一边缘计算节点,判断该边缘计算节点是否部署有直播审核文件生成服务;若否,则确定该边缘计算节点的直播审核文件生成服务的处理能力参考值为预设值;若是,则获取该边缘计算节点当前的预设性能指标值,根据所述预设性能指标值,确定该边缘计算节点的直播审核文件生成服务的处理能力参考值;根据所述预设性能指标值确定的直播审核文件生成服务的处理能力参考值大于所述预设值;其中,所述预设性能指标包括以下指标中的至少一种:
cpu利用率、尚未处理完成的直播流的数目、以及内存剩余容量。23.根据权利要求22所述的方法,其特征在于,所述根据所述处理能力参考信息从所述至少一个边缘计算节点中确定出第二边缘计算节点进一步包括:从所述至少一个边缘计算节点中识别出候选边缘计算节点;所述候选边缘计算节点的处理能力参考值高于所述第一边缘计算节点的处理能力参考值;从所述候选边缘计算节点中确定出第二边缘计算节点。24.根据权利要求23所述的方法,其特征在于,所述从所述候选边缘计算节点中确定出第二边缘计算节点进一步包括:从所述候选边缘计算节点中选取处理能力参考值最高的边缘计算节点,作为所述第二边缘计算节点。25.根据权利要求17-24中任一项所述的方法,其特征在于,在所述第一边缘计算节点接收主播端推送的直播流之前,所述方法还包括:接收主播端发起的推流请求,确定能够提供直播审核文件生成服务的目标集群,从所述目标集群中至少一个边缘计算节点中确定出第一边缘计算节点,并将所述第一边缘计算节点的节点信息发送至所述主播端。26.根据权利要求25所述的方法,其特征在于,所述确定能够提供直播审核文件生成服务的目标集群进一步包括:获取所述主播端的地理位置信息和/或运营商信息;确定与所述主播端的地理位置信息和/或运营商信息匹配的集群;判断所述匹配的集群是否能够提供直播审核文件生成服务;若是,则将所述匹配的集群作为所述目标集群;若否,从能够提供直播审核文件生成服务的集群中确定出所述目标集群。27.根据权利要求25或26所述的方法,其特征在于,所述从所述目标集群中至少一个边缘计算节点中确定出第一边缘计算节点进一步包括:根据任一所述边缘计算节点当前的预设信息,从所述目标集群中至少一个边缘计算节点中确定出第一边缘计算节点;其中,所述预设信息包括:与所述主播端的距离信息和/或网络状态信息。28.根据权利要求17-24中任一项所述的方法,其特征在于,所述确定能够提供直播审核文件生成服务的目标集群进一步包括:判断所述第一边缘计算节点隶属的集群是否能够提供直播审核文件生成服务;若是,将所述第一边缘计算节点隶属的集群确定为所述目标集群,并执行所述获取所述目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息,根据所述处理能力参考信息从所述至少一个边缘计算节点中确定出第二边缘计算节点的步骤。29.根据权利要求28所述的方法,其特征在于,若所述第一边缘计算节点隶属的集群无法提供直播审核文件生成服务,则所述方法还包括:从能够提供直播审核文件生成服务的集群中确定目标集群,并从所述目标集群的上行边缘计算节点中确定出第三边缘计算节点,向所述第一边缘计算节点反馈所述第三边缘计算节点的节点信息,以供所述第一边缘计算节点将所述直播流转推至所述第三边缘计算节点;
接收所述第三边缘计算节点发送的转推请求,执行所述获取所述目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息,并根据所述处理能力参考信息从所述至少一个边缘计算节点中确定出第二边缘计算节点的步骤;将所述第二边缘计算节点的节点信息发送至所述第三边缘计算节点,以供所述第三边缘计算节点将所述直播流转推至所述第二边缘计算节点。30.一种直播审核文件的生成方法,其特征在于,包括:接收主播端推送的直播流;向调度节点发送转推请求,以供所述调度节点从能够提供直播审核文件生成服务的目标集群中确定出第二边缘计算节点;其中,所述第二边缘计算节点基于目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息确定;将所述直播流转推至所述第二边缘计算节点,以供所述第二边缘计算节点对所述直播流进行处理,以生成所述直播流对应的直播审核文件。31.一种直播审核文件的生成方法,其特征在于,包括:接收第一边缘计算节点转推的直播流;其中,所述第一边缘计算节点接收主播端推送的直播流;对所述直播流进行处理,以生成所述直播流对应的直播审核文件。32.一种直播审核文件的生成系统,其特征在于,包括:主播端,用于向第一边缘计算节点推送直播流;第一边缘计算节点,用于接收所述直播流,并向调度节点发送转推请求,以及将所述直播流转推至第二边缘计算节点;调度节点,用于接收所述转推请求,确定能够提供直播审核文件生成服务的目标集群;以及获取所述目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息,并根据所述处理能力参考信息从所述至少一个边缘计算节点中确定出第二边缘计算节点;将所述第二边缘计算节点的节点信息发送至所述第一边缘计算节点;第二边缘计算节点,用于对所述直播流进行处理,以生成所述直播流对应的直播审核文件。33.一种调度节点,其特征在于,包括:接收模块,用于接收第一边缘计算节点发送的转推请求;第一确定模块,用于确定能够提供直播审核文件生成服务的目标集群;其中,所述第一边缘计算节点接收主播端推送的直播流;获取模块,用于获取所述目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息;第二确定模块,用于根据所述处理能力参考信息从所述至少一个边缘计算节点中确定出第二边缘计算节点;发送模块,用于将所述第二边缘计算节点的节点信息发送至所述第一边缘计算节点,以供所述第一边缘计算节点将所述直播流转推至第二边缘计算节点后,所述第二边缘计算节点对所述直播流进行处理,以生成所述直播流对应的直播审核文件。34.一种边缘计算节点,其特征在于,包括:接收模块,用于接收主播端推送的直播流;
请求模块,用于向调度节点发送转推请求,以供所述调度节点从能够提供直播审核文件生成服务的目标集群中确定出第二边缘计算节点;其中,所述第二边缘计算节点基于目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息确定;转推模块,用于将所述直播流转推至所述第二边缘计算节点,以供所述第二边缘计算节点对所述直播流进行处理,以生成所述直播流对应的直播审核文件。35.一种边缘计算节点,其特征在于,包括:接收模块,用于接收第一边缘计算节点转推的直播流;其中,所述第一边缘计算节点接收主播端推送的直播流;处理模块,用于对所述直播流进行处理,以生成所述直播流对应的直播审核文件。36.一种计算设备,其特征在于,包括:处理器、存储器、通信接口和通信总线,所述处理器、所述存储器和所述通信接口通过所述通信总线完成相互间的通信;所述存储器用于存放至少一可执行指令,所述可执行指令使所述处理器执行如权利要求17-31中任一项所述的直播审核文件的生成方法对应的操作。37.一种计算机存储介质,其特征在于,所述存储介质中存储有至少一可执行指令,所述可执行指令使处理器执行如权利要求17-31中任一项所述的直播审核文件的生成方法对应的操作。
技术总结本发明实施例公开了一种直播审核文件的生成方法、系统、调度节点及计算设备。方法包括:主播端向第一边缘计算节点推送直播流;第一边缘计算节点向调度节点发送转推请求;调度节点确定能够提供直播审核文件生成服务的目标集群以及获取目标集群中至少一个边缘计算节点的直播审核文件生成服务的处理能力参考信息,并根据处理能力参考信息从至少一个边缘计算节点中确定出第二边缘计算节点;将第二边缘计算节点的节点信息发送至第一边缘计算节点;第一边缘计算节点将直播流转推至第二边缘计算节点;第二边缘计算节点对直播流进行处理,以生成直播流对应的直播审核文件。采用本方案,能够降低直播产品运维成本,以及提升直播审核文件生成效率。播审核文件生成效率。播审核文件生成效率。
技术研发人员:孙袁袁 孙艺珂 陈腾启 赵馨昳
受保护的技术使用者:上海哔哩哔哩科技有限公司
技术研发日:2022.07.20
技术公布日:2022/11/1