一种电力数据流处理与流式查询方法

本发明公开一种电力数据流处理与流式查询方法，包括如下步骤：S1：实时获取电力数据流，对电力数据流进行预处理；S2：将预处理后的电力数据按设备物理位置与时间戳分区存储到数据库中，并构建两层索引，包括时空联合索引和数据范围索引；S3：接收用户的查询请求，对查询请求进行语法和语义解析，得到关键查询信息，根据关键查询信息匹配对应的索引类型，并根据匹配的索引类型和关键查询信息得到查询筛选信息；S4：根据查询筛选信息，对电力数据进行筛选，并将筛选结果进行排序，实时反馈给用户。本发明通过通过查询优化步骤，分析查询模式、优化索引策略、采用流式查询，显著提升电力数据流处理与流式查询的效率和性能。