From 315855587800b136d894771f41b72c60cc37bd32 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 26 十一月 2024 18:11:48 +0800
Subject: [PATCH] 接口修改/redis队列溢出保护/减少不必要的日志输出
---
l2/code_price_manager.py | 26 --------------------------
1 files changed, 0 insertions(+), 26 deletions(-)
diff --git a/l2/code_price_manager.py b/l2/code_price_manager.py
index bfb962d..0f00fbe 100644
--- a/l2/code_price_manager.py
+++ b/l2/code_price_manager.py
@@ -74,12 +74,6 @@
RedisUtils.setex_async(self.__db, f"buy1_price_limit_up_info-{code}", tool.get_expire(),
json.dumps((limit_up_time, open_limit_up_time)))
- def __get_buy1_price_limit_up_info(self, code):
- data = RedisUtils.get(self.__get_redis(), f"buy1_price_limit_up_info-{code}")
- if not data:
- return None, None
- data = json.loads(data)
- return data[0], data[1]
def __get_buy1_price_limit_up_info_cache(self, code):
cache_result = tool.CodeDataCacheUtil.get_cache(self.__buy1_price_limit_up_info_cache, code)
@@ -94,31 +88,11 @@
tool.CodeDataCacheUtil.set_cache(self.__current_buy_1_price, code, buy_1_price)
RedisUtils.setex_async(self.__db, f"buy1_price-{code}", tool.get_expire(), buy_1_price)
- # datas:[(code, buy_1_price)]
- def __save_buy1_prices(self, datas):
- for d in datas:
- code = d[0]
- buy_1_price = d[1]
- # 涓嶄繚瀛橀噸澶嶇殑鏁版嵁
- self.__save_buy1_price(code, buy_1_price)
-
- def __get_buy1_price(self, code):
- return RedisUtils.get(self.__get_redis(), f"buy1_price-{code}")
-
- def __get_buy1_price_cache(self, code):
- cache_result = tool.CodeDataCacheUtil.get_cache(self.__current_buy_1_price, code)
- if cache_result[0]:
- return cache_result[1]
- return None
-
# ------------------------鐐告澘鍚庣殑鏈�浣庝环------------------------------
def __save_open_limit_up_lowest_price(self, code, price):
tool.CodeDataCacheUtil.set_cache(self.__open_limit_up_lowest_price_cache, code, round(float(price), 2))
RedisUtils.setex_async(self.__db, f"open_limit_up_lowest_price-{code}", tool.get_expire(), f"{price}")
-
- def __get_open_limit_up_lowest_price(self, code):
- return RedisUtils.get(self.__get_redis(), f"open_limit_up_lowest_price-{code}")
def __get_open_limit_up_lowest_price_cache(self, code):
cache_result = tool.CodeDataCacheUtil.get_cache(self.__open_limit_up_lowest_price_cache, code)
--
Gitblit v1.8.0