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

config = {
    "host": "127.0.0.1",
    "port": 6379,
    "db": 0,
    "pwd": "123456"
}


class RedisManager:
    def __init__(self, db=config["db"]):
        self.pool = redis.ConnectionPool(host=config["host"], port=config["port"], password=config["pwd"],
                                         db=db, decode_responses=True)

    def getRedis(self):
        return redis.Redis(connection_pool=self.pool)


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

    pass