求助：无法通过REST API将ElastiCache Redis集群连接至React应用

一、排查Lambda连接Redis失败的核心原因 #

EC2可正常连接说明Redis集群本身无问题，故障大概率出在Lambda网络配置：

• 确保Lambda所在VPC与ElastiCache Redis的VPC一致，或通过VPC peering打通网络
• 给Lambda配置的安全组需允许出站访问Redis默认端口6379；同时Redis的安全组要允许Lambda安全组的入站流量（端口6379）
• 为Lambda执行角色附加AWSLambdaVPCAccessExecutionRole托管策略，确保具备VPC相关权限
• 确认使用正确的Redis端点：ElastiCache Redis端点格式为集群主节点地址:6379，不要误用EC2连接地址

二、Node.js REST API（Express + Redis）实现步骤 #

1. 初始化项目并安装依赖 #

mkdir redis-api && cd redis-api
npm init -y
npm install express redis cors
# 若用Serverless部署Lambda，需安装：npm install -D serverless-http

2. 核心代码（api.js） #

const express = require('express');
const redis = require('redis');
const cors = require('cors');
const app = express();

// 初始化Redis客户端
const redisClient = redis.createClient({
  url: 'redis://<你的ElastiCache Redis端点>:6379',
  // 若Redis设置了密码，添加：password: '你的Redis密码'
});

// 监听Redis连接错误
redisClient.on('error', (err) => {
  console.error('Redis连接异常:', err);
});

// 建立Redis连接
(async () => {
  await redisClient.connect();
})();

// 中间件配置
app.use(cors()); // 允许React前端跨域请求
app.use(express.json());

// 接口1：设置缓存（支持自定义过期时间）
app.post('/cache/set', async (req, res) => {
  try {
    const { key, value, ttl } = req.body;
    if (!key || !value) {
      return res.status(400).json({ error: 'key和value为必填项' });
    }
    ttl ? await redisClient.setEx(key, ttl, value) : await redisClient.set(key, value);
    res.status(200).json({ message: '缓存设置成功' });
  } catch (err) {
    res.status(500).json({ error: '设置缓存失败', details: err.message });
  }
});

// 接口2：获取缓存
app.get('/cache/get/:key', async (req, res) => {
  try {
    const value = await redisClient.get(req.params.key);
    value === null 
      ? res.status(404).json({ message: '缓存不存在' })
      : res.status(200).json({ key: req.params.key, value });
  } catch (err) {
    res.status(500).json({ error: '获取缓存失败', details: err.message });
  }
});

// 接口3：删除缓存
app.delete('/cache/delete/:key', async (req, res) => {
  try {
    const deleteCount = await redisClient.del(req.params.key);
    deleteCount === 0
      ? res.status(404).json({ message: '缓存不存在' })
      : res.status(200).json({ message: '缓存删除成功' });
  } catch (err) {
    res.status(500).json({ error: '删除缓存失败', details: err.message });
  }
});

// 部署到EC2时启动服务
const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {
  console.log(`API服务运行在端口${PORT}`);
});

// 部署到Lambda时导出handler（需配合serverless-http）
// module.exports.handler = serverless(app);

3. 部署方式选择 #

• EC2部署：在EC2上运行node api.js，或用PM2托管进程；确保EC2安全组允许前端访问API端口（如3000）
• Lambda部署：使用Serverless框架或AWS SAM，严格配置Lambda的VPC、安全组及执行角色，验证网络连通性

三、验证流程 #

1. 在Lambda代码中添加dns.lookup(<Redis端点>)，检查是否能正常解析IP
2. 用Postman或curl测试API接口，确认缓存读写操作正常
3. 查看CloudWatch（Lambda）或EC2日志，定位具体连接错误信息

内容的提问来源于stack exchange，提问作者Abhijith KM