如何通过Redis Enterprise REST API获取Redis实例已用内存并实现阈值触发机制

嘿，刚好我之前在团队里做过类似的Redis内存阈值告警和触发需求，给你梳理下实操的方案，应该能帮到你！

一、用Redis Enterprise REST API获取已用内存 #

你之前用的BDB元数据接口（就是拿内存限制、模块信息的那个）是基础信息接口，要拿实时已用内存得用统计数据接口：

• 对应的API端点是GET /v1/bdbs/{bdb_id}/stats，你需要指定要获取的指标为memory_used，同时设置interval=1来拉取最新的单点数据（如果要历史趋势可以调大interval，但实时监控用1就够）。
• 给你举个curl调用的实际例子（记得替换成你的集群地址、BDB ID和API Token）：

curl -X GET "https://your-redis-cluster-domain:9443/v1/bdbs/123/stats?metrics=memory_used&interval=1" \
  -H "Authorization: Bearer your-api-token-here" \
  -k

• 返回的JSON结果里，series数组下的data字段就是最新的已用内存数值（单位是字节），你用脚本解析这个值就行。

二、结合内存限制计算阈值 #

你已经能通过BDB元数据接口拿到实例的内存限制（字段是memory_size，同样是字节），接下来做简单的比例计算就行：

• 比如你要设80%的阈值，触发条件就是：memory_used > memory_size * 0.8
• 一定要注意单位统一，都是字节，别搞混MB/GB，避免计算错误。

三、实现阈值触发的逻辑 #

我当时是写了个Python定时脚本，核心逻辑大概是这样的，你可以参考：

import requests
import json

# 配置信息
REDIS_ENTERPRISE_URL = "https://your-redis-cluster-domain:9443"
BDB_ID = "123"
API_TOKEN = "your-api-token-here"
THRESHOLD_RATIO = 0.8  # 80%阈值

def get_bdb_metadata():
    """获取BDB基本信息，包含内存限制"""
    url = f"{REDIS_ENTERPRISE_URL}/v1/bdbs/{BDB_ID}"
    headers = {"Authorization": f"Bearer {API_TOKEN}"}
    response = requests.get(url, verify=False)  # 生产环境请关闭verify=False，配置有效SSL证书
    response.raise_for_status()
    return response.json()

def get_memory_used():
    """获取实时已用内存"""
    url = f"{REDIS_ENTERPRISE_URL}/v1/bdbs/{BDB_ID}/stats?metrics=memory_used&interval=1"
    headers = {"Authorization": f"Bearer {API_TOKEN}"}
    response = requests.get(url, verify=False)
    response.raise_for_status()
    stats_data = response.json()
    # 提取最新的已用内存数值
    return stats_data['series'][0]['data'][-1]

def trigger_eviction_or_custom_code():
    """自定义触发逻辑：比如执行驱逐策略、清理缓存、发告警等"""
    # 这里写你的具体业务逻辑，比如调整Redis驱逐策略，或者调用内部缓存清理接口
    print("内存阈值触发，执行自定义逻辑...")
    # 示例：如果要调整驱逐策略，可以调用BDB配置更新API
    # update_url = f"{REDIS_ENTERPRISE_URL}/v1/bdbs/{BDB_ID}"
    # payload = {"maxmemory_policy": "allkeys-lru"}
    # requests.put(update_url, headers=headers, json=payload, verify=False)

if __name__ == "__main__":
    try:
        bdb_metadata = get_bdb_metadata()
        memory_limit = bdb_metadata['memory_size']
        memory_used = get_memory_used()
        used_ratio = memory_used / memory_limit

        print(f"当前已用内存: {memory_used/1024/1024:.2f} MB，内存限制: {memory_limit/1024/1024:.2f} MB，使用率: {used_ratio*100:.1f}%")

        if used_ratio > THRESHOLD_RATIO:
            trigger_eviction_or_custom_code()
    except Exception as e:
        print(f"执行出错: {str(e)}")

之后把这个脚本用cron（Linux）或者Windows任务计划定时执行就行，比如每分钟跑一次，就能实时监控内存状态了。

四、一些踩坑后的注意事项 #

• API认证一定要用权限足够的有效API Token，不然会碰到权限不足的报错；
• 生产环境绝对不要用verify=False，得配置Redis Enterprise集群的有效SSL证书，避免安全风险；
• 给脚本加个日志记录吧，把每次的内存使用率、触发动作都写到日志里，后续排查问题方便很多；
• 如果只是需要告警，Redis Enterprise的管理控制台里其实也能配置内存阈值告警，但要是得执行自定义业务逻辑，还是脚本的方式更灵活。

内容来源于stack exchange