From a3c05bddc4c61d63b804ee541cf6dd01717ba94d Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 02 八月 2023 16:39:08 +0800
Subject: [PATCH] redis封装
---
l2/l2_data_manager.py | 34 ++++++++++++++++++----------------
1 files changed, 18 insertions(+), 16 deletions(-)
diff --git a/l2/l2_data_manager.py b/l2/l2_data_manager.py
index f11e2d4..bb5473c 100644
--- a/l2/l2_data_manager.py
+++ b/l2/l2_data_manager.py
@@ -4,6 +4,7 @@
import json
from db import redis_manager
+from db.redis_manager import RedisUtils
from utils import tool
from log_module.log import logger_l2_trade_buy
from utils.tool import CodeDataCacheUtil
@@ -42,7 +43,7 @@
def delete_buy_point(code):
CodeDataCacheUtil.clear_cache(TradePointManager.__buy_compute_index_info_cache, code)
redis = TradePointManager.__get_redis()
- redis.delete("buy_compute_index_info-{}".format(code))
+ RedisUtils.delete(redis, "buy_compute_index_info-{}".format(code))
# 鑾峰彇涔板叆鐐逛俊鎭�
# 杩斿洖鏁版嵁涓猴細涔板叆鐐� 绱绾拱棰� 宸茬粡璁＄畻鐨勬暟鎹储寮�
@@ -87,7 +88,8 @@
data_ = (_buy_single_index, buy_exec_index, compute_index, nums, count, list(max_num_sets),
volume_rate)
CodeDataCacheUtil.set_cache(TradePointManager.__buy_compute_index_info_cache, code, data_)
- redis.setex(_key, expire,
+ RedisUtils.setex(
+ redis,_key, expire,
json.dumps(data_))
# 鑾峰彇鎾や拱鍏ュ紑濮嬭绠楃殑淇℃伅
@@ -108,20 +110,20 @@
def set_buy_cancel_single_pos(cls, code, index):
redis = TradePointManager.__get_redis()
expire = tool.get_expire()
- redis.setex("buy_cancel_single_pos-{}".format(code), expire, index)
+ RedisUtils.setex(redis,"buy_cancel_single_pos-{}".format(code), expire, index)
# 鍒犻櫎涔版挙鐐规暟鎹�
@classmethod
def delete_buy_cancel_point(cls, code):
redis = TradePointManager.__get_redis()
- redis.delete("buy_cancel_single_pos-{}".format(code))
+ RedisUtils.delete( redis, "buy_cancel_single_pos-{}".format(code))
# 璁剧疆涔版挙绾拱棰�
@classmethod
def set_compute_info_for_cancel_buy(cls, code, index, nums):
redis = TradePointManager.__get_redis()
expire = tool.get_expire()
- redis.setex("compute_info_for_cancel_buy-{}".format(code), expire, json.dumps((index, nums)))
+ RedisUtils.setex( redis,"compute_info_for_cancel_buy-{}".format(code), expire, json.dumps((index, nums)))
logger_l2_trade_buy.info("{}淇濆瓨鎾ゅ崟绾拱棰濅俊鎭細{}锛寋}", code, index, nums)
# 鑾峰彇涔版挙绾拱棰濊绠椾俊鎭�
@@ -138,14 +140,14 @@
@classmethod
def delete_compute_info_for_cancel_buy(cls, code):
redis = TradePointManager.__get_redis()
- redis.delete("compute_info_for_cancel_buy-{}".format(code))
+ RedisUtils.delete(redis, "compute_info_for_cancel_buy-{}".format(code))
# 浠庝拱鍏ヤ俊鍙峰紑濮嬭缃定鍋滀拱涓庢定鍋滄挙鐨勫崟鏁�
@classmethod
def set_count_info_for_cancel_buy(cls, code, index, buy_count, cancel_count):
redis = TradePointManager.__get_redis()
expire = tool.get_expire()
- redis.setex("count_info_for_cancel_buy-{}".format(code), expire, json.dumps((index, buy_count, cancel_count)))
+ RedisUtils.setex(redis,"count_info_for_cancel_buy-{}".format(code), expire, json.dumps((index, buy_count, cancel_count)))
logger_l2_trade_buy.info("{}淇濆瓨鎾ゅ崟绾拱棰濅俊鎭細{}锛寋}", code, index, buy_count, cancel_count)
# 鑾峰彇涔版挙绾拱棰濊绠椾俊鎭�
@@ -162,17 +164,17 @@
@classmethod
def delete_count_info_for_cancel_buy(cls, code):
redis = TradePointManager.__get_redis()
- redis.delete("count_info_for_cancel_buy-{}".format(code))
+ RedisUtils.delete(redis, "count_info_for_cancel_buy-{}".format(code))
# 娓呴櫎l2鏁版嵁
def clear_l2_data(code):
redis_l2 = redis_manager.RedisManager(1).getRedis()
- keys = redis_l2.keys("l2-{}-*".format(code))
+ keys = RedisUtils.keys( redis_l2, "l2-{}-*".format(code))
for k in keys:
- redis_l2.delete(k)
+ RedisUtils.delete(redis_l2,k)
- redis_l2.delete("l2-data-latest-{}".format(code))
+ RedisUtils.delete(redis_l2, "l2-data-latest-{}".format(code))
second_930 = 9 * 3600 + 30 * 60 + 0
@@ -184,9 +186,9 @@
redis = _redisManager.getRedis()
count = redis.scard(key)
if count > 0:
- redis.delete(key)
- redis.sadd(key, "000000")
- redis.expire(key, tool.get_expire())
+ RedisUtils.delete(redis, key)
+ RedisUtils.sadd(redis, key, "000000")
+ RedisUtils.expire(redis, key, tool.get_expire())
# 绉婚櫎l2鍥哄畾鐩戞帶浠ｇ爜
@@ -200,8 +202,8 @@
def add_to_l2_fixed_codes(code):
key = "l2-fixed-codes"
redis = _redisManager.getRedis()
- redis.sadd(key, code)
- redis.expire(key, tool.get_expire())
+ RedisUtils.sadd(redis, key, code)
+ RedisUtils.expire(redis, key, tool.get_expire())
# 鏄惁鍦╨2鍥哄畾鐩戞帶浠ｇ爜涓�
--
Gitblit v1.8.0