From b8c569f1025c65ef25fdf31c30a95e2d2a66d891 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 23 八月 2023 18:01:46 +0800
Subject: [PATCH] H/L/S撤日志改为异步
---
l2/l2_data_util.py | 10 +++++-----
1 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/l2/l2_data_util.py b/l2/l2_data_util.py
index e65a04a..633de90 100644
--- a/l2/l2_data_util.py
+++ b/l2/l2_data_util.py
@@ -13,10 +13,10 @@
import constant
from code_attribute import gpcode_manager
-from db.redis_manager import RedisUtils
+from db.redis_manager_delegate import RedisUtils
from l2 import l2_data_log, l2_data_source_util
from log_module import log, log_export
-from db import redis_manager
+from db import redis_manager_delegate as redis_manager
from utils import tool
_redisManager = redis_manager.RedisManager(1)
@@ -139,7 +139,7 @@
RedisUtils.setex(redis_instance, key, expire, json.dumps(json_value), auto_free=False)
finally:
RedisUtils.delete(redis_instance, "l2-save-{}".format(code), auto_free=False)
- redis_instance.connection_pool.disconnect()
+ RedisUtils.realse(redis_instance)
print("淇濆瓨鏂版暟鎹敤鏃讹細", msg, "鑰楁椂锛歿}".format(round(time.time() * 1000) - start_time))
return datas
@@ -152,8 +152,8 @@
# 淇濆瓨鏈�杩戠殑鏁版嵁
__start_time = round(time.time() * 1000)
if datas:
- RedisUtils.setex(_redisManager.getRedis(), "l2-data-latest-{}".format(code), tool.get_expire(), json.dumps(datas))
- l2_data_log.l2_time(code, round(time.time() * 1000) - __start_time, "淇濆瓨鏈�杩憀2鏁版嵁鐢ㄦ椂")
+ RedisUtils.setex_async(_redisManager.getRedis(), "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
set_l2_data_latest_count(code, len(datas))
--
Gitblit v1.8.0