RDS Proxy 経由で RDS に接続する

タイプ: カスタムTCP
ポート範囲: 3306
ソース: sg-xxxxxxxxx(Lambda のSG)

タイプ: カスタムTCP
ポート範囲: 3306
ソース: sg-yyyyyyyyy(RDS Proxy のSG)

タイプ: HTTPS
ポート範囲: 443
ソース: sg-xxxxxxxxx(Lambda のSG)

サービス名: com.amazonaws.ap-northeast-1.secretsmanager
エンドポイントタイプ: interface
VPC: 上記で作成した、VPC
セキュリティグループ: Secrets Manager 用のセキュリティグループ
サブネット: 上記で作成した、2つのプライベートサブネット
プライベートDNS: 有効

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "logs:CreateLogGroup",
                "logs:CreateLogStream",
                "logs:PutLogEvents",
                "ec2:CreateNetworkInterface",
                "ec2:DescribeNetworkInterfaces",
                "ec2:DeleteNetworkInterface",
                "ec2:AssignPrivateIpAddresses",
                "ec2:UnassignPrivateIpAddresses"
            ],
            "Resource": "*"
        }
    ]
}

メソッド: GET
リソースパス: /
統合ターゲット: (先程作成した Lambda の名前)

$ curl https://xxxxxxxx.execute-api.ap-northeast-1.amazonaws.com
"Hello from Lambda!"

import boto3
import base64
from botocore.exceptions import ClientError

def lambda_handler(event, context):

    secret_name = "YourSecretName" # 書き換えてください
    region_name = "ap-northeast-1"

    session = boto3.session.Session()
    client = session.client(
        service_name='secretsmanager',
        region_name=region_name
    )

    try:
        get_secret_value_response = client.get_secret_value(
            SecretId=secret_name
        )
    except Exception as e:
        raise e
    else:
        if 'SecretString' in get_secret_value_response:
            return get_secret_value_response['SecretString']
        else:
            return base64.b64decode(get_secret_value_response['SecretBinary'])

$ curl https://xxxxxxxx.execute-api.ap-northeast-1.amazonaws.com | jp
{
  "username": "admin",
  "password": "xxxxxxxxxxxxxxx",
  "engine": "mysql",
  "host": "database-1.cluster-xxxxxxxxxx.ap-northeast-1.rds.amazonaws.com",
  "port": 3306,
  "dbname": "test_db",
  "dbClusterIdentifier": "database-1"
}

$ sudo amazon-linux-extras install python3.8 -y
$ sudo update-alternatives --install /usr/bin/python3 python3 /usr/bin/python3.8 1
$ python3 -V
Python 3.8.5

$ curl -O https://bootstrap.pypa.io/get-pip.py
$ python3 get-pip.py

$ pip install pymysql -t python
$ zip -r pymysql.zip python

$ aws s3 cp pymysql.zip s3://${input-bucket-name}/ # bucket名は要編集

try:
    get_secret_value_response = client.get_secret_value(
        SecretId=secret_name
    )
except Exception as e:
    raise e
else:
    secret_info = json.loads(get_secret_value_response["SecretString"])

# DB操作
connect = pymysql.connect(
    # Proxy のエンドポイントを指定するのを忘れないでください
    host="proxy.proxy-xxxxx.ap-northeast-1.rds.amazonaws.com",
    user=secret_info["username"],
    passwd=secret_info["password"],
    db=secret_info["dbname"],
    connect_timeout=5,
    cursorclass=pymysql.cursors.DictCursor,
)