zcdsj
/
mtc
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: 修改存储频次2

This commit is contained in:
caoqianming 2024-06-13 09:49:15 +08:00
parent 751b2934b8
commit 0dbecbc439
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
mqttc.py
View File

@ -54,8 +54,8 @@ def save_items(payload):
data['timex'] = datetime.strptime(item['time'], "%Y%m%d%H%M%S").replace(tzinfo=tz.gettz('Asia/Shanghai')) data['timex'] = datetime.strptime(item['time'], "%Y%m%d%H%M%S").replace(tzinfo=tz.gettz('Asia/Shanghai'))
data['mpoint_id'] = item['name'] data['mpoint_id'] = item['name']
last_timex: datetime = mpoint_dict.get(data['mpoint_id'], None) last_timex: datetime = mpoint_dict.get(data['mpoint_id'], None)
if data["timex"].second not in getattr(conf, "SAVE_SECONDS", [2, 7, 12, 17, 22, 27, 32, 37, 42, 47, 52, 57]) or ( if data["timex"].minute not in getattr(conf, "SAVE_MINUTES", [2, 7, 12, 17, 22, 27, 32, 37, 42, 47, 52, 57]) or (
last_timex and last_timex.second == data["timex"].second): last_timex and last_timex.minute == data["timex"].minute):
continue continue
try: try:
val_float = float(item["value"]) val_float = float(item["value"])