如何在ElastiCache Redis中高效删除15天以上旧键（防卡顿）

核心思路 #

避开KEYS这类会阻塞Redis的全量遍历命令，改用SCAN游标式分批遍历，配合OBJECT IDLETIME判断键的闲置时长，最后批量删除符合条件的键——全程控制单次操作的键数量，避免系统卡顿。

具体步骤 #

1. 计算闲置时间阈值：15天对应的秒数为 15*24*3600 = 1296000，记为IDLE_THRESHOLD。

2. 用SCAN分批遍历所有键
   SCAN通过游标逐步返回键集合，不会一次性加载所有键到内存，不会阻塞Redis。基础命令格式：

SCAN 0 COUNT 1000

• 0是初始游标，每次执行后会返回新游标，直到游标为0时遍历完成。
• COUNT参数控制单次返回的键数量，可根据Redis实例性能调整（建议500-2000之间，负载高时调小）。

3. 判断闲置时间并批量删除
   对SCAN返回的每个键，执行OBJECT IDLETIME <key>获取闲置秒数，若大于等于IDLE_THRESHOLD则加入待删除列表，积累到一定数量后用DEL批量删除（减少网络请求次数）。

示例Python脚本 #

import redis

# 替换为你的ElastiCache实例地址和端口
redis_client = redis.Redis(host='your-elasticache-endpoint', port=6379, db=0)

IDLE_THRESHOLD = 15 * 24 * 3600  # 15天秒数
SCAN_BATCH = 1000  # 单次SCAN获取的键数量
DEL_BATCH = 100    # 单次批量删除的键数量

cursor = 0
pending_delete = []

while True:
    cursor, keys = redis_client.scan(cursor, count=SCAN_BATCH)
    for key in keys:
        try:
            idle_sec = redis_client.object('idletime', key)
            if idle_sec >= IDLE_THRESHOLD:
                pending_delete.append(key)
                # 达到批量删除阈值时执行删除
                if len(pending_delete) >= DEL_BATCH:
                    redis_client.delete(*pending_delete)
                    pending_delete = []
        except Exception as e:
            # 处理键被并发删除等异常
            print(f"处理键 {key} 失败: {str(e)}")
    # 处理剩余待删除的键
    if pending_delete:
        redis_client.delete(*pending_delete)
        pending_delete = []
    # 游标为0表示遍历完成
    if cursor == 0:
        break

关键注意事项 #

• 避开业务高峰：选择流量低谷时段执行清理，降低对业务的影响。
• 动态调整批量参数：如果Redis CPU/内存使用率过高，立即调小SCAN_BATCH和DEL_BATCH的值。
• 集群模式适配：若你的ElastiCache是集群模式，需使用支持集群的客户端（如redis-py-cluster），遍历每个分片执行清理逻辑。
• 先测试再全量执行：先取少量键验证判断和删除逻辑，确认无误后再启动全量清理。

内容的提问来源于stack exchange，提问作者Neha Agarwal