From a3c05bddc4c61d63b804ee541cf6dd01717ba94d Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 02 八月 2023 16:39:08 +0800
Subject: [PATCH] redis封装
---
output/limit_up_data_filter.py | 7 ++++---
1 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/output/limit_up_data_filter.py b/output/limit_up_data_filter.py
index ee09aef..3953a59 100644
--- a/output/limit_up_data_filter.py
+++ b/output/limit_up_data_filter.py
@@ -5,6 +5,7 @@
# 鍒ゆ柇鏄緳鍑狅紝鍒ゆ柇鏄惁娑ㄥ仠锛屽垽鏂槸鍚︾偢鏉匡紝鍔犺浇鍒嗘暟
from code_attribute import code_volumn_manager, limit_up_time_manager, gpcode_manager
+from db.redis_manager import RedisUtils
from utils import tool
from db import redis_manager
from third_data.kpl_data_manager import KPLDataManager
@@ -22,11 +23,11 @@
return self.__redisManager.getRedis()
def ignore_code(self, type, code):
- self.__get_redis().sadd(f"kp_ignore_codes_{type}", code)
- self.__get_redis().expire(f"kp_ignore_codes_{type}", tool.get_expire())
+ RedisUtils.sadd(self.__get_redis(), f"kp_ignore_codes_{type}", code)
+ RedisUtils.expire( self.__get_redis(), f"kp_ignore_codes_{type}", tool.get_expire())
def list_ignore_codes(self, type):
- return self.__get_redis().smembers(f"kp_ignore_codes_{type}")
+ return RedisUtils.smembers(self.__get_redis(), f"kp_ignore_codes_{type}")
# 鑾峰彇娑ㄥ仠椤哄簭锛堟寜娑ㄥ仠鍘熷洜鍒嗙粍锛�
--
Gitblit v1.8.0