AWS CDKで作るサーバーレスデータベース基盤 【第3回】RDS Data API構築

$ sw_vers
ProductName:     macOS
ProductVersion:  14.7.4
BuildVersion:    23H420

$ node -v
v20.18.3

$ npm -v
10.8.2

$ cdk --version
2.1003.0 (build b242c23)

# RDS Data Service のクライアントライブラリとSecrets Manager のクライアントライブラリをインストール
npm install @aws-sdk/client-rds-data @aws-sdk/client-secrets-manager

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

export class ApiGateway extends Construct {
  public readonly api: apigateway.RestApi;

  constructor(scope: Construct,
    id: string,
    lambdaFunction: lambda.Function,
    dataApiLambda: lambda.Function  // 追加
  ) {
    super(scope, id);

    // API Gateway
    this.api = new apigateway.RestApi(this, 'UsersApi', {
      restApiName: 'Users Service',
      description: 'API Gateway for Aurora PostgreSQL Users',
      deployOptions: {
        stageName: 'prod',
      },
      binaryMediaTypes: []
    });

    // RDS Proxy　Lambda統合
    const rdsProxyIntegration = new apigateway.LambdaIntegration(lambdaFunction);

    // Data API Lambda統合 （追加）
    const dataApiIntegration = new apigateway.LambdaIntegration(dataApiLambda);

    // ルートパス（/）にGETメソッド
    this.api.root.addMethod('GET', rdsProxyIntegration);

    // RDS Proxyエンドポイント
    const rdsProxy = this.api.root.addResource('rdsProxy');
    rdsProxy.addMethod('GET', rdsProxyIntegration);

    // Data APIエンドポイント （追加）
    const dataApi = this.api.root.addResource('data-api');
    dataApi.addMethod('GET', dataApiIntegration);
  }
}

import { RDSDataClient, ExecuteStatementCommand } from '@aws-sdk/client-rds-data';

// 環境変数
const secretArn = process.env.SECRET_ARN;
const dbName = process.env.DB_NAME;
const clusterArn = process.env.CLUSTER_ARN;
const rdsData = new RDSDataClient({ region: process.env.AWS_REGION });

// Lambda関数ハンドラー
export const handler = async (event: any): Promise<any> => {
  console.log('Received event:', JSON.stringify(event, null, 2));

  try {
    // Data APIでクエリを実行
    const result = await rdsData.send(
      new ExecuteStatementCommand({
        resourceArn: clusterArn,
        secretArn: secretArn,
        database: dbName,
        sql: 'SELECT * FROM users',
        includeResultMetadata: true,
      })
    );

    // レスポンスデータを整形
    const users = result.records?.map(record => {
      const user: Record<string, any> = {};
      result.columnMetadata?.forEach((meta, index) => {
        const columnName = meta.name || `column_${index}`;
        const value = record[index].stringValue || record[index].longValue || record[index].booleanValue;
        user[columnName] = value;
      });
      return user;
    }) || [];

    // 成功レスポンス
    return {
      statusCode: 200,
      headers: {
        'Content-Type': 'application/json'
      },
      body: JSON.stringify({
        users: users
      })
    };

  } catch (error: unknown) {
    // エラーログ
    console.error('Error:', error);

    // エラーレスポンス
    return {
      statusCode: 500,
      headers: {
        'Content-Type': 'application/json'
      },
      body: JSON.stringify({
        message: 'Error querying users table via Data API',
        error: error instanceof Error ? error.message : 'Unknown error'
      })
    };
  }
};

import * as cdk from 'aws-cdk-lib';
import { Construct } from 'constructs';
import { Vpc } from './vpc';
import { Aurora } from './aurora';
import { Lambda } from './lambda';
import { ApiGateway } from './apigateway';

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

    // VPCの作成
    const vpc = new Vpc(this, 'VpcConstruct');

    // Aurora Serverless v2の作成
    const aurora = new Aurora(this, 'AuroraConstruct', vpc.vpc);

    // Lambda関数の作成
    const lambdaFunction = new Lambda(this,
      'LambdaConstruct',
      vpc.vpc,
      aurora.dbSecret,
      aurora.rdsProxy,
      aurora.cluster   // 追加
    );

    // API Gatewayの作成
    new ApiGateway(this,
      'ApiGatewayConstruct',
      lambdaFunction.rdsProxyLambda,
      lambdaFunction.dataApiLambda   //追加
    );
  }
}

# デプロイ前の構文チェックとCloudFormationテンプレート生成
cdk synth

# デプロイ
cd deploy

curl -X GET https://0hvjwvx8s2.execute-api.ap-northeast-1.amazonaws.com/prod/data-api

{
  "users": [
    {
      "id": 1,
      "name": "Test User 1",
      "create_datetime": "2025-03-17 05:29:33.716686",
      "update_datetime": "2025-03-17 05:29:33.716686"
    },
    {
      "id": 2,
      "name": "Test User 2",
      "create_datetime": "2025-03-17 05:29:33.716686",
      "update_datetime": "2025-03-17 05:29:33.716686"
    },
    {
      "id": 3,
      "name": "Test User 3",
      "create_datetime": "2025-03-17 05:29:33.716686",
      "update_datetime": "2025-03-17 05:29:33.716686"
    },
    {
      "id": 4,
      "name": "Test User 4",
      "create_datetime": "2025-03-17 05:29:33.716686",
      "update_datetime": "2025-03-17 05:29:33.716686"
    },
    {
      "id": 5,
      "name": "Test User 5",
      "create_datetime": "2025-03-17 05:29:33.716686",
      "update_datetime": "2025-03-17 05:29:33.716686"
    },
    {
      "id": 6,
      "name": "Test User 6",
      "create_datetime": "2025-03-17 05:29:33.716686",
      "update_datetime": "2025-03-17 05:29:33.716686"
    },
    {
      "id": 7,
      "name": "Test User 7",
      "create_datetime": "2025-03-17 05:29:33.716686",
      "update_datetime": "2025-03-17 05:29:33.716686"
    },
    {
      "id": 8,
      "name": "Test User 8",
      "create_datetime": "2025-03-17 05:29:33.716686",
      "update_datetime": "2025-03-17 05:29:33.716686"
    },
    {
      "id": 9,
      "name": "Test User 9",
      "create_datetime": "2025-03-17 05:29:33.716686",
      "update_datetime": "2025-03-17 05:29:33.716686"
    },
    {
      "id": 10,
      "name": "Test User 10",
      "create_datetime": "2025-03-17 05:29:33.716686",
      "update_datetime": "2025-03-17 05:29:33.716686"
    }
  ]
}