"""
redis管理器
"""
import redis

import constant

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)


if __name__ == "__main__":
    _redisManager = RedisManager(0)
    redis = _redisManager.getRedis()
    keys = redis.keys("volumn_max60-*")
    for k in keys:
        # print(k)
        redis.delete(k)

    pass