直播流任务处理方法、装置、存储介质、计算机设备.pdf

(19)国家知识产权局(12)发明专利申请(10)申请公布号CN115904721A(43)申请公布日2023.04.04(21)申请号202211573819.8(22)申请日2022.12.08(71)申请人天翼数字生活科技有限公司地址200000上海市静安区万荣路1256、1258号1423室(72)发明人程思远徐文杰肖锋王刚(74)专利代理机构北京集佳知识产权代理有限公司11227专利代理师黄忠(51)Int.Cl.G06F9/50(2006.01)权利要求书3页说明书13页附图3页(54)发明名称直播流任务处理方法、装置、存储介质、计算机设备(57)摘要本申请提供的直播流任务处理方法、装置、存储介质、计算机设备，在对目标任务进行处理前，先确认所有具有空闲资源的主机，构建为待分配主机集，接着可以对目标任务和待分配主机集中每一主机进行打分，利用打分机制，以便将各个任务均匀分配到各个主机上处理，提高各个主机的资源使用率。本申请在对任务进行分配时，若目标任务不是单类型任务，则在依据预设的分数匹配策略将任务分配至待分配主机集中符合条件的主机进行处理前，可以先将目标任务进行拆分，分配到各个主机进行处理后再合并，并将合并后的任务分配至待分配主机集中符合条件的主机进行最终处理，从而解决直播流处理服务中资源分布不均衡的问题，进而提高多能力结合的任务配置效率。CN115904721ACN115904721A权利要求书1/3页1.一种直播流任务处理方法，其特征在于，所述方法包括：获取目标任务以及待分配主机集，并确定所述目标任务对应的第一分数值以及所述待分配主机集中每一主机对应的第二分数值，所述待分配主机集中包含多个具有空闲资源的主机；判断所述目标任务是否为单类型任务；若是，则依据预设的分数匹配策略、所述第一分数值和所述第二分数值，将所述目标任务分配至所述待分配主机集中与所述目标任务对应的主机进行处理；若否，则将所述目标任务进行拆分，得到多个目标子任务，以及每个所述目标子任务对应的第三分数值；依据所述分数匹配策略、所述第二分数值和每个所述目标子任务对应的第三分数值，将每个所述目标子任务分配至所述待分配主机集中与该目标子任务对应的主机进行处理；将经过处理的各个目标子任务进行合并，得到目标组合任务，并将所述目标组合任务分配至所述待分配主机集中与所述目标组合任务对应的主机进行处理。2.根据权利要求1所述的直播流任务处理方法，其特征在于，所述确定所述目标任务对应的第一分数值，包括：获取所述目标任务的GPU消耗核数、内存占用空间以及CPU消耗核数；基于预设的任务资源打分公式，对所述GPU消耗核数、所述内存占用空间和所述CPU消耗核数进行计算，得到所述目标任务对应的第一分数值。3.根据权利要求1所述的直播流任务处理方法，其特征在于，所述确定所述待分配主机集中每一主机对应的第二分数值，包括：针对所述待分配主机集中每一主机，获取该主机的GPU核数、内存剩余空间以及CPU核数；基于预设的机器资源打分公式，对该主机的所述GPU核数、所述内存剩余空间和所述CPU核数进行计算，得到该主机对应的第二分数值。4.根据权利要求1所述的直播流任务处理方法，其特征在于，所述依据预设的分数匹配策略、所述第一分数值和所述第二分数值，将所述目标任务分配至所述待分配主机集中与所述目标任务对应的主机进行处理，包括：根据所述第一分数值，从所述待分配主机集中筛选出第二分数值不低于所述第一分数值的主机，并形成第一主机集合；将所述第一主机集合中每一主机对应的第二分数值按从高到低的顺序进行排序，得到第一排序结果；将所述第一排序结果中排序最高的第二分数值对应的主机作为第一目标主机，并将所述目标任务分配至所述第一目标主机进行处理。5.根据权利要求1所述的直播流任务处理方法，其特征在于，所述依据所述分数匹配策略、所述第二分数值和每个所述目标子任务对应的第三分数值，将每个所述目标子任务分配至所述待分配主机集中对应的主机进行处理，包括：将每个所述目标子任务对应的第三分数值分别与所述待分配主机集中每一主机对应的第二分数值进行匹配，得到每个所述目标子任务的匹配结果；依据各个目标子任务的匹配结果，将每个所述目标子任务分配至所述待分配主机集中2CN115904721A权利要求书2/3页与每个所述目标子任务对应的主机进行处理。6.根据权利要求5所述的直播流任务处理方法，其特征在于，所述将每个所述目标子任务对应的第三分数值分别与待分配主机集中每一主机对应的第二分数值进行匹配，得到每个所述目标子任务的匹配结果，包括：构建多个所述目标子任务对应的子任务集合，所述子任务集合中的每个所述目标子任务具有相应的优先级；从所述子任务集合中选取当前优先级最高的目标子任务，并从所述待分配主机集中筛选出第二分数值不低于该目标子任务对应