From d195d58dacca8396b4cacd609c008d029598e9e5 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 07 八月 2023 14:37:25 +0800
Subject: [PATCH] redis批量提交数据
---
l2/l2_data_manager_new.py | 14 +++++++++++++-
1 files changed, 13 insertions(+), 1 deletions(-)
diff --git a/l2/l2_data_manager_new.py b/l2/l2_data_manager_new.py
index 3c350b2..38a9114 100644
--- a/l2/l2_data_manager_new.py
+++ b/l2/l2_data_manager_new.py
@@ -58,6 +58,7 @@
# m鍊煎ぇ鍗曞鐞�
m_big_money_begin_cache={}
+m_big_money_process_index_cache={}
class L2BigNumForMProcessor:
def __init__(self):
@@ -93,11 +94,13 @@
# 娓呴櫎宸茬粡澶勭悊鐨勬暟鎹�
def clear_processed_end_index(self, code):
+ tool.CodeDataCacheUtil.clear_cache(m_big_money_process_index_cache, code)
key = "m_big_money_process_index-{}".format(code)
RedisUtils.delete(self.__get_redis(), key)
# 娣诲姞宸茬粡澶勭悊杩囩殑鍗�
def __set_processed_end_index(self, code, index):
+ tool.CodeDataCacheUtil.set_cache(m_big_money_process_index_cache,code,index)
key = "m_big_money_process_index-{}".format(code)
RedisUtils.setex(self.__get_redis(), key, tool.get_expire(), index)
@@ -109,6 +112,15 @@
return None
return int(val)
+ def __get_processed_end_index_cache(self, code):
+ cache_result = tool.CodeDataCacheUtil.get_cache(m_big_money_process_index_cache, code)
+ if cache_result[0]:
+ return cache_result[1]
+ val = self.__get_processed_end_index(code)
+ tool.CodeDataCacheUtil.set_cache(m_big_money_process_index_cache, code, val)
+ return val
+
+
# 澶勭悊澶у崟
def process(self, code, start_index, end_index, limit_up_price):
@@ -117,7 +129,7 @@
# 娌℃湁鑾峰彇鍒板紑濮嬩拱鍏ヤ俊鍙�
return
# 涓婃澶勭悊鍒扮殑鍧愭爣
- processed_index = self.__get_processed_end_index(code)
+ processed_index = self.__get_processed_end_index_cache(code)
if processed_index is None:
processed_index = 0
if processed_index >= end_index:
--
Gitblit v1.8.0