From f0bd15f2eb0bf5539010c957c295af6ec1d50bf9 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 07 八月 2023 14:23:35 +0800
Subject: [PATCH] redis批量提交数据
---
l2/transaction_progress.py | 15 +++++++++++++--
1 files changed, 13 insertions(+), 2 deletions(-)
diff --git a/l2/transaction_progress.py b/l2/transaction_progress.py
index 2b6cbd7..d839a27 100644
--- a/l2/transaction_progress.py
+++ b/l2/transaction_progress.py
@@ -13,6 +13,8 @@
import l2.l2_data_util
from log_module.log import logger_l2_trade_buy_queue, logger_l2_trade_buy_progress
+buy_progress_index_cache = {}
+
class TradeBuyQueue:
__redis_manager = redis_manager.RedisManager(0)
@@ -37,8 +39,9 @@
return val[0], [1]
def __save_buy_progress_index(self, code, index, is_default):
+ tool.CodeDataCacheUtil.set_cache(buy_progress_index_cache, code, (index, is_default))
key = "trade_buy_progress_index-{}".format(code)
- RedisUtils.setex(self.__getRedis(), key, tool.get_expire(), json.dumps((index, is_default)))
+ RedisUtils.setex_async(self.__getRedis(), key, tool.get_expire(), json.dumps((index, is_default)))
# 杩斿洖鏁版嵁涓庢洿鏂版椂闂�
def __get_buy_progress_index(self, code):
@@ -48,6 +51,14 @@
return None, True
val = json.loads(val)
return int(val[0]), bool(val[1])
+
+ def __get_buy_progress_index_cache(self, code):
+ cache_result = tool.CodeDataCacheUtil.get_cache(buy_progress_index_cache, code)
+ if cache_result[0]:
+ return cache_result[1]
+ val = self.__get_buy_progress_index(code)
+ tool.CodeDataCacheUtil.set_cache(buy_progress_index_cache, code, val)
+ return val
# 鏈�杩戠殑闈炴定鍋滀拱1鐨勬椂闂�
def __save_latest_not_limit_up_time(self, code, time_str):
@@ -146,7 +157,7 @@
# 鑾峰彇鎴愪氦杩涘害绱㈠紩
def get_traded_index(self, code):
- index, is_default = self.__get_buy_progress_index(code)
+ index, is_default = self.__get_buy_progress_index_cache(code)
return index, is_default
def set_traded_index(self, code, index):
--
Gitblit v1.8.0