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

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

官网 ：https://myems.io

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

本期解读：

数字量数据清洗算法：myems/myems-cleaning/clean_digital_value.py

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

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

导入必要的库:

• time：用于处理时间相关的功能。

• datetime 和 timedelta：用于处理日期和时间的计算。

• mysql.connector：用于连接 MySQL 数据库。

• schedule：用于安排定时任务。

• config：一个自定义的配置模块，用于存储数据库连接信息和其他配置。

定义 Job 函数：

• 这个函数负责实际的数据清理工作。

• 首先尝试连接到历史数据数据库（cnx_historical），如果连接失败，则记录错误并退出。

• 计算过期时间（expired_utc），这是当前时间减去live_in_days天。

• 执行 SQL 删除命令，删除所有在expired_utc之前的数据。

• 如果删除过程中出现异常，则记录错误。

• 最后，无论成功或失败，都会关闭数据库连接和游标。

定义 process 函数：

• 这个函数用于安排和执行清理任务。

• 如果配置为调试模式（config.is_debug），则立即执行一次清理任务。

• 如果不是调试模式，则使用schedule库每 8 小时安排一次清理任务。

• 使用一个无限循环来持续检查并执行待处理的任务。

日志记录：

• 在整个过程中，使用logger对象来记录信息或错误，这对于监控和调试是非常有用的。

配置文件的使用：

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

总的来说，这个脚本是一个自动化的数据清理工具，用于定期删除数据库中不再需要的数据，以保持数据库的效率和可管理性。