(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210446712.0 (22)申请日 2022.04.26 (71)申请人 康键信息技 术 （深圳） 有限公司 地址 518052 广东省深圳市前海深港合作 区前湾一路1号A栋201室 （入驻深圳市 前海商务秘书 有限公司） (72)发明人 曹翔　 (74)专利代理 机构 北京市京大律师事务所 11321 专利代理师 沈克琪 (51)Int.Cl. G06F 9/48(2006.01) G06F 9/50(2006.01) (54)发明名称 批量计算任务的分配方法、 装置、 设备及存 储介质 (57)摘要 本发明涉及大数据技术领域， 公开了一种批 量计算任务的分配方法、 装置、 设备及存储介质， 用于提高集群的稳定性。 所述批量计算任务的分 配方法包括： 通过批量计算任务的调度请求对目 标集群进行节点探活， 得到多个存活节点； 从多 个存活节 点中选取目标节点数量的待命节点， 并 从待命节 点中抽取目标节点； 通过目标节点从批 量计算任务中拉取目标任务承 载量的计算任务， 并判断批量计算任务是否存在剩余； 若批量计算 任务中存在剩余， 则抽取下一目标节点， 并通过 下一目标节点获取下一节点任务承载量的计算 任务， 直至批量计算任务中不存在剩余。 此外， 本 发明还涉及区块链技术， 目标任务承 载量可存储 于区块链 节点中。 权利要求书2页 说明书12页 附图4页 CN 114780222 A 2022.07.22 CN 114780222 A 1.一种批量计算任务的分配方法， 其特 征在于， 所述批量计算任务的分配方法包括： 接收批量计算任务的调度请求， 并通过所述调度请求对目标集群进行节点探活， 得到 多个存活节点； 从多个存活节点中选取目标节点数量的待命节点， 并从所述待命节点中抽取目标节 点； 通过所述目标节点从所述批量计算任务中拉取目标任务承载量的计算任务， 并判断所 述批量计算任务是否存在剩余； 若所述批量计算任务中存在剩余， 则抽取下一目标节点， 并通过下一目标节点获取下 一节点任务承载量的计算任务， 直至所述批量计算任务中不存在剩余。 2.根据权利要求1所述的批量计算任务的分配方法， 其特征在于， 在所述接收批量计算 任务的调 度请求， 并通过所述调 度请求对目标集群进 行节点探活， 得到多个存活节点之前， 所述批量计算任务的分配方法还 包括： 对历史批量计算任务进行任务完成参数采集， 得到任务完成数量和任务完成时长； 根据所述任务完成数量和所述任务完成时长， 计算理想节点数量； 判断所述理想节点数量是否小于或等于预置可用节点总量； 若所述理想节点数量小于或等于预置可用节点总量， 则将所述理想节点数量确定为目 标节点数量。 3.根据权利要求2所述的批量计算任务的分配方法， 其特征在于， 所述根据所述任务完 成数量和所述任务完成时长， 计算理想节点数量， 包括： 通过所述任务完成数量和任务完成时长， 计算平均完成时长， 所述平均完成时长用于 指示单节点完成任务所需的时长； 计算所述平均完成时长与预置理想完成时长之间的差值， 得到理想差值， 并根据所述 理想差值确定浮动节点数量； 获取所述历史批量计算任务的实际参与节点数量， 并通过所述浮动节点数量和所述实 际参与节点数量， 计算理想节点数量。 4.根据权利要求1所述的批量计算任务的分配方法， 其特征在于， 所述接收批量计算任 务的调度请求， 并通过 所述调度请求对目标集群进行节点探活， 得到多个存活节点， 包括： 接收批量计算任务的调度请求， 并通过所述调度请求获取所述批量计算任务对应的目 标应用信息； 通过预置的服务器心跳机制， 对目标集群中的所有节点进行心跳检测， 得到存活节点 列表； 从所述存活节点列表中提取 所述目标应用信息对应的存活节点， 得到多个存活节点。 5.根据权利要求1所述的批量计算任务的分配方法， 其特征在于， 所述从多个存活节点 中选取目标节点数量的待命节点， 并从所述待命节点中抽取目标节点， 包括： 获取所述目标集群的总节点数量， 并通过预置的节点选取比例值和所述总节点数量计 算目标节点数量； 从多个存活节点中选取所述目标节点数量的待命节点， 并从所述待命节点中随机抽取 一个节点， 得到目标节点。 6.根据权利要求1所述的批量计算任务的分配方法， 其特征在于， 所述通过所述目标节权　利　要　求　书 1/2 页 2 CN 114780222 A 2点从所述批量计算任务中拉取目标任务承载量的计算任务， 并判断所述批量计算任务是否 存在剩余， 包括： 获取所述目标节点对应的目标任务承载量， 并向所述目标节点发送调度指令； 基于所述调度指令， 通过所述目标节点从所述批量计算任务中拉取所述目标任务承载 量的计算任务， 以使得 所述目标节点异步执 行拉取到的计算任务； 判断所述批量计算任务是否存在剩余。 7.根据权利要求1所述的批量计算任务的分配方法， 其特征在于， 所述若所述批量计算 任务中存在剩余， 则抽取下一 目标节点， 并通过下一 目标节点获取下一节点任务承载量的 计算任务， 直至所述批量计算任务中不存在剩余， 包括： S1、 若所述批量计算任务中存在剩余， 则从剩余待命节点中随机抽取下一目标节点， 所 述剩余待命节点 为所有待命节点中除已被抽取的目标节点以外的节点； S2、 通过下一目标节点获取下一节点任务承载量的计算任务， 并判断所述批量计算任 务是否存在剩余； S3、 若所述批量计算任务中存在剩余， 则重复执行步骤S1 ‑S2， 直至所述批量计算任务 中不存在剩余。 8.一种批量计算任务的分配装置， 其特 征在于， 所述批量计算任务的分配装置包括： 接收模块， 用于接收批量计算任务的调度请求， 并通过所述调度请求对目标集群进行 节点探活， 得到多个存活节点； 抽取模块， 用于从多个存活节点中选取目标节点数量的待命节点， 并从所述待命节点 中抽取目标节点； 判断模块， 用于通过所述目标节点从所述批量计算任务中拉取目标任务承载量的计算 任务， 并判断所述批量计算任务是否存在剩余； 循环模块， 用于若所述批量计算任务中存在剩余， 则抽取下一目标节点， 并通过下一目 标节点获取 下一节点任务承载量的计算任务， 直至所述批量计算任务中不存在剩余。 9.一种批量计算任务的分配设备， 其特征在于， 所述批量计算任务的分配设备包括： 存 储器和至少一个处 理器， 所述存 储器中存 储有计算机程序； 所述至少一个处理器调用所述存储器中的所述计算机程序， 以使得所述批量计算任务 的分配设备 执行如权利要求1 ‑7中任意一项所述的批量计算任务的分配方法。 10.一种计算机可读存储介质， 所述计算机可读存储介质上存储有计算机程序， 其特征 在于， 所述计算机程序被处理器执行时实现如权利要求1 ‑7中任一项所述批量计算任务的 分配方法。权　利　要　求　书 2/2 页 3 CN 114780222 A 3