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

本期解读：

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

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

概要

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

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

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

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

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

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

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

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

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

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

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

详细解析

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

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

3. 多进程并行计算：

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

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

4.虚拟点计算流程：

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

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

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

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

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

5.

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

代码特点

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

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

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

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

注意事项

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

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

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

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