From 4d321ae069fce2c0f6f7884bec8fa6c4ec534d1a Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 03 八月 2023 18:25:33 +0800
Subject: [PATCH] redis连接池归还
---
trade/trade_data_manager.py | 18 ++++++------------
1 files changed, 6 insertions(+), 12 deletions(-)
diff --git a/trade/trade_data_manager.py b/trade/trade_data_manager.py
index b7b97ac..9ab4daa 100644
--- a/trade/trade_data_manager.py
+++ b/trade/trade_data_manager.py
@@ -61,15 +61,13 @@
# last_data: 涔板叆鐐规渶鍚庝竴鏉℃暟鎹�
@classmethod
def set_buy_position_info(cls, code, capture_time, trade_time, last_data, last_data_index):
- redis = cls.redisManager.getRedis()
- RedisUtils.setex(redis, "buy_position_info-{}".format(code), tool.get_expire(),
+ RedisUtils.setex(cls.redisManager.getRedis(), "buy_position_info-{}".format(code), tool.get_expire(),
json.dumps((capture_time, trade_time, last_data, last_data_index)))
# 鑾峰彇涔板叆鐐逛俊鎭�
@classmethod
def get_buy_position_info(cls, code):
- redis = cls.redisManager.getRedis()
- val_str = RedisUtils.get(redis, "buy_position_info-{}".format(code))
+ val_str = RedisUtils.get( cls.redisManager.getRedis(), "buy_position_info-{}".format(code))
if val_str is None:
return None, None, None, None
else:
@@ -79,16 +77,14 @@
# 鍒犻櫎涔板叆鐐逛俊鎭�
@classmethod
def remove_buy_position_info(cls, code):
- redis = cls.redisManager.getRedis()
- RedisUtils.delete(redis, "buy_position_info-{}".format(code))
+ RedisUtils.delete( cls.redisManager.getRedis(), "buy_position_info-{}".format(code))
# 璁剧疆涔板叆纭鐐逛俊鎭�
@classmethod
def __set_buy_sure_position(cls, code, index, data):
logger_trade.debug("涔板叆纭鐐逛俊鎭細 code:{} index:{} data:{}", code, index, data)
- redis = cls.redisManager.getRedis()
key = "buy_sure_position-{}".format(code)
- RedisUtils.setex(redis, key, tool.get_expire(), json.dumps((index, data)))
+ RedisUtils.setex(cls.redisManager.getRedis(), key, tool.get_expire(), json.dumps((index, data)))
cls.buy_sure_position_dict[code] = (index, data)
# 绉婚櫎涓嬪崟淇″彿鐨勮缁嗕俊鎭�
cls.remove_buy_position_info(code)
@@ -96,9 +92,8 @@
# 娓呴櫎涔板叆纭鐐逛俊鎭�
@classmethod
def __clear_buy_sure_position(cls, code):
- redis = cls.redisManager.getRedis()
key = "buy_sure_position-{}".format(code)
- RedisUtils.delete(redis, key)
+ RedisUtils.delete(cls.redisManager.getRedis(), key)
if code in cls.buy_sure_position_dict:
cls.buy_sure_position_dict.pop(code)
@@ -109,9 +104,8 @@
if temp is not None:
return temp[0], temp[1]
- redis = cls.redisManager.getRedis()
key = "buy_sure_position-{}".format(code)
- val = RedisUtils.get(redis, key)
+ val = RedisUtils.get(cls.redisManager.getRedis(), key)
if val is None:
return None, None
else:
--
Gitblit v1.8.0