[发明专利]一种计算任务的预警方法、装置、计算机设备及存储介质

说明书

本发明公开了一种计算任务的预警方法、装置、计算机设备及存储介质，该方法包括：根据基线任务的预估执行时长以及基线任务之间的依赖关系计算得到待监控的目标任务的当前预估完成信息，目标任务包括任一基线任务，获取当前时间目标任务的当前执行状态信息，将目标任务的预估执行时长以及当前预估完成信息与当前执行状态信息进行比较，获取比较结果，根据比较结果判断所述目标任务是否存在异常。本发明通过根据基线任务之间的依赖关系对目标任务监控和预警，节省了人工分析上游依赖任务节点和估算上游依赖任务节点正常运行时长的工作量，同时提高了每个依赖任务的最晚完成时间计算的准确率。

技术领域

本发明涉及计算机技术领域，特别涉及一种计算任务的预警方法、装置、计算机设备及存储介质。

背景技术

随着大数据技术的发展以及业务场景的复杂化，离线计算任务的规模快速扩大，任务节点之间的关系错综复杂，任务链路涉及多个业务系统，业务流程较长。

目前，对离线计算任务的监控和预警，大都采用针对任务链路进行人工分析关键任务的上游任务，根据经验值设置每个任务的超时时间，配置任务出错预警和超时预警。由于需要人工分析任务关系和根据经验值配置任务运行时长，导致了当前的离线计算任务监控和预警，存在配置工作量巨大，预警不及时或者误报，大量重复预警，无法及时根据业务调整做出及时调整预警配置等问题。

因此，亟需提出一种新的计算任务的预警方法，以解决上述问题。

发明内容

为了解决现有技术的问题，本发明实施例提供了一种计算任务的预警方法、装置、计算机设备以及存储介质，以克服现有技术中存在的问题。

为解决上述一个或多个技术问题，本发明采用的技术方案是：

第一方面，提供了一种计算任务的预警方法，该方法包括如下步骤：

根据基线任务的预估执行时长以及所述基线任务之间的依赖关系计算得到待监控的目标任务的当前预估完成信息，所述当前预估完成信息包括预估完成时间，所述目标任务包括任一基线任务；

获取当前时间所述目标任务的当前执行状态信息，所述当前执行状态信息包括所述目标任务的实际执行时长以及实际完成信息；

将所述目标任务的预估执行时长以及所述当前预估完成信息与所述当前执行状态信息进行比较，获取比较结果；

根据所述比较结果判断所述目标任务是否存在异常。

进一步的，所述方法包括基线任务的预估执行时长的获取过程，包括：

获取每一基线任务的历史执行时长，根据所述历史执行时长以及预设计算规则计算得到每一所述基线任务的预估执行时长。

进一步的，所述根据基线任务的预估执行时长以及所述基线任务之间的依赖关系计算得到待监控的目标任务的当前预估完成信息包括：

根据基线任务之间的依赖关系生成有向无环图，所述有向无环图的节点为所述基线任务，所述有向无环图的每条边对应所述边的后继节点的预估执行时长；

根据所述有向无环图生成所述有向无环图的转置图，并遍历所述转置图，获取以每一所述目标任务为起始节点的最大连通图；

根据所述最大连通图以及所述最大连通图上相应基线任务的预估执行时长确定每一所述目标任务的当前预估完成信息。

进一步的，所述根据基线任务的预估执行时长以及所述基线任务之间的依赖关系计算得到待监控的目标任务的当前预估完成信息还包括：

查询目标系统中是否存在所述目标任务的历史预估完成信息，若存在，则判断所述当前预估完成信息是否小于所述历史预估完成信息，若不是，则将所述历史预估完成信息作为所述目标任务的当前预估完成信息。