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
| 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(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
|
|
