同一CDK栈内Lambda无需硬编码连接ElastiCache Redis集群的方案

步骤1：优化RedisCluster构造，暴露必要属性 #

在原有RedisCluster类中新增两个便捷方法，直接返回Redis连接所需的地址和端口，避免上层业务直接操作底层Cfn资源，符合组件封装的最佳实践：

export class RedisCluster extends Construct {
  private redisCluster: CfnCacheCluster;
  constructor(scope: Construct, config: BuildConfig, id: string) {
    // 原有逻辑保持不变
  }

  public getRedisCluster(): CfnCacheCluster {
      return this.redisCluster;
  }

  // 新增：返回Redis端点地址
  public getRedisEndpointHost(): string {
    return this.redisCluster.attrRedisEndpointAddress;
  }

  // 新增：返回Redis服务端口
  public getRedisEndpointPort(): string {
    return this.redisCluster.attrRedisEndpointPort;
  }
}

attrRedisEndpointAddress和attrRedisEndpointPort是CDK为CfnCacheCluster自动提供的内置属性，基于CDK的Token机制实现，部署时会自动替换为实际创建的Redis集群的真实值，无需提前手动获取。

步骤2：改造Lambda构造，接收Redis实例作为入参 #

给Lambda自定义构造的入参增加RedisCluster实例字段，直接从实例中读取连接参数填充到环境变量：

// 定义Lambda构造的入参类型，新增RedisCluster实例字段
interface LambdaConstructProps {
  config: BuildConfig;
  customXXXRole: IRole;
  layer: ILayerVersion;
  redisCluster: RedisCluster;
}

export class RedisAccessLambda extends Construct {
  constructor(scope: Construct, id: string, props: LambdaConstructProps) {
    super(scope, id);

    const lambdaFunction = new lambda.Function(this, 'XXXXX', {
      functionName: `XXXXX`,
      runtime: lambda.Runtime.PYTHON_3_8,
      handler: props.config.handler,
      role: props.customXXXRole,
      code: lambda.Code.fromAsset('xxx.zip'),
      timeout: Duration.seconds(props.config.timeout),
      memorySize: props.config.memory_size,
      reservedConcurrentExecutions: props.config.reserved_concurrent_executions,
      layers: [props.layer],
      environment: {     
        // 直接从传入的Redis实例获取连接参数，部署时自动替换为真实值
        redis_host: props.redisCluster.getRedisEndpointHost(),
        redis_port: props.redisCluster.getRedisEndpointPort()
      },
      // 必须配置：Lambda要访问VPC内的Redis，需要部署到同一VPC的私有子网
      vpc: Vpc.fromLookup(this, "VPC", {
        isDefault:false,
        vpcName: props.config.vpcName,
      }),
      vpcSubnets: { subnetType: SubnetType.PRIVATE },
      securityGroups: [SecurityGroup.fromSecurityGroupId(this, 'LambdaSG', props.config.lambdaSecurityGroupId)]
    });
  }
}

步骤3：在CDK栈中组装两个组件 #

在栈定义文件中按依赖顺序实例化组件，先创建Redis集群，再将实例传入Lambda构造即可：

export class MyApplicationStack extends Stack {
  constructor(scope: Construct, id: string, props?: StackProps) {
    super(scope, id, props);
    const buildConfig = // 你的配置实例

    // 第一步：实例化Redis集群构造
    const redisCluster = new RedisCluster(this, buildConfig, 'DevRedisCluster');

    // 第二步：实例化Lambda构造，传入已创建的Redis实例
    const redisLambda = new RedisAccessLambda(this, 'DevRedisLambda', {
      config: buildConfig,
      customXXXRole: yourRoleInstance, // 你的Lambda角色实例
      layer: yourLayerInstance, // 你的Lambda层实例
      redisCluster: redisCluster
    });

    // 必须配置：放开Redis安全组规则，允许Lambda安全组访问Redis默认端口6379
    const redisSecurityGroup = SecurityGroup.fromSecurityGroupId(this, 'RedisSG', buildConfig.securityGroupId);
    const lambdaSecurityGroup = SecurityGroup.fromSecurityGroupId(this, 'LambdaSG', buildConfig.lambdaSecurityGroupId);
    redisSecurityGroup.addIngressRule(lambdaSecurityGroup, Port.tcp(6379), 'Allow Lambda access to Redis');
  }
}

补充说明 #

该方案完全符合CDK最佳实践，所有资源引用都通过CDK内置机制自动解析，无硬编码配置。部署时CloudFormation会自动按依赖顺序创建资源，先完成Redis集群部署，再自动将生成的端点地址注入Lambda环境变量，无需人工干预。

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