(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210982368.7 (22)申请日 2022.08.16 (71)申请人 中国工商银行股份有限公司 地址 100140 北京市西城区复兴门内大街 55号 (72)发明人 李轶　唐晓勇　史晨霄　施政益　 (74)专利代理 机构 北京康信知识产权代理有限 责任公司 1 1240 专利代理师 周春枚 (51)Int.Cl. G06F 9/50(2006.01) (54)发明名称 分布式任务的分配方法及其装置、 电子设备 及存储介质 (57)摘要 本发明公开了一种分布式任务的分配方法 及其装置、 电子设备及存储介质， 涉及金融科技 领域或其他相关领域， 其中， 该分配方法包括： 轮 询任务列表， 检测任务列表中是否存在构建任 务， 在检测到构建任务时， 将构建任务加入待分 配任务集合中， 并向预设负载均衡模块发起宿主 机地址请求， 在返回的宿主机地址集合不为空 时， 确定待分配任务集合中每个构建任务的任务 负载值以及宿主机地址集合中每个宿主机的服 务负载值， 并采用预设分配策略， 为构建任务分 配对应的宿主机， 直到待分配任务集合为空， 将 分配成功的构建任务从任务列表中删除。 本发明 解决了相关技术中无法高效利用构建集群性能， 为构建任务分配适当的宿主机的 的技术问题。 权利要求书3页 说明书17页 附图4页 CN 115269201 A 2022.11.01 CN 115269201 A 1.一种分布式任务的分配方法， 其特 征在于， 应用于构建系统， 包括： 轮询任务列表， 检测所述任务列表中是否存在构建任务， 得到检测结果， 其中， 所述构 建任务用于构建相应的制品， 在所述构建系统接 收到所述构建任务的情况下， 将所述构建 任务加入所述任务列表； 在所述检测结果指示检测到构建任务的情况下， 将所述构建任务加入待分配任务集合 中， 并向预设负载均衡模块 发起宿主机地址请求， 其中， 所述预设负载均衡模块执行所述宿 主机地址请求， 并返回宿主机地址集 合； 在所述宿主机地址集合不为空 的情况下， 确定所述待分配任务集合中每个所述构建任 务的任务负载值以及所述宿主机地址集 合中每个宿主机的服 务负载值； 基于所述任务负载值和所述服务负载值， 采用预设分配策略， 为所述构建任务分配对 应的所述宿主机， 直到所述待分配任务集合为空， 并将分配成功的所述构建任务从所述任 务列表中删除。 2.根据权利要求1所述的分配方法， 其特征在于， 所述预设负载均衡模块执行所述宿主 机地址请求， 并返回宿主机地址集 合的步骤， 包括： 所述预设负载均衡模块基于所述宿主机地址请求中携带的集群类型， 从预设数据库中 查询与所述 集群类型对应的宿主机列表； 所述预设负载均衡模块基于所述宿主机列表中各宿主机地址， 向各所述宿主机地址指 示的宿主机的构建代理发送宿主机健康状态和负载状态查询请求， 其中， 所述构建代理将 对应的宿主机的健康状态检查结果和负载状态结果返回所述预设负载均衡模块； 所述预设负载均衡模块基于所述 健康状态检查结果， 确定健康宿主机列表； 所述预设负载均衡模块基于所述负载状态结果， 从所述健康宿主机列表中筛选宿主机 集合， 得到所述宿 主机地址集合， 其中， 所述宿 主机集合中的每个宿 主机的当前服务负载值 小于等于宿主机的最大负载值。 3.根据权利要求2所述的分配方法， 其特征在于， 在所述预设负载均衡模块基于所述宿 主机列表中各宿 主机地址， 向各所述宿 主机地址指示的宿主机的构建代理发送宿 主机健康 状态和负载状态查询请求之前， 还 包括： 所述构建代理基于第一预设间隔周期， 向所在的宿主机发起健康状态检查请求， 得到 所述宿主机的所述健康状态检查结果， 并将所述健康状态检查结果上传至预设日志中心， 其中， 所述健康状态检查请求携带的检查类型至少包括： 容器服务存活状态检查、 构建进程 存活状态检查、 操作系统文件使用状态检查； 在所述容器服务存活状态检查、 所述构建进程存活状态检查以及所述操作系统文件使 用状态检查 都通过的情况下， 所述构建代理将所述宿 主机的所述健康状态检查结果记录为 健康状态， 其中， 将容器服务存活表征为所述容器服务存活状态检查通过； 将构建进程存活 表征为所述构建进程存活状态检查通过； 在操作系统文件的空余量大于预设空余阈值的情 况下， 所述操作系统文件使用状态检查 通过。 4.根据权利要求3所述的分配方法， 其特征在于， 在将所述健康状态检查结果上传至预 设日志中心之后， 还 包括： 基于第二预设间隔周期， 从所述预设日志中心获取所述宿主机列表中各宿主机的健康 状态检查结果；权　利　要　求　书 1/3 页 2 CN 115269201 A 2在所述健康状态检查结果指示所述宿主机处于非健康状态的情况下， 基于所述健康状 态检查结果中携带的状态参数， 匹配自愈策略； 在匹配到所述自愈策略的情况下， 检查在历史过程中是否已经发起过与所述自愈策略 对应的自愈请求； 在没有发起过所述自愈请求的情况下， 向所述构建代 理发起所述自愈请求， 其中， 所述 构建代理执 行所述自愈请求中携带的自愈脚本， 修复所述宿主机 。 5.根据权利要求1所述的分配方法， 其特征在于， 确定所述待分配任务集合中每个所述 构建任务的任务负载值的步骤， 包括： 确定每种构建类型的构建任务的任务负载初始值； 采用预设发起策略， 在预设宿主机上发起与所述构建类型相同的构建任务， 其中， 所述 预设发起策略是指从所述构建任务的任务数量为零的情况下开始， 每次发起时所述任务数 量加一， 直到所述预设宿主机的服 务负载值达 到最大负载值； 在所述预设宿主机的服 务负载值达 到所述最大负载值的情况 下， 确定目标任务数量； 基于所述任务负载初始值以及所述目标任务数量， 确定所述构建类型的构建任务的初 始任务负载值以及平均执 行时间； 获取所述构建类型的构建任务的实际执 行时间； 基于预设调节参数、 所述初始任务负载值、 所述平均执行时间以及所述实际执行时间， 确定所述构建类型的构建任务的所述任务负载值。 6.根据权利要求1所述的分配方法， 其特征在于， 在基于所述任务负载值和所述服务负 载值， 采用预设 分配策略， 为所述构建任务分配对应的所述宿主机之前， 还 包括： 将所述待分配任务集合中所述构建任务依据发起时间进行排序， 得到目标任务集合， 其中， 所述目标任务 集合中每个所述构建任务对应有所述构建任务的所述任务负载值； 将所述宿主机地址集合中所述宿主机依据每个所述宿主机的所述服务负载值进行排 序， 得到目标宿 主机集合， 其中， 所述目标宿 主机集合中每个所述宿主机对应有 所述宿主机 的所述服务负载值。 7.根据权利要求6所述的分配方法， 其特征在于， 基于所述任务负载值和所述服务负载 值， 采用预设 分配策略， 为所述构建任务分配对应的所述宿主机的步骤， 包括： 基于所述目标任务 集合和所述目标宿主机集 合， 为第一构建任务分配第一宿主机； 在将所述第 一构建任务分配给所述第 一宿主机的情况下， 确定所述第 一宿主机的当前 服务负载值为所述第一构建任务的所述任务负载值与所述第一宿主机的所述服务负载值 之和； 在所述第一宿主机的所述当前服务负载值大于等于所述第一宿主机的最大负载值的 情况下， 将所述第一宿主机从所述目标宿主机集 合删除； 在所述第一宿主机的所述当前服务负载值小于所述第一宿主机的最大负载值的情况 下， 更新所述第一宿主机的服务负载值为所述当前服务负载值， 并重新对所述目标宿主机 集合中的宿主机进行排序； 基于所述目标任务集合和重新排序后的所述目标宿主机集合， 为第 二构建任务分配第 二宿主机， 直到所述目标任务集合为空， 或者， 所目标宿 主机集合为空， 其中， 所述第一构建 任务与所述第二构建任务 不同。权　利　要　求　书 2/3 页 3 CN 115269201 A 3