使用CDK创建Aurora Serverless v2集群后创建数据库遇问题求助

你遇到的错误根源是：之前的数据库创建逻辑依赖了Aurora Data API，但Aurora Serverless v2不支持该功能，因此需要改用直接连接数据库的方式完成建库操作。以下是两种可行的实现方案：

方案1：用VPC内的Lambda函数自动化建库 #

这是生产环境推荐的自动化方式，核心思路是让Lambda部署在集群所在VPC内，直接通过数据库端口连接并执行建库语句。

CDK代码示例（以PostgreSQL为例） #

import * as cdk from 'aws-cdk-lib';
import * as lambda from 'aws-cdk-lib/aws-lambda';
import * as rds from 'aws-cdk-lib/aws-rds';
import * as secretsmanager from 'aws-cdk-lib/aws-secretsmanager';
import * as ec2 from 'aws-cdk-lib/aws-ec2';
import { Construct } from 'constructs';

export class AuroraServerlessV2Stack extends cdk.Stack {
  constructor(scope: Construct, id: string, props?: cdk.StackProps) {
    super(scope, id, props);

    // 引入已创建的VPC、集群安全组和Serverless v2集群
    const vpc = ec2.Vpc.fromLookup(this, 'ExistingVpc', { vpcId: 'vpc-xxxxxx' });
    const dbSecurityGroup = ec2.SecurityGroup.fromSecurityGroupId(this, 'DbSG', 'sg-xxxxxx');
    const dbCluster = rds.ServerlessCluster.fromServerlessClusterAttributes(this, 'ExistingCluster', {
      clusterIdentifier: 'stack-dev-dbclusterdevc49f8bef-ndxhnjvzrltl',
      secret: secretsmanager.Secret.fromSecretNameV2(this, 'DbSecret', 'your-db-secret-name'),
      vpc: vpc,
    });

    // 创建初始化数据库的Lambda函数
    const initDbLambda = new lambda.Function(this, 'InitDbLambda', {
      runtime: lambda.Runtime.PYTHON_3_11,
      code: lambda.Code.fromAsset('lambda'), // 代码存放在项目根目录的lambda文件夹下
      handler: 'init_db.handler',
      vpc: vpc,
      vpcSubnets: { subnetType: ec2.SubnetType.PRIVATE_ISOLATED }, // 部署到集群所在的私有子网
      securityGroups: [dbSecurityGroup],
      environment: {
        DB_SECRET_ARN: dbCluster.secret!.secretArn,
        DB_ENDPOINT: dbCluster.clusterEndpoint.hostname,
      },
      timeout: cdk.Duration.minutes(1), // 延长超时时间确保操作完成
      // 赋予Lambda读取数据库密钥的权限
      initialPolicy: [
        new cdk.aws_iam.PolicyStatement({
          actions: ['secretsmanager:GetSecretValue'],
          resources: [dbCluster.secret!.secretArn],
        }),
      ],
    });

    // 确保Lambda在集群部署完成后再执行
    initDbLambda.node.addDependency(dbCluster);

    // 通过自定义资源触发Lambda，保证仅执行一次初始化
    new cdk.CustomResource(this, 'InitDbCustomResource', {
      serviceToken: initDbLambda.functionArn,
    });
  }
}

Lambda执行代码（lambda/init_db.py） #

import boto3
import psycopg2
import json
import os

secrets_manager = boto3.client('secretsmanager')

def handler(event, context):
    # 从Secrets Manager获取数据库凭证
    secret_response = secrets_manager.get_secret_value(SecretId=os.environ['DB_SECRET_ARN'])
    secret = json.loads(secret_response['SecretString'])
    db_user = secret['username']
    db_password = secret['password']
    db_host = os.environ['DB_ENDPOINT']
    port = 5432

    # 连接默认系统数据库（如postgres），创建目标业务数据库
    try:
        conn = psycopg2.connect(
            user=db_user,
            password=db_password,
            host=db_host,
            port=port,
            database='postgres'
        )
        conn.autocommit = True
        cursor = conn.cursor()
        # 替换为你的目标数据库名称
        cursor.execute("CREATE DATABASE my_app_db;")
        cursor.close()
        conn.close()
        return {'status': 'success'}
    except Exception as e:
        # 处理数据库已存在的情况，避免重复执行时报错
        if 'database "my_app_db" already exists' in str(e):
            return {'status': 'already exists'}
        raise e

方案2：EC2实例手动/脚本初始化 #

如果是测试环境，可在集群所在VPC内启动一台EC2实例，安装对应数据库的客户端工具（如psql或mysql），通过集群端点连接后手动执行CREATE DATABASE语句。这种方式无需复杂配置，但不适合生产环境的自动化需求。

关键注意事项 #

• 确保Lambda/EC2的安全组与集群安全组之间有端口访问规则（允许访问数据库端口：PostgreSQL为5432，MySQL为3306）。
• 处理数据库已存在的异常，避免自定义资源重复执行导致部署失败。

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