redis日志

Administrator

2023-08-02 a7a3b3a96e7520af02057ec9c0afbddaf82d0ad3

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
"""
redis管理器
"""
import redis
 
import constant
from log_module.log import logger_redis_debug
 
config = constant.REDIS_CONFIG
 
pool_cache = {}
 
 
class RedisManager:
 
    def __init__(self, db=config["db"]):
        pool = None
        if db in pool_cache:
            pool = pool_cache[db]
        else:
            pool = redis.ConnectionPool(host=config["host"], port=config["port"], password=config["pwd"],
                                        db=db, decode_responses=True, max_connections=200)
            pool_cache[db] = pool
        self.pool = pool
 
    def getRedis(self):
        return redis.Redis(connection_pool=self.pool)
 
 
class RedisUtils:
    @classmethod
    def get(cls, redis_, key):
        logger_redis_debug.info("get:{}",key)
        return redis_.get(key)
 
    @classmethod
    def delete(cls, redis_, key):
        logger_redis_debug.info("delete:{}", key)
        return redis_.delete(key)
 
    @classmethod
    def keys(cls, redis_, key):
        logger_redis_debug.info("keys:{}", key)
        return redis_.keys(key)
 
    @classmethod
    def set(cls, redis_, key, val):
        logger_redis_debug.info("set:{}", key)
        return redis_.set(key, val)
 
    @classmethod
    def setex(cls, redis_, key, expire, val):
        logger_redis_debug.info("setex:{}", key)
        return redis_.setex(key, expire, val)
 
    @classmethod
    def expire(cls, redis_, key, expire):
        logger_redis_debug.info("expire:{}", key)
        return redis_.expire(key, expire)
 
    @classmethod
    def sadd(cls, redis_, key, val):
        logger_redis_debug.info("sadd:{}", key)
        return redis_.sadd(key, val)
 
    @classmethod
    def sismember(cls, redis_, key, val):
        logger_redis_debug.info("sismember:{}", key)
        return redis_.sismember(key, val)
 
    @classmethod
    def smembers(cls, redis_, key):
        logger_redis_debug.info("smembers:{}", key)
        return redis_.smembers(key)
 
    @classmethod
    def srem(cls, redis_, key, val):
        logger_redis_debug.info("srem:{}", key)
        return redis_.srem(key, val)
 
    @classmethod
    def incrby(cls, redis_, key, num):
        logger_redis_debug.info("incrby:{}", key)
        return redis_.incrby(key, num)
 
    @classmethod
    def lpush(cls, redis_, key, val):
        logger_redis_debug.info("lpush:{}", key)
        return redis_.lpush(key, val)
 
    @classmethod
    def lpop(cls, redis_, key):
        logger_redis_debug.info("lpop:{}", key)
        return redis_.lpop(key)
 
 
 
 
if __name__ == "__main__":
    pass