如何用Terraform实现ECS Fargate中FastAPI连接ElastiCache Redis集群？

现有配置 #

FastAPI Redis配置函数 #

def redis_config():
    try:
        REDIS_HOST = "master.redis-cluster.r8ktvp.apn2.cache.amazonaws.com:6379"
        rd = redis.Redis(host=REDIS_HOST)
    except:
        print("redis connection failure")
    return rd

ECS任务定义环境变量 #

REDIS_ENDPOINT="master.redis-cluster.r8ktvp.apn2.cache.amazonaws.com"
REDIS_PORT=6379

Terraform配置 #

包含ElastiCache子网组、复制组、Redis安全组及ECS任务定义（已省略JWT与PostgreSQL相关环境变量）

遇到的问题 #

• 首次配置时，CloudWatch日志出现地址端口重复的连接错误
• 将REDIS_HOST中的端口去掉后，出现无日志输出且连接超时的情况

解决方案 #

1. 修复代码中的端口重复问题 #

原代码的核心问题是：redis.Redis()的host参数传入了带端口的地址，而该方法默认会使用port=6379，最终导致连接地址变成master.redis-cluster.r8ktvp.apn2.cache.amazonaws.com:6379:6379，触发端口重复错误。

正确的做法是读取ECS定义的环境变量，分开传递host和port参数：

import os
import redis

def redis_config():
    try:
        # 从环境变量读取配置，避免硬编码
        REDIS_HOST = os.getenv("REDIS_ENDPOINT")
        REDIS_PORT = int(os.getenv("REDIS_PORT", 6379))
        # 分开传入host和port，避免端口重复
        rd = redis.Redis(host=REDIS_HOST, port=REDIS_PORT, socket_connect_timeout=10)
        # 主动测试连接，确保能正常连通
        rd.ping()
    except Exception as e:
        # 打印具体错误信息，方便排查
        print(f"Redis连接失败: {str(e)}")
        raise
    return rd

2. 排查私有子网下的网络连通性问题 #

修改代码后仍出现超时，需要从以下几个维度排查：

• 安全组配置：
  • 确保ElastiCache Redis的安全组允许ECS任务所在安全组的6379端口入站流量
  • ECS任务的安全组允许出站访问6379端口到ElastiCache的安全组
• 子网与路由：
  • ECS任务和ElastiCache必须处于同一VPC的私有子网中（ElastiCache不允许跨VPC访问，除非用对等连接）
  • 私有子网的路由表无需互联网网关，但要确保子网之间的路由正常（如果ECS和Redis在不同私有子网）
• ElastiCache访问控制：
  • 检查ElastiCache复制组的transit_encryption_enabled配置，如果启用了传输加密，需要在Redis连接时开启ssl=True参数
  • 确认ElastiCache的子网组包含ECS任务所在的私有子网

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