Python3用scan和delete命令批量清理redis数据
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 |
import redis import time redis_cache = redis.Redis(host="", port=0000, password="xxxx", db=1) print("begin") print(redis_cache.dbsize()) begin_pos = 0 while True: result = redis_cache.scan(begin_pos, "xxxxx_*", 100000) return_pos, datalist = result print(time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(time.time())), return_pos) if len(datalist) > 0: print(time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(time.time())), "delete", len(datalist)) redis_cache.delete(*datalist) if return_pos == 0: break begin_pos = return_pos print("over") |
有几个知识点： scan命令的第一个入参从0 … [阅读全文…]