(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210433253.2 (22)申请日 2022.04.22 (71)申请人 中国工商银行股份有限公司 地址 100140 北京市西城区复兴门内大街 55号 (72)发明人 李臻　胡继强　张彤　 (74)专利代理 机构 中科专利商标代理有限责任 公司 11021 专利代理师 张琛 (51)Int.Cl. G06F 9/48(2006.01) G06F 9/38(2006.01) G06F 9/46(2006.01) G06F 9/50(2006.01) (54)发明名称 批量业务任务执行方法、 装置、 设备、 介质和 程序产品 (57)摘要 本公开提供了一种批量业务任务执行方法， 可以应用于大数据技术领域和人工智能技术领 域。 其中， 批量业务任务执行方法， 包括： 解析批 量业务任务对应的批量任务文件， 确定批量任务 文件中每个任务文件对应的任务要素信息； 根据 任务要素信息获取对应每个任务文件的本地任 务脚本； 以及基于批量任务文件对应的任务检查 信息， 执行每个任务文件的本地任务脚本， 完成 批量业务任务执行。 本公开还提供了一种批量业 务任务执 行装置、 设备、 存 储介质和程序 产品。 权利要求书2页 说明书20页 附图6页 CN 114721807 A 2022.07.08 CN 114721807 A 1.一种批量 业务任务执 行方法， 其中， 包括： 解析所述批量业务任务对应的批量任务文件， 确定所述批量任务文件中每个任务文件 对应的任务要素信息； 根据所述任务要素信息获取对应所述每 个任务文件的本地任务脚本； 以及 基于所述批量任务文件对应的任务检查信息， 执行所述每个任务文件的本地任务脚 本， 完成所述批量 业务任务执 行。 2.根据权利要求1所述的方法， 其中， 在所述解析所述批量业务任务对应的批量任务文 件， 确定所述批量任务文件中每 个任务文件 对应的任务要素信息之前， 还 包括： 通过下行任务链路接收所述批量 业务任务； 根据心跳连接进程监听并拉取对应数据分区的所述批量业务任务对应的批量任务信 息； 其中， 所述批量任务信息包括所述批量任务文件和批量脚本版本信息 。 3.根据权利要求2所述的方法， 其中， 在所述根据心跳连接进程监 听并拉取对应数据分 区的所述批量 业务任务对应的批量任务文件之前， 还 包括： 根据所述批量业务任务的批量目标地址， 复制所述批量业务任务到对应所述数据分 区； 响应于所述复制所述批量 业务任务到对应所述数据分区， 创建所述心跳连接进程。 4.根据权利要求2所述的方法， 其中， 在所述解析所述批量业务任务对应的批量任务文 件， 确定所述批量任务文件中每 个任务文件 对应的任务要素信息中， 包括： 解析所述批量任务文件中每 个任务文件 对应的具体任务请求； 根据所述具体任务请求确定所述每 个任务文件 对应的任务要素信息 。 5.根据权利要求4所述的方法， 其中， 在所述解析所述批量任务文件中每个任务文件对 应的具体任务请求之前， 还 包括： 匹配所述批量脚本版本信 息与本地脚本版本信 息， 检查所述批量任务文件的脚本检查 信息； 响应于所述脚本检查信 息， 解析所述批量任务文件检查对应所述每个任务文件的任务 执行类型； 其中， 所述任务检查信息包括所述任务执 行类型和所述脚本检查信息 。 6.根据权利要求5所述的方法， 其中， 在所述匹配所述批量脚本版本信 息与本地脚本版 本信息， 检查所述批量任务文件的脚本检查信息之后， 还 包括： 响应于所述脚本检查信息， 更新所述本地脚本版本信息 。 7.根据权利要求5所述的方法， 其中， 在所述响应于所述脚本检查信息， 解析所述批量 任务文件检查对应所述每 个任务文件的任务执 行类型中， 包括： 根据所述每个任务文件的文件任务标识， 通过对应的任务线程池 并发解析所述批量任 务文件， 其中， 包括： 通过所述任务线程池中对应的任务线程， 根据所述每个任务文件的任 务进程标识确定所述每 个任务文件的任务执 行类型； 其中， 所述任务执 行类型包括即时任务类型和定时任务类型。 8.根据权利要求1所述的方法， 其中， 在所述根据 所述任务要素信 息获取对应所述每个 任务文件的本地任务脚本中， 包括：权　利　要　求　书 1/2 页 2 CN 114721807 A 2根据预设匹配顺序， 逐个匹配所述任务要素信息中的多个 基本任务要素； 获取与所述多个 基本任务要素均匹配的本地任务脚本 。 9.根据权利要求8所述的方法， 其中， 在所述基于所述批量任务文件对应的任务检查信 息， 执行所述每个任务文件的本地任务脚本， 完成所述批量 业务任务执 行中， 包括： 当所述任务检查信 息的任务执行类型为即时任务类型， 执行所述每个任务文件的本地 任务脚本； 当所述任务检查信 息的任务执行类型为定时任务类型， 根据所述每个任务文件的指定 执行时间， 执 行所述每个任务文件的本地任务脚本 。 10.根据权利要求9所述的方法， 其中， 在所述执行所述每个任务文件的本地任务脚本 中， 包括： 当所述每个任务文件对应为并行任务 时， 根据所述每个任务文件的多个第 一平台脚本 任务标识， 并发执 行所述本地任务脚本中对应的多个第一子任务脚本； 和/或 当所述每个任务文件对应为串行任务 时， 根据所述每个任务文件的多个第 二平台脚本 任务标识， 依据所述每个第二平台脚本任务标识所标记的任务脚本执行标识顺序， 依序执 行所述本地任务脚本中对应的多个第二子任务脚本 。 11.根据权利要求9所述的方法， 其中， 在所述执行所述每个任务文件的本地任务脚本 中， 还包括： 根据所述任务要素信息中的时间任务要素， 停止所述本地任务脚本的执 行。 12.根据权利要求1所述的方法， 其中， 在所述基于所述批量任务文件对应的任务检查 信息， 执行所述每个任务文件的本地任务脚本之后， 还 包括： 汇总所述本地任务脚本的执 行结果消息 输出至加载队列； 通过上行任务链路上 载所述加载队列中的执 行结果消息 。 13.一种批量 业务任务执 行装置， 包括： 文件解析模块， 用于解析所述批量业务任务对应的批量任务文件， 确定所述批量任务 文件中每 个任务文件 对应的任务要素信息； 脚本获取模块， 用于根据所述任务要素信 息获取对应所述每个任务文件的本地任务脚 本； 以及 任务执行模块， 用于基于所述批量任务文件对应的任务检查信息， 执行所述每个任务 文件的本地任务脚本， 完成所述批量 业务任务执 行。 14.一种电子设备， 包括： 一个或多个处 理器； 存储装置， 用于存 储一个或多个程序， 其中， 当所述一个或多个程序被所述一个或多个处理器执行时， 使得所述一个或多个 处理器执行根据权利要求1～12中任一项所述的方法。 15.一种计算机可读存储介质， 其上存储有可执行指令， 该指令被处理器执行时使处理 器执行根据权利要求1～12中任一项所述的方法。 16.一种计算机程序产品， 包括计算机程序， 所述计算机程序被处理器执行时实现根据 权利要求1～12中任一项所述的方法。权　利　要　求　书 2/2 页 3 CN 114721807 A 3