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

MyEMS 开源能源管理系统适用于建筑、工厂、商场、医院、园区的电、水、气等能源数据采集、分析、报表，还有光伏、储能、充电桩、微电网、设备控制、故障诊断、工单管理、人工智能优化等可选功能。资深专业团队开发维护，保障长期支持。用开源助力企业集团、产业园区、能源运营商低碳发展!

官网 ：https://myems.io

MyEMS 开源社区版下载：https://gitee.com/myems/myems

本期解读：

空间能耗分项数据汇总计算方法：myems-aggregation/space_energy_input_item.py

源代码链接：https://gitee.com/myems/myems/blob/master/myems-aggregation/space_energy_input_category.py?sessionid=429368173

这段代码是一个用于处理能源数据的 Python 脚本，主要功能是计算和聚合特定空间（如建筑物中的房间或区域）的能源输入数据。它通过与MySQL数据库交互来获取和存储数据，并使用多进程来提高处理效率。下面是对代码的概括性总结和详细解析：

概括性总结

1. 主函数 (main): 循环执行，首先从系统数据库中获取所有空间的列表，然后使用多进程方式调用worker函数处理每个空间。每轮循环结束后休眠一段时间。

2. 工作函数 (worker): 对于给定的空间，该函数执行多个步骤来聚合该空间的能源输入数据。这包括从系统数据库中获取与该空间相关的各种能源计量设备（如实际计量表、虚拟计量表、离线计量表等），然后从能源数据库中获取这些设备的能源数据，最后聚合这些数据并保存回能源数据库。

详细解析

1. 连接数据库: 使用mysql.connector连接到 MySQL 数据库，分别操作系统数据库和能源数据库。

2. 获取空间列表: 从系统数据库中查询所有空间，并将它们存储在一个列表中。

3. 多进程处理: 使用 Python 的multiprocessing.Pool来并行处理每个空间，以提高效率。

4. 空间能源数据处理:获取与空间相关的各种能源计量设备列表。确定聚合数据的起始和结束时间。从能源数据库中获取这些设备的能源数据。确定所有设备的共同时间段，以便进行数据聚合。按能源项目和小时聚合能源数据。将聚合后的数据保存回能源数据库。

5.错误处理和日志记录: 在每个步骤中，如果遇到异常，则记录错误信息，并在必要时关闭数据库连接。

6.休眠和重试机制: 在无法连接数据库或处理数据时，脚本会休眠一段时间后重试。