From e0ca7b43c17ebe25e718d5ca229c989f48340015 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 07 八月 2023 16:16:30 +0800
Subject: [PATCH] redis批量提交数据
---
l2/l2_data_manager.py | 11 ++++++-----
1 files changed, 6 insertions(+), 5 deletions(-)
diff --git a/l2/l2_data_manager.py b/l2/l2_data_manager.py
index 8b46f7d..7071b03 100644
--- a/l2/l2_data_manager.py
+++ b/l2/l2_data_manager.py
@@ -9,6 +9,7 @@
from log_module.log import logger_l2_trade_buy
from utils.tool import CodeDataCacheUtil
+_db = 1
_redisManager = redis_manager.RedisManager(1)
@@ -42,7 +43,7 @@
@staticmethod
def delete_buy_point(code):
CodeDataCacheUtil.clear_cache(TradePointManager.__buy_compute_index_info_cache, code)
- RedisUtils.delete_async(TradePointManager.__get_redis(), "buy_compute_index_info-{}".format(code))
+ RedisUtils.delete_async(_db, "buy_compute_index_info-{}".format(code))
# 鑾峰彇涔板叆鐐逛俊鎭�
# 杩斿洖鏁版嵁涓猴細涔板叆鐐� 绱绾拱棰� 宸茬粡璁＄畻鐨勬暟鎹储寮�
@@ -86,7 +87,7 @@
volume_rate)
CodeDataCacheUtil.set_cache(TradePointManager.__buy_compute_index_info_cache, code, data_)
RedisUtils.setex_async(
- TradePointManager.__get_redis(), _key, expire,
+ _db, _key, expire,
json.dumps(data_))
# 鑾峰彇鎾や拱鍏ュ紑濮嬭绠楃殑淇℃伅
@@ -110,7 +111,7 @@
# 鍒犻櫎涔版挙鐐规暟鎹�
@classmethod
def delete_buy_cancel_point(cls, code):
- RedisUtils.delete_async(TradePointManager.__get_redis(), "buy_cancel_single_pos-{}".format(code))
+ RedisUtils.delete_async(_db, "buy_cancel_single_pos-{}".format(code))
# 璁剧疆涔版挙绾拱棰�
@classmethod
@@ -131,7 +132,7 @@
@classmethod
def delete_compute_info_for_cancel_buy(cls, code):
- RedisUtils.delete_async(TradePointManager.__get_redis(), "compute_info_for_cancel_buy-{}".format(code))
+ RedisUtils.delete_async(_db, "compute_info_for_cancel_buy-{}".format(code))
# 浠庝拱鍏ヤ俊鍙峰紑濮嬭缃定鍋滀拱涓庢定鍋滄挙鐨勫崟鏁�
@classmethod
@@ -153,7 +154,7 @@
@classmethod
def delete_count_info_for_cancel_buy(cls, code):
- RedisUtils.delete_async(TradePointManager.__get_redis(), "count_info_for_cancel_buy-{}".format(code))
+ RedisUtils.delete_async(_db, "count_info_for_cancel_buy-{}".format(code))
# 娓呴櫎l2鏁版嵁
--
Gitblit v1.8.0