一种基于Kafka实时消息智能水库调度方法及系统

本发明公开了一种基于Kafka实时消息智能水库调度方法及系统，包括以下步骤：基于实时消息系统数据结构，接收水库调度实时数据；基于Kafka Stream State Store，根据水库调度实时数据的时间戳，计算该数据所处时间窗口，并根据时间窗口和水库调度计算规则聚合与该数据相关的其它计算数据，驱动关联计算链，计算链各节点依次被数据驱动，从而水库调度的完整计算。本发明方法通过智能时间窗口，实现数据驱动的实时数据处理计算，完成水库的智能调度，无须人工干预，大幅提升计算可靠性和系统稳定性。同时，本发明系统利用数据驱动微应用模式，达到分时和分布并行计算，大幅降低硬件资源要求，适合大型水库和大规模水库群调度计算。