AWS re:Post을(를) 사용하면 다음에 동의하게 됩니다. AWS re:Post 이용 약관
AWS re:Postre:Post

Looking for example lambda functions for Aurora Serverless v2

0

Aurora MySQL serverless 1 is no longer supported (for creation), yet all of the documentation is still pointing towards serverless v1. I am using MySQL serverless v2 with secrets manager and I have a python module that is able to connect to the writer endpoint alright without RDS proxy. For following the lambda function examples, I have created an RDS proxy, however I am finding a hard time finding reliable lambda code examples, especially in javascript that can successfully connect to my Aurora serverless v2. The goal is to have this connection be triggered by cognito events.

주제
서버리스컴퓨팅보안, 신원 및 규정 준수분석데이터베이스
태그
서버리스AWS Lambda아마존 Cognito아마존 AuroraAWS 시크릿 관리자
언어
English
rePost-User-1458258
질문됨 일 년 전1297회 조회
1개 답변
0

Hi,

Below is a sample code,

const AWS = require('aws-sdk');
const rdsDataService = new AWS.RDSDataService();

exports.handler = async (event, context) => {
    // Set the SQL statement
    const sql = 'SELECT * FROM my_table';

    // Execute the SQL statement
    const params = {
        database: 'my_database',
        resourceArn: 'arn:aws:rds:us-east-1:123456789012:cluster:my-cluster',
        secretArn: 'arn:aws:secretsmanager:us-east-1:123456789012:secret:my-secret',
        sql: sql
    };
    const response = await rdsDataService.executeStatement(params).promise();

    // Return the query results as a JSON string
    const body = JSON.stringify(response.records);
    const statusCode = 200;
    return { statusCode, body };
};

Hope this helps

AWS
Arun
답변함 일 년 전
  • rePost-User-1458258
    일 년 전

    Hi Arun, thanks for the code example. This brings the same error:

    {"errorType":"BadRequestException","errorMessage":"HttpEndpoint is not enabled for cluster

    since serverless v2 has no support for Data API. Hence, the need for code example using RDS proxy endpoint alongside secrets manager.

    Thanks again!

  • Arun
    일 년 전

    Sure. can you try importing pg8000 to create a pg8000.connect object to connect to the DB. A code sample with teh same is below

    import boto3 import pg8000

    def lambda_handler(event, context): rds_data = boto3.client('rds-data') response = rds_data.execute_statement( resourceArn='arn:aws:rds:us-east-1:123456789012:cluster:my-db-cluster', secretArn='arn:aws:secretsmanager:us-east-1:123456789012:secret:my-db-secret', database='my-db-name', sql='SELECT * FROM my_table;' )

    conn = pg8000.connect(
    host=response['records'][0][0]['stringValue'],
    port=5432,
    database='my-db-name',
    user='my-db-user',
    password='my-db-password'
)

cursor = conn.cursor()
cursor.execute('SELECT * FROM my_table')
rows = cursor.fetchall()

for row in rows:
    print(row)

cursor.close()
conn.close()

    Try and let us know, if it works

로그인하지 않았습니다. 로그인해야 답변을 게시할 수 있습니다.

좋은 답변은 질문에 명확하게 답하고 건설적인 피드백을 제공하며 질문자의 전문적인 성장을 장려합니다.

질문 답변하기에 대한 가이드라인

관련 콘텐츠