From 394e24aaba9b28c6427444d47aab6505c735fb7e Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 30 九月 2022 16:54:18 +0800
Subject: [PATCH] L2数据处理完善
---
data_process.py | 6 +++++-
1 files changed, 5 insertions(+), 1 deletions(-)
diff --git a/data_process.py b/data_process.py
index dbf1df5..27acdc9 100644
--- a/data_process.py
+++ b/data_process.py
@@ -15,6 +15,7 @@
# 缁熻浠婃棩鍗栧嚭
# 缁熻浠婃棩涔板叆
import tool
+from code_data_util import ZYLTGBUtil
__redisManager = redis_manager.RedisManager(0)
@@ -154,6 +155,7 @@
# 淇濆瓨鑷敱娴侀�氬競鍊�
def saveZYLTSZ(datasList):
+ redis = __redisManager.getRedis()
_list = []
for data in datasList:
# 淇濆瓨
@@ -161,6 +163,8 @@
"update_time": int(round(t.time() * 1000))}
if float(data["zyltgb"]) > 0:
_list.append(_dict)
+ # 淇濆瓨10澶�
+ ZYLTGBUtil.save(data["code"],data["zyltgb"],data["zyltgb_unit"])
mongo_data.save("ths-zylt", _list)
@@ -189,7 +193,7 @@
val = redis.get("client-active-{}".format(client_id))
if val is None:
return None
- val=json.loads(val)
+ val = json.loads(val)
return val[0]
--
Gitblit v1.8.0