产线问题分析与解决系列：2 Redis告急！内存飙升背后的真相与解决之道

import redis
from collections import defaultdict
def scan_keys(redis_client):
    cursor = 0
    while True:
        cursor, keys = redis_client.scan(cursor, count=1000)  # 每次扫描 1000 个 keys
        yield from keys  # 使用生成器返回 keys
        if cursor == 0:
            break  # 如果游标为 0，则表示扫描完成
def main(redis_host, redis_port, redis_db, redis_password, use_ssl):
    # 连接 Redis，支持 SSL 连接
    redis_client = redis.StrictRedis(
        host=redis_host,
        port=redis_port,
        db=redis_db,
        password=redis_password,
        ssl=use_ssl,  # 根据配置是否使用 SSL
        decode_responses=True  # 自动解码字节为字符串
    )
    # 要统计的 key 前缀和数量
    prefix_count = defaultdict(int)
    # 使用 SCAN 统计前缀
    for key in scan_keys(redis_client):
        prefix = key[:6]  # 取前 6 个字符作为前缀
        prefix_count[prefix] += 1  # 计数
    # 输出统计结果并取前50个
    sorted_prefix_count = sorted(prefix_count.items(), key=lambda item: item[1], reverse=True)[:50]
    print("前缀统计结果（前 50 个）：")
    for prefix, count in sorted_prefix_count:
        print(f"前缀: {prefix}, 数量: {count}")
if __name__ == "__main__":
    # 输入 Redis 配置信息
#     redis_host = input("请输入 Redis 的 IP 地址: ")
#     redis_port = int(input("请输入 Redis 的端口: "))  # 端口一般是 6379
#     redis_db = int(input("请输入 Redis 的数据库索引 (0-15): "))  # 默认数据库索引是 0
#     redis_password = input("请输入 Redis 的密码 (如果没有，请直接回车): ") or None
    redis_host = '10.100.1.182'
    redis_port = 63100  # 端口一般是 6379
    redis_db = 3  # 默认数据库索引是 0
    redis_password ='xxxxxxxx'
#     use_ssl = False
    use_ssl = True
    main(redis_host, redis_port, redis_db, redis_password,use_ssl)

import redis
import time
def delete_keys_with_prefix(redis_client, prefix, batch_size=1000):
    """
    批量删除指定前缀的Redis key
    :param redis_client: Redis客户端实例
    :param prefix: 要删除的key的前缀
    :param batch_size: 每次删除的key数量，默认1000
    """
    cursor = 0
    total_deleted = 0
    while True:
        # 使用SCAN命令获取一批key
        cursor, keys = redis_client.scan(cursor=cursor, match=f"{prefix}*", count=batch_size)

        if not keys:
            print("没有找到更多符合条件的key，删除完成。")
            break
        # 删除这批key
        deleted_count = redis_client.delete(*keys)
        total_deleted += deleted_count
        print(f"已删除 {deleted_count} 个key，总共删除 {total_deleted} 个key。")
        # 如果SCAN返回的cursor为0，表示遍历完成
        if cursor == 0:
            print("所有符合条件的key已删除完毕。")
            break
        # 为了避免对Redis造成过大压力，可以适当休眠
        time.sleep(0.1)
if __name__ == "__main__":
    # Redis连接配置
    redis_host = "localhost"  # Redis主机地址
    redis_port = 6379         # Redis端口
    redis_db = 0              # Redis数据库编号
    redis_password = "your_password_here"  # Redis密码
    redis_ssl = False         # 是否启用SSL认证
    # 创建Redis客户端
    redis_client = redis.Redis(
        host=redis_host,
        port=redis_port,
        db=redis_db,
        password=redis_password,
        ssl=redis_ssl,        # 是否启用SSL认证
        decode_responses=True
    )
    # 要删除的key的前缀
    prefix = "messag"
    # 批量删除
    delete_keys_with_prefix(redis_client, prefix)