From d4645c925024fbcf8947b0435d4b4754829e3a9e Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 25 九月 2023 12:08:21 +0800
Subject: [PATCH] 成交数据上传优化
---
l2/l2_data_util.py | 16 ++++++++--------
1 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/l2/l2_data_util.py b/l2/l2_data_util.py
index ad6f487..b5dbb57 100644
--- a/l2/l2_data_util.py
+++ b/l2/l2_data_util.py
@@ -15,10 +15,11 @@
from code_attribute import gpcode_manager
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 log_module import log, log_export, async_log_util
from db import redis_manager_delegate as redis_manager
from utils import tool
+__db = 1
_redisManager = redis_manager.RedisManager(1)
# l2鏁版嵁绠＄悊
# 鏈湴鏈�鏂颁竴娆′笂浼犵殑鏁版嵁
@@ -148,21 +149,20 @@
# 淇濆瓨l2鏁版嵁
def save_l2_data(code, datas, add_datas):
# 鍙湁鏈夋柊鏇炬暟鎹墠闇�瑕佷繚瀛�
- if len(add_datas) > 0:
+ if add_datas:
# 淇濆瓨鏈�杩戠殑鏁版嵁
__start_time = round(time.time() * 1000)
if datas:
- 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鏁版嵁鐢ㄦ椂")
+ RedisUtils.setex_async(__db, "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))
try:
- log.logger_l2_data.info("{}-{}", code, add_datas)
+ async_log_util.l2_data_log.info(log.logger_l2_data, f"{code}-{add_datas}")
except Exception as e:
logging.exception(e)
- # 鏆傛椂涓嶅皢鏁版嵁淇濆瓨鍒皉edis
- # saveL2Data(code, add_datas)
# 璁剧疆鏈�鏂扮殑l2鏁版嵁閲囬泦鐨勬暟閲�
@@ -347,7 +347,7 @@
# 鏁版嵁閲嶅娆℃暟榛樿涓�1
datas.append({"key": key, "val": item, "re": 1})
dataIndexs.setdefault(key, len(datas) - 1)
- # TODO 娴嬭瘯鐨勬椂鍊欏紑鍚紝鏂逛究璁板綍澶у崟鏁版嵁
+ # 娴嬭瘯鐨勬椂鍊欏紑鍚紝鏂逛究璁板綍澶у崟鏁版嵁
# l2_data_util.save_big_data(code, same_time_num, data)
return datas
--
Gitblit v1.8.0