"""
|
redis管理器
|
"""
|
import redis
|
|
import constant
|
|
config = constant.REDIS_CONFIG
|
|
|
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("volumn_max60-*")
|
for k in keys:
|
# print(k)
|
redis.delete(k)
|
|
pass
|
