Lambda 함수와 S3 버킷 연결하기

AWS console 창에서 Lambda 검색 후 이동

함수 생성 클릭

함수이름을 입력하고, 런타임은 python 3.12 를 선택한다. 람다 함수를 작성할 때 사용할 언어를 선택하는 것. 나는 파이썬이 주 언어이기 때문에 파이썬을 선택했다. 이렇게 하면 함수 생성은 끝난다.

이 화면이 나오면 성공이다. 이제 여기 트리거 추가를 클릭한다. 

트리거 추가에서 소스를 선택한다. 소스는 S3를 선택.

아래 그림에 나와있는 것 처럼 버킷은 아까 우리가 만든 버킷을 선택하고, 아래 체크박스에 표시하고 추가를 누르면 lambda에 트리거 추가가 된다.

 

코드-> 코드 소스 창에서 lambda_function.py 라는 기본 파이썬 파일을 선택한 후 아래 코드를 삽입하고 Deploy를 선택하면 된다.
나중에 추가적으로 람다함수 변경을 통해서 필요한게 있으면 각자 알맞게 수정하면 된다. 

import boto3
import gzip
import json

def lambda_handler(event, context):
    s3 = boto3.client('s3')
    logs = boto3.client('logs')

    for record in event['Records']:
        bucket = record['s3']['bucket']['name']
        key = record['s3']['object']['key']

        response = s3.get_object(Bucket=bucket, Key=key)
        log_data = gzip.decompress(response['Body'].read()).decode('utf-8')

        log_group_name = 'YourLogGroupName' //클라우드워치의 로그 그룹 이름을 작성한다.
        log_stream_name = 'YourLogStreamName'// 클라우드워치의 로그 스트림 이름을 작성한다.

        response = logs.create_log_stream(
            logGroupName=log_group_name,
            logStreamName=log_stream_name
        )

        log_events = [
            {
                'timestamp': int(record['eventTime'] / 1000),
                'message': log_data
            }
        ]

        response = logs.put_log_events(
            logGroupName=log_group_name,
            logStreamName=log_stream_name,
            logEvents=log_events
        )

 여기까지 하면 람다함수와 S3 버킷 간 연결이 완료된다. 위 코드블럭을 보면 로그 그룹 및 로그스트림이름을 작성해야하는 부분이 있다. 이는 클라우드 워치에서 설정하는 것이다. 람다와 클라우드 워치를 연결하는 부분이 필요하다. 이는 다음 게시글에서 다뤄보도록 하겠다.