(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211141886.2 (22)申请日 2022.09.20 (71)申请人 建信金融科技有限责任公司 地址 200120 上海市浦东 新区中国(上海) 自由贸易试验区银城路99号12层、 15 层 (72)发明人 杜腾宵　 (74)专利代理 机构 中科专利商标代理有限责任 公司 11021 专利代理师 吕朝蕙 (51)Int.Cl. G06F 9/48(2006.01) G06F 16/22(2019.01) (54)发明名称 批量作业调度方法、 装置以及作业处 理系统 (57)摘要 本公开提供了一种批量作业调度方法、 装置 以及作业处理系统， 可以应用于大数据技术领 域。 该方法应用于作业处理系统， 作业处理系统 包括协调服务模块和用于处理批量作业的业务 系统， 每个业务系统利用至少一个服务实例来执 行批量作业中的多个任务。 该方法包括： 获取与 每个业务系统相关的任务信息； 任务信息包括任 务所属批量作业的批量作业标识、 任务的任务标 识、 任务之间的依赖关系、 服务实例的服务实例 标识； 根据任务信息， 创建目录树， 目录树包括与 批量作业标识对应的批量作业节 点、 与任务标识 对应的任务节点 以及与服务实例标识对应的服 务实例节点， 且任务节点的值与依赖关系相关； 以及基于目录树， 对任务节点进行调度， 以执行 批量作业中的任务。 权利要求书2页 说明书13页 附图5页 CN 115525412 A 2022.12.27 CN 115525412 A 1.一种批量作业调度方法， 应用于作业处理系统， 所述作业处理系统包括协调服务模 块和用于处理批量作业的至少一个业务系统， 每个业务系统利用至少一个服务实例来执行 所述批量作业中的多个任务； 所述方法包括： 获取与所述每个业务系统相关的任务信 息； 所述任务信 息包括任务所属批量作业的批 量作业标识、 任务的任务标识、 任务之间的依赖关系 、 服务实例的服 务实例标识； 根据所述任务信息， 创建目录树， 所述目录树包括与所述批量作业标识对应的批量作 业节点、 与所述任务标识对应的任务节点以及与所述服务实例标识对应的服务实例节点， 且所述任务节点的值与所述依赖关系相关； 以及 基于所述目录树， 对所述任务节点进行调度， 以执 行所述批量作业中的任务。 2.根据权利要求1所述的方法， 其中， 所述 根据所述任务信息， 创建目录树包括： 根据与业 务系统相关的服 务实例的服 务实例标识， 创建服 务实例节点； 根据所述业务系统所执行的任务的任务标识， 创建所述服务实例节点的父节点， 得到 任务节点； 并将所述任务所依赖的其 他任务的任务标识， 确定为所述任务节点的值； 以及 根据所述任务所属的批量作业的批量作业标识， 创建所述任务节点的父节点， 得到批 量作业节点。 3.根据权利要求1所述的方法， 还 包括： 在创建目录树之后， 获取与所述目录树中服 务实例节点对应的服 务实例的状态信息； 以及 在确定所述服务实例处于停机状态的情况下， 从所述目录树中删除与 所述服务实例相 关的节点。 4.根据权利要求3所述的方法， 其中， 在服务实例和任务分别与同一个业务系统相关的 情况下， 与所述服务实例对应的服务实例节点是与所述任务对应的任务节点的子节点； 所 述从所述目录树中删除与所述 服务实例相关的节点包括： 从所述目录树中删除与所述 服务实例对应的服 务实例节点； 以及 在确定与任务节点满足父子关系的服务实例节点的数量是0的情况下， 删除所述任务 节点。 5.根据权利要求1所述的方法， 还 包括： 根据所述目录树， 生成有向无环图信息； 其中， 所述有向无环图信息包括节点和边， 所述有向无环图信息中的节点与所述目录 树中的任务节点 一一对应， 所述有向无环图信息中的边指示了节点之间的依赖关系。 6.根据权利要求1至5中任意一项所述的方法， 所述批量作业包括多个任务组， 每个任 务组包括第一任务和依赖所述第一任务的第二任务； 所述基于所述 目录树， 对所述任务节 点进行调度包括： 针对所述每 个任务组， 执 行以下操作： 获取所述第一任务的执 行状态； 根据所述执行状态， 在所述目录树中更新第一状态节点的值， 所述第一状态节点是与 所述第一任务对应的第一任务节点的子节点； 以及 在所述第一状态节点的值发生变更的情况下， 触发由所述第二任务注册的监听器， 以 便所述第二任务利用所述监听器确定所述第一状态节点的值， 并在所述第二任务所依赖的 全部任务均执 行成功的情况 下开始执 行所述第二任务。权　利　要　求　书 1/2 页 2 CN 115525412 A 27.一种作业处 理系统， 包括： 至少一个业务系统， 每个业务系统利用至少一个服务实例来执行批量作业中的多个任 务， 所述每个业务系统用于在启动时扫描 各自的多个任务， 得到任务信息， 并发送所述任务 信息； 以及 协调服务模块， 用于执 行根据权利要求1至 5中任意一项所述的方法。 8.根据权利要求7所述的系统， 其中， 所述批量作业包括多个任务组， 每个任务组包括 第一任务和依赖所述第一任务的第二任务； 所述协调服务模块还用于： 获取所述第一任务的执行状态； 根据 所述执行状态， 在目录 树中更新第一状态节点的值， 所述第一状态节点是与所述第一任务对应的第一任务节点的 子节点； 在所述第一状态 节点的值发生变更的情况 下， 触发由所述第二任务注 册的监听器； 所述业务系统还用于： 通过所述第 一任务向所述协调服务模块注册用于监 听所述第 一 状态节点的所述监听器； 响应于所述监听器被触发， 利用所述监听器确定所述状态节点的 值， 并在所述第二任务所依赖的全部任务均执 行成功的情况 下开始执 行所述第二任务。 9.一种批量作业调度装置， 应用于作业处理系统， 所述作业处理系统包括协调服务模 块和用于处理批量作业的至少一个业务系统， 每个业务系统利用至少一个服务实例来执行 所述批量作业中的多个任务； 所述装置包括： 获取模块， 用于获取所述每个业务系统的任务信息； 所述任务信息包括任务所属批量 作业的批量作业标识、 任务的任务标识、 任务之间的依赖关系 、 服务实例的服 务实例标识； 创建模块， 用于根据所述任务信息， 创建目录树， 所述目录树包括与所述批量作业标 识、 所述任务标识、 所述服务实例标识分别对应的批量作业节点、 任务节点和服务实例节 点， 且所述任务节点的值与所述依赖关系相关； 调度模块， 用于基于所述目录树， 对所述任务节点进行调度， 以执行所述批量作业中的 任务。 10.一种电子设备， 包括： 一个或多个处 理器； 存储装置， 用于存 储一个或多个程序， 其中， 当所述一个或多个程序被所述一个或多个处理器执行时， 使得所述一个或多个 处理器执行根据权利要求1～6中任一项所述的方法。 11.一种计算机可读存储介质， 其上存储有可执行指令， 该指令被处理器执行时使处理 器执行根据权利要求1～6中任一项所述的方法。 12.一种计算机程序产品， 包括计算机程序， 所述计算机程序被处理器执行时实现根据 权利要求1～6中任一项所述的方法。权　利　要　求　书 2/2 页 3 CN 115525412 A 3