(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211114651.4 (22)申请日 2022.09.14 (71)申请人 平安科技 （深圳） 有限公司 地址 518000 广东省深圳市福田街道福安 社区益田路5 033号平安金融 中心23楼 (72)发明人 熊平　 (74)专利代理 机构 北京中强智尚知识产权代理 有限公司 1 1448 专利代理师 朱春元 (51)Int.Cl. G06F 9/48(2006.01) G06F 9/50(2006.01) (54)发明名称 一种任务分发方法、 装置、 设备及 介质 (57)摘要 本发明涉及计算机软件及数字医疗技术领 域， 公开了一种任务分发方法、 装置、 设备及介 质， 本发明通过将根据最新配置的任务清单和当 前运行的任务清单对原始任务清单进行修改， 获 得仅带有需要待分发任务的待配置清单， 再通过 将待配置清单中的任务分发给正常运行的临时 节点和新增节 点， 不但能够 使新增节 点分担部分 任务的执行， 使待配置清单中的任务在临时节点 和新增节 点上合理运行， 而且能够避免在任务需 要分发时增加临时节点的负载量的问题， 使各个 临时节点和新增节点负载效果均衡 。 权利要求书3页 说明书11页 附图4页 CN 115421891 A 2022.12.02 CN 115421891 A 1.一种任务分发方法， 其特 征在于， 包括： 在zookeeper集群中创建多个临时节点， 并在多个所述临时节点 中确定一个主节点， 所 述主节点用于读取原始任务清单和最新配置的任务清单； 所述读取原始任务清单包括已向 各个所述临 时节点配置的任务， 所述最新配置的任务清单包括待向各个所述临时节点最新 配置的任务； 调用所述主节点采集各个所述临时节点各自对应的任务信息、 以及节点状态信息， 并 确定当前运行 的任务清单、 正常运行 的临时节点和异常运行 的临时节点； 所述当前运行 的 任务清单包括所有所述临时节点上当前运行的全部任务； 调用所述主节点对所述当前运行的任务清单和所述最新配置的任务清单分别与所述 原始任务清单进行对比， 判断所述原 始任务清单 是否发生变化； 若发生变化， 则根据 所述最新配置的任务清单和当前运行的任务清单对所述原始任务 清单进行修改， 获得待配置清单； 所述待配置清单包括所述当前运行 的任务清单上且位于 所述最新配置的任务清单上的任务、 以及所述最新配置的任务清单相对所述原始任务清单 新增的任务； 在k8s中创建新增节点， 并将所述待配置清单中的任务分发给所述正常运行的临时节 点和所述 新增节点。 2.如权利要求1所述的任务分发方法， 其特征在于， 所述在k8s中创建新增节点， 并将所 述待配置清单中的任务分发给 所述正常运行的临时节点和所述 新增节点， 包括： 将所述异常运行的临时节点上运行的待配置清单 上的任务分发给 各个所述 新增节点； 将所述正常运行的临时节点上的非所述待配置清单上的任务收回， 并使在所述正常运 行的临时节点运行 的所述待配置清单上的任务在各自对应的所述正常运行的临时节点上 继续运行； 判断所述待配置清单上是否还有未分发的任务， 若有， 则根据所述正常运行的临时节 点和所述新增节点的负载量， 确定所述未分发的任务对应的待分发节点， 并将所述未分发 的任务分发给 所述待分发节点。 3.如权利要求2所述的任务分发方法， 其特征在于， 所述将所述异常运行的临时节点上 运行的待配置清单 上的任务分发给 各个所述 新增节点， 包括： 在所述k8s中创建预设数量的新增节点； 将与所述预设数量相同的所述异常运行的临时节点回收至所述zo okeeper集群中； 将被回收的所述异常运行的临时节点上运行的所述待配置清单上的任务分发给各个 所述新增节点； 调用所述主节点根据 各个未被收回的所述临时节点各自对应的节点状态信 息， 判断是 否有所述异常运行的临时节点； 若有， 则重复在所述k8s中创建预设数量的新增节点至将被回收的所述异常运行的临 时节点上运行的所述待配置清单上的任务分发给各个所述新增节点的步骤， 直至判断出没 有所述异常运行的临时节点 为止。 4.如权利要求1所述的任务分发方法， 其特征在于， 所述在k8s中创建新增节点， 并将所 述待配置清单中的任务分发给 所述正常运行的临时节点和所述 新增节点， 包括： 将所述异常运行的临时节点上运行的待配置清单上的任务分发给所述正常运行的临权　利　要　求　书 1/3 页 2 CN 115421891 A 2时节点； 在所述k8s中创建与所述异常运行的临时节点数量相同的新增节点； 将与所述异常运行的临时节点回收至所述zo okeeper集群； 将所述待配置清单中的全部任务均分给 所述正常运行的临时节点和所述 新增节点。 5.如权利要求4所述的任务分发方法， 其特征在于， 所述将所述异常运行的临时节点上 运行的待配置清单 上的任务分发给 所述正常运行的临时节点， 包括： 根据各个所述正常运行的临时节点各自对应的负载量进行从小到大的排序， 并将排序 中的前N个所述正常运行的临时节点作为 目标节点； 其中， N为所述异常运行 的临时节点的 个数； 将所述异常运行的临时节点上运行的待配置清单 上的任务分发给 所述目标节点。 6.如权利要求4所述的任务分发方法， 其特征在于， 所述将所述待配置清单的全部任务 均分给所述正常运行的临时节点和所述 新增节点， 包括： 将所述待配置清单的全部任务向所述正常运行的临时节点和所述新增节点进行周期 性配置， 直至将所述待配置清单的任务重新分配至各个所述正常运行的临时节点和所述新 增节点为止。 7.如权利要求1所述的任务分发方法， 其特征在于， 所述调用所述主节点对所述当前运 行的任务清单和所述最新配置的任务清单分别与所述原始任务清单进 行对比， 判断所述原 始任务清单 是否发生变化， 包括： 根据所述原始任务清单与 所述最新配置的任务清单进行对比， 判断所述最新配置的任 务清单上是否有新的任务、 以及所述原 始任务清单 上是否有需要被停止的第一停止任务； 根据所述当前运行的任务清单与 所述原始任务清单进行对比， 判断所述原始任务清单 上是否有被停止的第二停止任务； 若判断结果为有所述新的任务需要被配置、 和/或所述原始任务清单上有第一停止任 务和/或第二停止任务被停止， 则确定所述原 始任务清单发生变化； 所述根据所述最新配置的任务清单和当前运行的任务清单对所述原始任务清单进行 修改， 包括： 在所述原始任务清单中加入所述新的任务， 和/或将所述原始任务清单上被停止的第 一停止任务和/或第二停止任务从所述原始任务清单中去除， 完成对所述原始任务清单 的 修改； 将修改后的所述原 始任务清单作为所述待配置清单。 8.一种任务分发装置， 其特 征在于， 包括： 节点创建模块， 用于在zookeeper集群中创建多个临时节点， 并在多个所述临时节点中 确定一个主节点， 所述主节点用于读取原始任务清单和最新配置的任务清单； 所述读取原 始任务清单包括已向各个所述临 时节点配置的任务， 所述最新配置的任务清单包括待向各 个所述临时节点 最新配置的任务； 采集模块， 用于调用所述主节点采集各个所述临时节点各自对应的任务信息、 以及节 点状态信息， 并确定 当前运行的任务清单、 正常运行的临 时节点和异常运行的临时节点； 所 述当前运行的任务清单包括所有所述临时节点上当前运行的全部任务； 判断模块， 用于调用所述主节点对所述当前运行的任务清单和所述最新配置的任务清权　利　要　求　书 2/3 页 3 CN 115421891 A 3