[AWS] API Gateway + Lambda + RDS(MySQL) 연결 (2)

이전 글에 이어 Lambda와 RDS를 연결하는 부분을 구현해보자.

RDS로는 MySQL을 사용할 것이다.

 

 

RDS

1. 파라미터 그룹 설정

 

RDS 생성 후 파라미터 그룹에서 몇 가지 환경 설정 작업을 해줘야 한다.

 

- 타임존 설정

- Character Set

- Max Connection

 

 

RDS > 파라미터 그룹 > 파라미터 그룹 생성

 

파라미터 그룹 패밀리에는 RDB 생성 시 선택했던 MySQL 버전을 선택한다.

 

생성된 파라미터 그룹을 클릭하고 편집을 선택한다.

 

 

time_zone → Asia/Seoul

 

 

character_set_client, character_set_connection, character_set_database, character_set_filesystem, character_set_results, character_set_server → uft8mb4

 

collation_connection, collation_server → utf8mb4_general_ci

참고 : utf8mb4와 utf8의 차이

→ 이모지 저장 가능 여부이다. utf8mb4는 이모지를 저장할 수 있다.

 

 

max_connection → 기본 (인스턴스 사양에 따라 자동으로 정해짐)

 

 

생성한 파라미터 그룹을 데이터베이스 인스턴스와 연결해야 한다.

 

RDS > 데이터베이스 > 생성한 인스턴스 선택 > 수정 > 추가 구성

 

DB 파라미터 그룹을 default.mysql8.0에서 방금 생성한 파라미터 그룹으로 바꾼다.

 

 

서비스가 운영 중인 상태가 아니라면 즉시 적용을 선택한다. 수정 완료 후 데이터베이스를 재부팅해준다.

 

 

2. 보안 그룹 설정

 

로컬 PC 및 EC2에서 RDS에 접근하기 위해 RDS의 보안 그룹에 IP를 등록해야 한다.

 

데이터베이스 인스턴스 > 연결 및 보안 > VPC 보안 그룹

 

보안 그룹 선택 > 인바운드 규칙 편집

유형에서 MYSQL/Aurora 선택 후 내 IP를 등록한다.

 

 

IAM

IAM > 역할 > 역할 생성

 

AWS 서비스, Lambda 선택

 

 

AWSLambdaVPCAccessExecutionRole 권한 추가 후 이름 입력하고 역할 생성!

 

 

Lambda

1. Lambda 함수 작성

 

로컬에서 lambda_function.py 코드를 작성하고 zip 파일로 압축해서 업로드할 것이다.

 

lambda_function.py

import sys
import logging
import pymysql
import json
import random


rds_host  = "RDS 엔드포인트"
user_name = "Master 사용자 이름"
password = "Password"
db_name = "초기 데이터베이스 이름"

logger = logging.getLogger()
logger.setLevel(logging.INFO)


try:
    conn = pymysql.connect(host=rds_host, user=user_name, passwd=password, db=db_name, connect_timeout=5)
except pymysql.MySQLError as e:
    logger.error("연결 실패!")
    logger.error(e)
    sys.exit()

logger.info("연결 성공!")


def lambda_handler(event, context):
    print(event)
    
    randnum = random.randrange(1,123)
    
    userid = "user_test" + str(randnum)
    url = event["body-json"]["url"]

    item_count = 0
    sql_string = f"insert into URLS (userid, url) values('{userid}', '{url}')"
    
    with conn.cursor() as cur:
        cur.execute("create table if not exists URLS ( userid varchar(20) PRIMARY KEY, url varchar(20) NOT NULL)")
        cur.execute(sql_string)
        conn.commit()

    return "Lambda+RDS 성공!"

 

lambda_handler 함수 안에서 print한 event는 CloudWatch 로그에서 확인할 수 있다.

 

 

lambda_function.py 파일이 있는 디렉터리를 대상으로 pip install --target [dir_name] pymysql --no-user 코드를 터미널에 입력한다.

 

 

다음과 같은 폴더들이 생기는데, lambda_function.py 파일과 폴더들을 lambda_function.zip으로 압축한다. 이 zip 파일을 Lambda에 업로드한다.

 

 

2. 역할 수정

 

기존 역할을 AWSLambdaVPCAccessExecutionRole 권한이 있는 역할로 바꾼다.

 

 

3. VPC 설정

 

구성 > VPC > 편집

 

VPC, 서브넷, VPC 보안 그룹을 RDS와 똑같이 설정한다.

 

 

MySQL Workbench

로컬에 MySQL Workbench를 설치하고 MySQL Connections에서 RDS와 연결한다.

 

 

Connection Name, Hostname(RDS 엔드포인트), Username(Master 사용자 이름), Password(Master 사용자 암호)를 입력한 후 접속하면 AWS에서 RDS 인스턴스 생성 시 설정한 기본 데이터베이스가 보인다.

 

 

테이블을 조회해보면 Postman으로 보낸 POST 요청이 잘 들어간 것을 확인할 수 있다!