From a3c05bddc4c61d63b804ee541cf6dd01717ba94d Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 02 八月 2023 16:39:08 +0800
Subject: [PATCH] redis封装
---
ths/client_manager.py | 9 +++++----
1 files changed, 5 insertions(+), 4 deletions(-)
diff --git a/ths/client_manager.py b/ths/client_manager.py
index 1dfc09e..b74d874 100644
--- a/ths/client_manager.py
+++ b/ths/client_manager.py
@@ -1,6 +1,7 @@
# 瀹㈡埛绔鐞嗗櫒
import json
+from db.redis_manager import RedisUtils
from user import authority
from db import redis_manager
from utils import import_util
@@ -12,7 +13,7 @@
def getValidL2Clients():
redis = __redisManager.getRedis()
- keys = redis.keys("client-active-*")
+ keys = RedisUtils.keys(redis, "client-active-*")
client_ids = []
for k in keys:
_id = k.split("client-active-")[1]
@@ -27,7 +28,7 @@
# 鑾峰彇瀹㈡埛绔疘P
def getActiveClientIP(client_id):
redis = __redisManager.getRedis()
- val = redis.get("client-active-{}".format(client_id))
+ val = RedisUtils.get(redis, "client-active-{}".format(client_id))
if val is None:
return None
val = json.loads(val)
@@ -39,7 +40,7 @@
return
redis = __redisManager.getRedis()
- redis.setex("client-active-{}".format(client_id), 10, json.dumps((host, thsDead)))
+ RedisUtils.setex(redis,"client-active-{}".format(client_id), 10, json.dumps((host, thsDead)))
if ths_util:
ths_util.set_ths_dead_state(client_id, thsDead)
@@ -47,7 +48,7 @@
# 鑾峰彇瀹㈡埛绔悓鑺遍『鐘舵��
def getTHSState(client_id):
redis = __redisManager.getRedis()
- val = redis.get("client-active-{}".format(client_id))
+ val = RedisUtils.get(redis, "client-active-{}".format(client_id))
if val is None:
return None
val = json.loads(val)
--
Gitblit v1.8.0