[AWS] Lambda에서 S3 파일 읽기 실습

🎯 AWS 내에 구축한 Lambda에서 S3에 접근하여 파일 읽기

✅ Lambda, S3를 학습 할 수 있다.

 

 

👉 S3 버킷 생성

아래와 같이 S3 버킷을 만들어보자.

s3로 접속

 

버킷 만들기를 클릭

 

버킷 이름, 리전 설정 (이름은 중복 불가, 리전은 서울로) (⛔ lambda를 lamdba로 잘못 적은 버킷이므로 주의)

다음과 같이 서버 측 암호화 활성 후 SSE-S3 클릭 후 버킷 만들기 실행

 

 

👉 S3에 파일 업로드

람다에서 쓸 데이터를 업로드 해보자  

 

업로드 버튼 클릭

 

hello world라고 만든 test.txt를 업로드

 

 

👉 IAM Role 만들기

Lambda를 위한 IAM Role을 만들어 S3 엑세스 권한을 부여하자

IAM 접근

 

액세스 관리 → 역할 → 역할 만들기 선택

 

Lambda를 사용할 것이니 AWS 서비스 → Lambda → 다음 선택

 

AmazonS3FullAccess 권한을 부여하도록 한다.

 

역할 이름을 설정

 

역할 생성 클릭

 

👉 Lambda 함수 생성하기

이제 S3와 연결 할 lambda를 만들어보자.

lambda 선택

 

함수 생성 클릭

 

함수 이름(Lambda 이름)을 정해주고 역할(role)은 crocusS3FullAccess로 정해준다.

 

 

👉 Lambda 함수 작성하여 S3 데이터 호출하기

아래 샘플 코드를 이용하여 S3에 연결해보자.

 

https://docs.aws.amazon.com/ko_kr/AmazonS3/latest/userguide/example_s3_GetObject_section.html

AWS SDK를 사용하여 Amazon S3 버킷에서 객체 가져오기 - Amazon Simple Storage Service

 

import { GetObjectCommand } from "@aws-sdk/client-s3";
import { S3Client } from "@aws-sdk/client-s3";

const REGION = "ap-northeast-2"; //e.g. "us-east-1"
const s3Client = new S3Client({ region: REGION });

export const handler = async(event) => {
    const bucketParams = {
        Bucket: "crocus-lamdba-s3-test-bucket",
        Key: "test.txt"
    }

    try {
        // Create a helper function to convert a ReadableStream to a string.
        const streamToString = (stream) =>
          new Promise((resolve, reject) => {
            const chunks = [];
            stream.on("data", (chunk) => chunks.push(chunk));
            stream.on("error", reject);
            stream.on("end", () => resolve(Buffer.concat(chunks).toString("utf8")));
          });
        
        // Get the object} from the Amazon S3 bucket. It is returned as a ReadableStream.
        const data = await s3Client.send(new GetObjectCommand(bucketParams));
        
        // Convert the ReadableStream to a string.
        const bodyContents = await streamToString(data.Body);
        return {
            statusCode: 200,
            body: JSON.stringify(bodyContents),
        };
    } catch (err) {
        console.log("Error", err);
    }

};

 

코드를 입력 후 deploy → test를 통해 실행

 

test.txt에 hello world를 적은 내용이 잘 나타남을 알 수 있다.