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

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

官网 ：

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

本期解读：

模拟量数据清洗算法：myems-cleaning/clean_analog_value.py

源代码链接：https://gitee.com/myems/myems/blob/master/myems-normalization/virtualmeter.py?sessionid=343534821

这段代码是一个用于清理数据库中过期数据的 Python 脚本。它主要用于连接到一个MySQL数据库，并删除那些超过特定时间（由配置文件定义）的数据记录。下面是对这段代码的详细解释：

概括性总结

1. 数据库连接：脚本首先尝试连接到 MySQL 数据库。

2. 数据清理：连接成功后，它会执行一个 SQL 命令来删除所有超过配置文件中指定天数的数据。

3. 日志记录：整个过程中的错误和操作信息会被记录到日志中。

4. 定时任务：脚本可以配置为定时任务，每隔一定时间（例如每 8 小时）执行一次数据清理。

5. 调试模式：如果配置为调试模式，脚本会立即执行一次清理操作，而不是设置为定时任务。

详细解析

1. 导入模块：time：用于处理时间相关的功能。datetime：处理日期和时间。mysql.connector：连接 MySQL 数据库。schedule：安排定时任务。config：导入配置文件。

2. 函数 job(logger)：尝试连接到数据库。如果连接失败，记录错误并退出函数。计算过期时间（当前时间减去配置文件中定义的天数）。执行 SQL 命令删除过期的数据。提交事务以确保更改被保存。记录删除操作的信息。- 无论操作成功与否，最后关闭数据库连接。

3. 函数 process(logger)：检查是否处于调试模式。如果是，则立即执行一次清理操作。如果不是调试模式，则设置定时任务，每隔 8 小时执行一次清理操作。使用无限循环来持续检查并执行计划中的任务。

配置文件 config

• 这个脚本依赖于一个外部的配置文件 config，其中包含了数据库连接信息、日志设置、是否为调试模式以及数据保留的天数等配置。

日志记录

• 脚本使用传入的 logger 对象来记录操作信息和错误，这对于监控脚本的运行状态和调试非常重要。

定时任务

• 使用 schedule 模块来安排定时任务，这在生产环境中非常有用，可以定期自动清理数据库中的旧数据。