From 1ff185866bcf0796d2367699bc000abb326360d5 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 15 九月 2023 17:02:51 +0800
Subject: [PATCH] 交易设置独立进程/删除trade_client_server/记录L2逐笔委托日志
---
l2/l2_data_util.py | 7 +++----
1 files changed, 3 insertions(+), 4 deletions(-)
diff --git a/l2/l2_data_util.py b/l2/l2_data_util.py
index 6b5a42c..b5dbb57 100644
--- a/l2/l2_data_util.py
+++ b/l2/l2_data_util.py
@@ -19,6 +19,7 @@
from db import redis_manager_delegate as redis_manager
from utils import tool
+__db = 1
_redisManager = redis_manager.RedisManager(1)
# l2鏁版嵁绠＄悊
# 鏈湴鏈�鏂颁竴娆′笂浼犵殑鏁版嵁
@@ -148,11 +149,11 @@
# 淇濆瓨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(),
+ 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鏁版嵁鐢ㄦ椂")
# 璁剧疆杩涘唴瀛�
@@ -162,8 +163,6 @@
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鏁版嵁閲囬泦鐨勬暟閲�
--
Gitblit v1.8.0