(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210368064.1 (22)申请日 2022.04.08 (71)申请人 广州南方卫星导 航仪器有限公司 地址 510000 广东省广州市天河区思成路 39号4楼A区、 5楼A区、 6楼A区 (72)发明人 颜丽玲　肖京　杜卫钢　王江林　 文述生　闫志愿　郝志刚　黄海锋　 (74)专利代理 机构 广州粤高专利商标代理有限 公司 44102 专利代理师 禹小明 (51)Int.Cl. G06F 9/50(2006.01) G06F 9/48(2006.01) (54)发明名称 分布式空三计算任务调度方法及系统 (57)摘要 本发明提出了一种分布式空三计算任务调 度方法， 涉及任务调度技术领域， 包括： 获取主机 节点实时的状态数据； 根据实时的状态数据， 综 合业务指标计算每个主机节点的选举优先级； 设 置主机节点选举时的筛选条件得到预设的选举 规则； 按照选举优先级及预设的选举规则选举主 机节点， 对封装好的任务信息投递到该主机节点 进行计算； 当计算成功是判断此次计算是否为计 算流程的最后一步， 若是， 则结束计算过程； 否 则， 生成下一阶段的计算任务， 待下一次投递。 本 发明还提出了一种分布式空三计算任务调度系 统， 在任务 分发调度时结合了不同计算任务类型 对主机硬件性能不同要求， 在保证计算进程稳定 的前提下， 使大规模实景空三的计算时间达到最 短。 权利要求书2页 说明书11页 附图3页 CN 114780235 A 2022.07.22 CN 114780235 A 1.分布式空三计算任务调度方法， 用于对多个主机节点进行任务调度， 其特征在于， 包 括以下步骤： S1： 对每个主机节点硬件的使用状态进行监控， 获取实时的状态数据； S2： 根据实时的状态数据， 综合 业务指标计算每 个主机节点的选举优先级； S3： 依据调度任务的任务类型， 设置主机节点选举时的筛选条件， 得到预设的选举规 则； S4： 按照选举优先级及预设的选举规则选取主机节点， 若选举成功， 则将封装好的任务 信息从待投递列表中投递到该主机节点进 行计算， 然后执行步骤S 5； 若选举失败， 则将封装 好的任务信息回投到初始列表中， 待下一次投递； S5： 对计算状态进行监控， 若计算成功则执行步骤S6， 若计算失败则标识失败状态， 并 将封装好的任务信息回投到待投递列表中， 返回执 行步骤S4； S6： 判断此次计算是否为计算流程的最后一步， 若是， 则结束计算过程； 否则， 生成下一 阶段的计算任务， 并将下一阶段的计算任务回投到待投递列表中， 返回执 行步骤S4。 2.根据权利要求1所述的分布式空三计算任务调度 方法， 其特征在于， 所述步骤S5还包 括： 当某一个封装好的任务信息被标记三次失败状态后， 结束计算过程。 3.根据权利要求1所述的分布式空三计算任务调度方法， 其特征在于， 在步骤S1中， 所 述实时的状态数据包括CPU实时利用率、 内存实时占用率、 内存大小、 GPU实时利用率和GPU 显存实时占用率； 在步骤S2中， 根据每个主机节点 实时的状态数据， 按照综合业务指标为每 个主机节点设置权重值， 根据权重值对每个主机节点实时的状态数据进行计算， 根据每个 主机节点的计算结果生成选举优先级； 所述综合业务指标包括了空三计算的任务的不同计 算阶段的硬件需求指标， 根据不同计算阶段不同的硬件需求指标为每个主机节点设置权重 值， 根据权重值对每个主机节点实时的状态数据进行计算， 根据每个主机节点的计算结果 生成选举优先级。 4.根据权利要求3所述的分布式空三计算任务调度方法， 其特征在于， 在步骤S4中， 所 述选举规则具体包括： 主机节点在线且启用， 主机节点的剩余内存大于封装好的任务信息 所需计算的运行内存， 主机节 点的CPU实时利用率小于90％， 可用任务槽大于0， 主机节点当 前无已运行的同类任务， 主机节点距离上一次投递任务时间间隔大于3分钟， CPU实时利用 率小的优先派送； 其中： 主机节点的剩余内存通过内存实时占用率、 内存大小计算得到； 可 用任务槽用于主机节点执 行任务， 主机节点会根据机器性能配置对应的任务槽数量。 5.根据权利要求1～4任一项所述的分布式空三计算任务调度方法， 其特征在于， 在所 述步骤S5中， 对计算状态进行监控， 当计算成功时， 需要进一步检查计算结果是否符合规 范， 若是， 则将任务标记为成功， 执行步骤S6； 否则， 将任务标识失败状态， 并将封装好的任 务信息回投到待投递列表中， 返回执 行步骤S4。 6.分布式空三计算任务调度系统， 其特征在于， 包括多个主机节点、 主机节点监控模 块、 选举优先级计算模块、 任务类型识别模块、 筛选条件设置模块、 选举规则预设模块、 选举 模块、 任务初始列 表模块和任务待投递列 表模块； 所述主机节点上设置有计算模块、 计算状 态监控模块和计算 流程判断模块； 其中： 所述主机节点监控模块用于对每个主机节点硬件的使用状态进行监控， 获取实时的状 态数据；权　利　要　求　书 1/2 页 2 CN 114780235 A 2所述选举优先级计算模块用于根据实时的状态数据， 综合业务指标计算增减主机节点 后的每个主机节点选举优先级； 所述任务类型识别模块用于识别调度任务的任务类型， 由筛选条件设置模块根据任务 类型设置主机节点选举时的筛选条件， 得到预设的选举规则并保存于选举规则预设模块 中； 所述任务初始列表模块用于存储任务初始列表； 所述任务待投递列表模块用于存储任 务待投递列表， 其包括了 封装好的任务信息； 所述选举模块用于按照选举优先级及预设的选举规则选取主机节点， 若选举成功， 则 将封装好的任务信息从待投递列表中投递到该主机节点进行计算， 若选举失败， 则将封装 好的任务信息回投到初始列表中， 待下一次投递； 所述计算状态监控模块用于对主机节点的计算状态进行监控， 若计算成功传输至计算 流程判断模块进一步处理， 若计算失败则标识失败状态， 并将封装好的任务信息回投到待 投递列表中， 待下一次投递； 所述计算流程判断模块用于判断此次计算是否为计算流程的最后一步， 若是， 则结束 计算过程； 否则， 生成下一阶段的计算任务， 并将下一阶段的计算任务回投到待投递列表 中， 待下一次投递。 7.根据权利要求6所述的分布式空三计算任务调度系统， 其特征在于， 在所述计算状态 监控模块中， 当某一个封装好的任务信息被标记三次失败状态后， 结束计算过程。 8.根据权利要求6所述的分布式空三计算任务调度系统， 其特征在于， 在所述主机节点 监控模块中， 其获取主机节点实时的状态数据包括CPU实时利用率、 内存实时占用率、 内存 大小、 GPU实时利用率和GPU显存实时占用率； 在所述选举优 先级计算模块中， 根据每个主机 节点实时的状态数据， 按照 综合业务指标为每个主机节点设置权重值， 根据权重值对每个 主机节点实时的状态数据进行计算， 根据每个主机节点的计算结果生成选举优先级； 所述 综合业务指标包括了空三计算的任务的不同计算阶段的硬件需求指标， 根据不同计算阶段 不同的硬件需求指标为每个主机节点设置权重值， 根据权重值对每个主机节点实时的状态 数据进行计算， 根据每 个主机节点的计算结果 生成选举优先级。 9.根据权利要求8所述的分布式空三计算任务调度系统， 其特征在于， 在选举规则预设 模块中， 其预设的选举规则具体包括： 主机节点在线且启用， 主机节点的剩余内存大于封装 好的任务信息所需计算的运行内存， 主机节点的CPU实时利用率小于90％， 可用任务槽大于 0， 主机节 点当前无已运行的同类任务， 主机节点距离上一次投递任务时间间隔大于3 分钟， CPU实时利用率小的优先派送； 其中： 主机节点的剩余内存通过内存实时占用率、 内存大小 计算得到； 可用任务槽用于主机节点执行任务， 主机节点会根据机器性能配置对应的任务 槽数量。 10.根据权利要求6～9任一项所述的分布式空三计算任务调度系统， 其特征在于， 在所 述计算状态监控模块中， 对计算状态进行监控， 当计算成功 时会进一步检查计算结果是否 符合规范， 若 是， 则将任务标记 为成功， 传输至计算流程判断模块进一步处理， 否则， 将任务 标识失败状态， 并将封装好的任务信息回投到待投递列表中， 待下一次投递。权　利　要　求　书 2/2 页 3 CN 114780235 A 3