| | |
| | | |
| | | |
| | | class RedisManager: |
| | | def __init__(self,db=config["db"]): |
| | | 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(1) |
| | | redis = _redisManager.getRedis() |
| | | keys = redis.keys("l2-*") |
| | | for k in keys: |
| | | redis.delete(k) |
| | | keys = redis.keys("l2-data-latest-*") |
| | | for k in keys: |
| | | redis.delete(k) |
| | | |
| | | pass |