From b79f40afbe849f56f7c2db94e9bcebf3f5e92ec6 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 04 八月 2023 09:47:45 +0800
Subject: [PATCH] redis连接池归还
---
code_attribute/big_money_num_manager.py | 22 +++++++++++-----------
1 files changed, 11 insertions(+), 11 deletions(-)
diff --git a/code_attribute/big_money_num_manager.py b/code_attribute/big_money_num_manager.py
index 91c5cd5..23223be 100644
--- a/code_attribute/big_money_num_manager.py
+++ b/code_attribute/big_money_num_manager.py
@@ -4,6 +4,7 @@
# 澶у崟绠＄悊
from db import redis_manager
+from db.redis_manager import RedisUtils
from utils import tool
__redisManager = redis_manager.RedisManager(0)
@@ -18,24 +19,20 @@
def add_num(code, num):
- redis = __redisManager.getRedis()
- redis.incrby("big_money-{}".format(code), num)
+ RedisUtils.incrby(__redisManager.getRedis(), "big_money-{}".format(code), num)
# 璁剧疆杩囨湡鏃堕棿
def expire(code):
- redis = __redisManager.getRedis()
- redis.expire("big_money-{}".format(code), tool.get_expire())
+ RedisUtils.expire(__redisManager.getRedis(), "big_money-{}".format(code), tool.get_expire())
def reset(code):
- redis = __redisManager.getRedis()
- redis.set("big_money-{}".format(code), 0)
+ RedisUtils.set(__redisManager.getRedis(), "big_money-{}".format(code), 0)
def get_num(code):
- redis = __redisManager.getRedis()
- num = redis.get("big_money-{}".format(code))
+ num = RedisUtils.get(__redisManager.getRedis(), "big_money-{}".format(code))
if num is None:
return 0
return round(int(num) / 1000 / 4)
@@ -43,9 +40,12 @@
def reset_all():
redis = __redisManager.getRedis()
- keys = redis.keys("big_money-*")
- for k in keys:
- redis.setex(k, tool.get_expire(), 0)
+ try:
+ keys = RedisUtils.keys(redis, "big_money-*", auto_free=False)
+ for k in keys:
+ RedisUtils.setex(redis, k, tool.get_expire(), 0, auto_free=False)
+ finally:
+ redis.connection_pool.disconnect()
if __name__ == "__main__":
--
Gitblit v1.8.0