From a3c05bddc4c61d63b804ee541cf6dd01717ba94d Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 02 八月 2023 16:39:08 +0800
Subject: [PATCH] redis封装
---
l2/l2_data_util.py | 17 +++++++++--------
1 files changed, 9 insertions(+), 8 deletions(-)
diff --git a/l2/l2_data_util.py b/l2/l2_data_util.py
index c7c25d4..081a585 100644
--- a/l2/l2_data_util.py
+++ b/l2/l2_data_util.py
@@ -13,6 +13,7 @@
import constant
from code_attribute import gpcode_manager
+from db.redis_manager import RedisUtils
from l2 import l2_data_log, l2_data_source_util
from log_module import log
from db import redis_manager
@@ -38,7 +39,7 @@
if load_latest :
if local_latest_datas.get(code) is None or force:
# 鑾峰彇鏈�杩戠殑鏁版嵁
- _data = redis.get("l2-data-latest-{}".format(code))
+ _data = RedisUtils.get(redis,"l2-data-latest-{}".format(code))
if _data is not None:
if code in local_latest_datas:
local_latest_datas[code] = json.loads(_data)
@@ -125,21 +126,21 @@
for _data in datas:
i += 1
key = "l2-" + _data["key"]
- value = redis_instance.get(key)
+ value = RedisUtils.get(redis_instance, key)
if value is None:
# 鏂板
try:
value = {"index": _data["index"], "re": _data["re"]}
- redis_instance.setex(key, expire, json.dumps(value))
+ RedisUtils.setex(redis_instance,key, expire, json.dumps(value))
except:
logging.error("鏇存L2鏁版嵁鍑洪敊锛歿} key:{}".format(code, key))
else:
json_value = json.loads(value)
if json_value["re"] != _data["re"]:
json_value["re"] = _data["re"]
- redis_instance.setex(key, expire, json.dumps(json_value))
+ RedisUtils.setex(redis_instance,key, expire, json.dumps(json_value))
finally:
- redis_instance.delete("l2-save-{}".format(code))
+ RedisUtils.delete(redis_instance, "l2-save-{}".format(code))
print("淇濆瓨鏂版暟鎹敤鏃讹細", msg, "鑰楁椂锛歿}".format(round(time.time() * 1000) - start_time))
return datas
@@ -153,7 +154,7 @@
# 淇濆瓨鏈�杩戠殑鏁版嵁
__start_time = round(time.time() * 1000)
if datas:
- redis.setex("l2-data-latest-{}".format(code), tool.get_expire(), json.dumps(datas))
+ RedisUtils.setex(redis,"l2-data-latest-{}".format(code), tool.get_expire(), json.dumps(datas))
l2_data_log.l2_time(code, round(time.time() * 1000) - __start_time, "淇濆瓨鏈�杩憀2鏁版嵁鐢ㄦ椂")
# 璁剧疆杩涘唴瀛�
local_latest_datas[code] = datas
@@ -170,7 +171,7 @@
def set_l2_data_latest_count(code, count):
redis = _redisManager.getRedis()
key = "latest-l2-count-{}".format(code)
- redis.setex(key, 2, count)
+ RedisUtils.setex( redis,key, 2, count)
pass
@@ -181,7 +182,7 @@
redis = _redisManager.getRedis()
key = "latest-l2-count-{}".format(code)
- result = redis.get(key)
+ result = RedisUtils.get(redis, key)
if result is None:
return 0
else:
--
Gitblit v1.8.0