(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211148219.7 (22)申请日 2022.09.20 (71)申请人 中国建设银行股份有限公司 地址 100033 北京市西城区金融大街25号 申请人 建信金融科技有限责任公司 (72)发明人 李龙飞　 (74)专利代理 机构 北京同立钧成知识产权代理 有限公司 1 1205 专利代理师 独旭　刘芳 (51)Int.Cl. G06F 16/25(2019.01) G06F 8/41(2018.01) (54)发明名称 异常作业预警方法、 装置、 设备、 存储介质和 程序产品 (57)摘要 本申请属于数据处理技术领域， 具体涉及一 种异常作业预警方法、 装置、 设备、 存储介质和程 序产品。 该方法包括通过 获取作业运行数据和作 业依赖数据； 根据所述作业依赖数据和目标作 业， 获取所述目标作业所依 赖的直接依赖作业和 间接依赖作业； 根据所述作业运行数据获取每个 作业的作业信息； 根据每个作业的作业信息、 所 述目标作业和所述依赖作业， 确定所述目标作业 是否为异常作业， 并在所述目标作业为异常作业 时， 发送预警提醒； 由于通过目标作业和该目标 作业的依赖作业来确定目标作业是否为异常作 业， 因此可以及时发现目标作业异常， 同时节省 了运维人员人工查询异常原因的时间， 提高了发 现异常作业的效率。 权利要求书3页 说明书15页 附图5页 CN 115495512 A 2022.12.20 CN 115495512 A 1.一种异常作业预警方法， 其特 征在于， 包括： 获取作业运行数据和作业依赖数据， 其中， 所述作业运行数据包括多个作业的运行状 态流水， 所述作业依赖数据用于指示作业之间的依赖关系； 根据所述作业依赖数据和目标作业， 获取所述目标作业所依赖的依赖作业， 所述依赖 作业包括 直接依赖作业和间接依赖作业； 根据所述作业运行数据获取每个作业的作业信 息， 所述作业信 息包括已完成作业的流 水信息或待完成作业的开始信息； 根据每个作业的作业信息、 所述目标作业和所述依赖作业， 确定所述目标作业是否为 异常作业， 并在所述目标作业 为异常作业时， 发送预警提醒。 2.根据权利要求1所述的方法， 其特征在于， 所述根据所述作业依赖数据和目标作业， 获取所述目标作业所依赖的依赖作业， 包括： 根据所述作业依赖数据， 获取每个作业的当前执行节点的依赖信 息， 其中， 所述作业依 赖数据包括具有直接依赖关系的作业， 所述依赖信息包括当前执行节点的直接依赖节点和 间接依赖节点； 根据每个当前执行节点的依赖信 息和执行所述目标作业的目标节点的标识， 获取所述 目标作业所依赖的依赖作业。 3.根据权利要求2所述的方法， 其特征在于， 所述根据所述作业依赖数据， 获取每个作 业的当前 执行节点的依赖信息， 包括： 针对当前执行节点， 设置待发送节点列表和已发送节点列表， 所述待发送节点列表用 于存储所述当前执行节点的标识以及从直接依赖节点接收的标识信息， 所述标识信息包括 与所述直接依赖节点具有间接或直接依赖关系的执 行节点的标识； 在所述待发送节点列表为空时， 根据每个当前执行节点的已发送节点列表， 获取每个 当前执行节点的依赖信息， 所述已发送节点列表用于记录 向预设节点发送的列表信息， 所 述列表信息包括所述待发送节点列表中的当前执行节点的标识以及从直接依赖节点接 收 的标识信息， 所述预设节点 为依赖所述当前 执行节点的执 行节点。 4.根据权利要求1所述的方法， 其特征在于， 所述作业信息包括已完成作业的流水信 息， 所述根据每个作业的作业信息、 所述目标作业和所述依赖作业， 确定所述目标作业是否 为异常作业， 包括： 根据每个作业的已完成作业的流水信息， 获取运行状态为 错误的至少一个错 误作业； 判断所述目标作业和/或所述依赖作业是否为所述至少一个错 误作业中的作业； 若所述依赖作业和/或所述目标作业 为错误作业， 则确定所述目标作业 为异常作业。 5.根据权利要求1所述的方法， 其特征在于， 所述作业信息包括已完成作业的流水信 息， 所述根据每个作业的作业信息、 所述目标作业和所述依赖作业， 确定所述目标作业是否 为异常作业， 包括： 根据每个作业的已完成作业的流水信 息， 获取所述目标作业和所述依赖作业的当次作 业时长； 若所述目标作业的当次作业时长超过预设时长， 和/或所述依赖作业的当次作业时长 超过预设时长， 则确定所述目标作业为异常作业， 所述预设时长是根据 平均运行时长、 标准 差和纠偏时长确定的。权　利　要　求　书 1/3 页 2 CN 115495512 A 26.根据权利要求1所述的方法， 其特征在于， 所述作业信息包括待完成作业的开始信 息， 所述根据每个作业的作业信息、 所述目标作业和所述依赖作业， 确定所述目标作业是否 为异常作业， 包括： 根据待完成作业的开始信息， 获取待完成作业的作业 开始时间； 根据所述待完成作业的作业开始时间和所述目标作业， 获取所述目标作业的作业开始 时间； 在所述目标作业的作业开始时间发生延迟时， 根据 所述待完成作业的作业开始时间和 所述依赖作业， 获取 所述依赖作业的作业 开始时间； 根据所述依赖作业的作业 开始时间， 确定所述目标作业是否为异常作业。 7.根据权利要求6所述的方法， 其特征在于， 所述根据所述依赖作业的作业开始时间， 确定所述目标作业是否为异常作业， 包括： 根据所述依赖作业的作业 开始时间， 获取发生延迟的目标依赖作业； 根据所述目标依赖作业和依赖关系， 获取每个所述目标依赖作业所对应的目标直接依 赖作业； 若所述目标直接依赖作业与 所述目标依赖作业为同一作业， 则删除所述目标直接依赖 作业对应的目标依赖作业； 获取剩余的目标依赖作业， 确定所述目标作业 为异常作业。 8.根据权利要求1所述的方法， 其特征在于， 所述预警提醒用于指示所述目标作业和/ 或所述依赖作业 为错误作业； 或者， 所述预警提醒用于指示所述目标作业和/或所述依赖作业的当次作业时长超过 预设时长； 或者， 所述预警提醒用于指示所述依赖作业发生延迟。 9.一种异常作业预警装置， 其特 征在于， 包括： 获取模块， 用于获取作业运行数据和作业依赖数据， 其中， 所述作业运行数据包括多个 作业的运行状态流水， 所述作业依赖数据用于指示作业之间的依赖关系； 所述获取模块， 还用于根据所述作业依赖数据和目标作业， 获取所述目标作业所依赖 的依赖作业， 所述依赖作业包括 直接依赖作业和间接依赖作业； 所述获取模块， 还用于根据所述作业运行数据获取每个作业的作业信息， 所述作业信 息包括已完成作业的流水信息或待完成作业的开始信息； 检测模块， 用于根据每个作业的作业信 息、 所述目标作业和所述依赖作业， 确定所述目 标作业是否为异常作业； 发送模块， 用于在所述目标作业 为异常作业时， 发送预警提醒。 10.一种异常作业预警设备， 其特 征在于， 包括： 存储器； 处理器； 其中， 所述存 储器存储计算机执 行指令； 所述处理器执行所述存储器存储的计算机执行指令， 以实现如权利要求1 ‑8中任一项 所述的异常作业预警方法。 11.一种计算机存储介质， 其特征在于， 所述计算机存储介质中存储有计算机执行指权　利　要　求　书 2/3 页 3 CN 115495512 A 3