Python3用scan和delete命令批量清理redis数据

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")

有几个知识点：

1. scan命令的第一个入参从0开始代表从头扫描
2. scan命令的返回是(pos, [])元组，第一个pos可以作为下次扫描的入参pos，第二个值就是扫描到的KEY
3. scan命令的第三个参数，是本次扫描的KEY数目，比如传递10万个，但是返回的LIST可能是0，因为有0个匹配
4. redis的delete命令传递的是array参数，可以用*list传递