(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210885410.3 (22)申请日 2022.07.26 (71)申请人 中国工商银行股份有限公司 地址 100140 北京市西城区复兴门内大街 55号 (72)发明人 谢伟　 (74)专利代理 机构 北京三友知识产权代理有限 公司 11127 专利代理师 董骁毅　任默闻 (51)Int.Cl. G06Q 10/06(2012.01) G06Q 40/02(2012.01) (54)发明名称 分布式体系下批量作业处 理方法及装置 (57)摘要 一种分布式体系下批量作业处理方法及装 置， 涉及分布式处理技术领域， 可用于金融领域， 方法包括： 将批量作业划分成一个或多个分组； 根据执行计划在默认园区内由对应执行器依次 执行各个分组 内的作业； 若当前分组 内当前作业 的执行器状态异常， 则对当前分组 内的作业进行 作业回溯以定位到当前分组入口作业， 选择就近 园区且状态正常的当前分组入口作业的执行器 来执行所述入口作业， 并在就近园区内依次完成 后续各个分组 内的作业。 本发明通过对分布式体 系下的批量作业进行分组， 对于同一个 分组内的 作业都在同一园区内完成， 减少了跨域调度， 保 障了批量作业的执行效率， 另外本发 明还实现了 基于分组的作业自重启和切换调度， 提升了应急 恢复效率。 权利要求书2页 说明书9页 附图4页 CN 115169949 A 2022.10.11 CN 115169949 A 1.一种分布式体系下批量作业处 理方法， 其特 征在于， 所述方法包括： 将批量作业划分成一个或多个分组； 根据执行计划在默认园区内由对应执 行器依次执 行各个分组内的作业； 若当前分组内当前作业的执行器状态异常， 则对所述当前分组内的作业进行作业 回溯 以定位到当前分组入口作业， 选择就近园区且状态正常的所述当前分组入口作业的执行器 来执行所述入口作业， 并在所述 就近园区内依次完成后续各个分组内的作业。 2.根据权利要求1所述的方法， 其特征在于， 还包括： 执行每个分组的入口作业前， 检查 待执行分组内所有作业的执行器状态， 若有任一执行器状态异常， 则选择就近园区且状态 正常的所述待 执行分组入口作业的执行器来执行所述入口作业， 并在所述就近园区内依次 完成后续各个分组内的作业。 3.根据权利要求1所述的方法， 其特征在于， 所述将批量作业划分成一个或多个分组作 业包括： 按照批量作业文件的处理流程， 将所述批量作业中处理相同业务的不同层的作业 进行分组， 划分成一个或多个分组。 4.根据权利要求1所述的方法， 其特征在于， 所述执行器状态异常包括： 执行器自身故 障异常和当前作业的外 部依赖状态 异常； 当所述执行器状态异常为执行器自身故障时， 对所述当前分组内的作业进行作业 回溯 以定位到当前分组入口作业， 选择本园区内故障执行器的备用执行器来执行所述入口作 业， 并在本园区内依次完成后续各个分组内的作业； 当所述执行器状态异常为当前作业的外部依赖状态异常时， 对所述当前分组内的作业 进行作业回溯以定位到 当前分组入口作业， 选择就近园区内所述当前分组入口作业的执行 器来执行所述入口作业， 并在所述 就近园区内依次完成后续各个分组内的作业。 5.根据权利要求4所述的方法， 其特征在于， 当所述执行器状态异常为执行器自身故 障， 切换备用执行器来执行所述入口作业后， 还包括： 向监控中心上送监控报文以进 行执行 器故障低级别报警。 6.根据权利要求4所述的方法， 其特征在于， 当所述执行器状态异常为当前作业的外部 依赖状态异常， 选择就近园区内的执行器来执行所述入口作业后， 还包括： 向监控中心上送 监控报文以进行跨园区调度中级别报警。 7.根据权利要求4所述的方法， 其特征在于， 当所述执行器状态异常为当前作业的外部 依赖状态异常， 且经检查所有园区内的所述当前分组入口作业的执行器均异常， 则中断批 量作业处 理， 向监控中心上送监控报文以进行作业中断高级别报警。 8.根据权利要求7所述的方法， 其特征在于， 所述中断批量作业处理后， 还包括： 等待预 设时间后重新进行当前分组入口作业的调度执 行。 9.根据权利要求1所述的方法， 其特征在于， 还包括： 通过指定分组内作业执行器的工 作状态来控制所述批量作业的调度路径， 所述执行器的工作状态包括： 正常工作状态、 故障 状态及维护状态。 10.根据权利要求1所述的方法， 其特征在于， 所述由对应执行器依次执行各个分组内 的作业包括： 由对应执 行器根据分组内作业的下游 依赖关系依次执 行各个分组内的作业。 11.根据权利要求10所述的方法， 其特征在于， 所述分组内作业的下游依赖关系 包括灰 度依赖关系和 一般依赖关系， 所述灰度依赖关系的作业完成灰度批量作业， 所述一般依赖权　利　要　求　书 1/2 页 2 CN 115169949 A 2关系的作业完成一般 批量作业。 12.一种分布式体系下批量作业处 理装置， 其特 征在于， 所述装置包括： 分组单元， 用于将批量作业划分成一个或多个分组； 执行单元， 用于根据执行计划在默认园区内由对应执行器依次执行各个分组内的作 业； 路径选择单元， 用于在当前分组内当前作业的执行器状态异常时， 对所述当前分组内 的作业进 行作业回溯以定位到 当前分组入口作业， 选择就近园区且状态正常的所述当前分 组入口作业的执行器来执行所述入口作业， 并在所述就近园区内依次完成后续各个分组内 的作业。 13.一种电子设备， 包括存储器、 处理器及存储在存储器上并可在处理器上运行的计算 机程序， 其特征在于， 所述处理器执行所述计算机程序时实现权利要求 1至11任一项 所述方 法。 14.一种计算机可读存储介质， 其特征在于， 所述计算机可读存储介质存储有执行权利 要求1至1 1任一项所述方法的计算机程序。权　利　要　求　书 2/2 页 3 CN 115169949 A 3