AWS Lambda, API Gateway, RDS

API Gateway 👉 AWD Lambda 👉 RDS 연결

Lambda 함수 생성 & RDS 연결

• post_db_practice의 이름으로 람다 함수를 생성하자.
  

• 로컬에서 zip 파일을 만들어보자 (파이썬 패키지 관련 설정 설명)

pip3 install pymysql -t ./

• 해당 압축 파일을 Layer로 추가하자.
  

• post_db_practice 람다 함수에서 Layer 추가
  

• 코드 작성

import pymysql

'''
예시
event = {}
event['cafe_id'] = 1
event['possible'] = 1
event['star'] = 1
event['consent'] = 1
event['noise'] = 1
event['table'] = 1
event['light'] = 1
event['wifi'] = 1
event['customer'] = 1
event['detail'] = "요호"
event['writer'] = 1
'''


def lambda_handler(event, context):
    conn = pymysql.connect(
        host="[Hostname]", 
        user="[Username]", 
        password="[Password]", 
        db="[Database]"
    )
    cursor = conn.cursor()
    
    data = []
    data.append(event['cafe_id'])
    data.append(event['possible'])
    data.append(event['star'])
    data.append(event['consent'])
    data.append(event['table'])
    data.append(event['noise'])
    data.append(event['light'])
    data.append(event['wifi'])
    data.append(event['customer'])
    data.append(event['detail'])
    data.append(event['writer'])
    
    print(data)

    sql = 'INSERT INTO review  \
    	  (`cafe_id`, `possible`, `star`, `consent`, `table`, `noise`, `light`, `wifi`, `customer`, `detail`, `writer`)  \
           VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s)'
           
    cursor.execute(sql, data)
    
    conn.commit()
    conn.close()

    return {
             "success": True
           }

API Gateway 설정

API url은 /cafes/{cafe-id}/reviews로
id가 {cafe-id}인 카페에 대한 후기를 남기는 시나리오라고 하자. (코드를 이해했다면 바로 이해할 듯.)

• 리소스 추가
  이렇게 3개의 리소스를 추가한다.

• [POST] 메서드 추가
  

• [통합 요청] 선택하기
  

• URL 경로 파라미터로 cafe-id 설정하기

• [매핑 템플릿] 설정 > 메서드 요청 패스스루
  

• cafe_id에 대한 코드 수정

import pymysql

def lambda_handler(event, context):

    cafe_id = event['params']['path']['cafe-id']
    body = event['body-json']
        
    conn = pymysql.connect(
        host="[Hostname]", 
        user="[Username]", 
        password="[Password]", 
        db="[Database]"
    )
    cursor = conn.cursor()
    print(event)
    
    data = []
    data.append(cafe_id) # cafe_id
    data.append(body['possible'])
    data.append(body['star'])
    data.append(body['consent'])
    data.append(body['table'])
    data.append(body['noise'])
    data.append(body['light'])
    data.append(body['wifi'])
    data.append(body['customer'])
    data.append(body['detail'])
    data.append(body['writer'])
    
    print(data)

    sql = 'INSERT INTO \
           review (`cafe_id`, `possible`, `star`, `consent`, `table`, `noise`, `light`, `wifi`, `customer`, `detail`, `writer`)  \
           VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s)'
    cursor.execute(sql, data)
    
    conn.commit()
    conn.close()

    return {
            "success": True
           }

(더 효율적인 코드 생각해보자..)

그 후 API 배포! 하면 성공

++ 인증된 사용자만 접근할 수 있도록 API 키 설정하기

---

에러 정리

요청 테스트할 때

Execution failed due to configuration error: Invalid permissions on Lambda function

이런 에러 메세지와 함께 Internal Server Error가 났다.

[통합 요청](Integration Request)을 선택하여
이런 팝업창이 나오도록 하자
[Lambda 함수] 선택할 때 뜬다.

참고 링크

• pymysql 사용법 참고
• Lambda, RDS 연결
• API Gateway 매핑 템플릿 설정