一种智能告警任务调度方法及系统

本发明公开一种智能告警任务调度方法及系统，该方法在对工作流定义时，记录任务之间的依赖关系，当存在超时任务时，遍历依赖关系查找受超时任务影响的下游任务，评估每个受影响的下游任务产出时间，将每个受影响的下游任务产出时间与预定告警时间对比，若满足触发条件则触发告警；采用大数据流式处理引擎Flink搭建消息处理流程，在数据源层通过消息队列收集和缓冲消息事件；通过实时流式处理层从消息队列消费消息，基于事件触发机制，根据事件类型调用对应的预计算模型进行处理；将处理后的结果在结果输出层按业务需求输出。本发明解决传统技术存在的功能单一无法满足复杂场景、告警滞后、配置繁琐缺乏关联以及资源调度与告警脱节的问题。