MyEMS开源能源管理系统核心代码解读009

本期解读：

虚拟点计算方法：myems/myems-normalization/virtualpoint.py

源代码请点击‘阅读原文’链接

这段代码是一个用于计算和更新虚拟点（virtual points）值的Python脚本。虚拟点是指那些不直接对应于物理传感器读数的数据点，而是通过计算或转换其他数据点得到的。这个脚本的核心功能包括从数据库查询虚拟点信息、并行处理每个虚拟点的计算，并将计算结果保存回数据库。下面是对代码的详细解析：

概要

连接数据库：脚本首先尝试连接到系统数据库（cnx_system_db），以获取虚拟点的列表。

查询虚拟点：从系统数据库中查询所有标记为虚拟的点（is_virtual = 1）。

多进程处理：使用Python的multiprocessing库创建进程池，以并行方式处理每个虚拟点的计算。

虚拟点计算：对于每个虚拟点，脚本执行以下步骤：

连接到历史数据库（cnx_historical_db）。

获取虚拟点的起始和结束时间。

解析虚拟点的表达式和替换规则。

从系统数据库查询相关点的类型。

从历史数据库查询相关点的值。

使用SymPy库计算虚拟点的值。

将计算结果保存回历史数据库。

详细解析

数据库连接与错误处理：脚本使用mysql.connector连接MySQL数据库，并在连接失败时进行重试。

查询虚拟点：通过SQL查询获取所有虚拟点的信息，包括ID、名称、数据源ID、对象类型、高低限和地址。

多进程并行计算：

使用Pool创建进程池，并行调用worker函数处理每个虚拟点。

worker函数负责单个虚拟点的计算逻辑。

虚拟点计算流程：

步骤1：确定计算的起始和结束时间。

步骤2：解析虚拟点的表达式和替换规则。

步骤3：查询相关点的类型。

步骤4：查询相关点在指定时间范围内的值。

步骤5：使用SymPy计算表达式的值。

结果保存：将计算得到的虚拟点值保存回历史数据库，并更新最新值表。

代码特点

健壮性：脚本包含错误处理和数据库重连机制，确保稳定运行。

效率：通过多进程并行处理提高计算效率。

灵活性：支持通过配置文件（config模块）调整数据库连接和其他参数。

可扩展性：代码结构清晰，易于扩展和维护。

注意事项

数据库配置：需要正确配置数据库连接信息。

依赖库：脚本依赖于mysql.connector和sympy等Python库。

并发控制：在高并发环境下，需要注意数据库的连接数和性能问题。

错误处理：脚本中的错误处理主要用于日志记录和重试机制，实际应用中可能需要更详细的异常处理策略。