[ENHANCEMENT] 이미지 압축 로직 Lambda로 분리

[soun997]

이슈 번호 (#317)

요약

문제

• 기존에는 이미지를 압축하는 로직을 애플리케이션 서버에서 실행하고 있었습니다.
• 그러나 이미지 압축에 소요되는 시간으로 인해 다량의 이미지 업로드 요청시, 다른 요청들까지 대기함으로써 서버의 응답성이 저하되는 문제가 있었습니다.
  • VU를 10으로 설정하고 성능 테스트를 진행한 결과, 요청 처리가 불가능할 정도로 서버에 부하가 오는 것을 확인할 수 있었습니다.

아이디어

• 이미지 압축 로직을 애플리케이션 서버에서 분리한다면, 요청이 이미지 압축이 끝날 때까지 대기하는 시간을 없앨 수 있을 것이라고 생각했습니다.

해결

• 이미지 압축 로직을 Lambda로 분리하여 기존 로직을 제거했습니다.
• 콜드스타트 문제를 회피하기 위해 Node 기반의 코드로 이미지 압축 로직을 재작성했습니다.
  • 압축 퀄리티는 기본값인 80을 사용했습니다.
• S3에 이미지가 업로드되는 이벤트를 트리거로 Lambda 함수가 자동으로 실행되게 설정했습니다.
  • 중간에 Amazon SQS(메시지큐)를 추가해 안정적인 이벤트 전달이 가능하도록 했습니다.

Node.js 기반 이미지 압축 로직 코드

import { S3Client, GetObjectCommand, PutObjectCommand } from "@aws-sdk/client-s3";
import sharp from 'sharp';

const s3 = new S3Client({
    region: 'ap-northeast-2'
});

export async function handler(event) {
    // S3 버킷과 객체 키 가져오기
    const bucket = event.Records[0].s3.bucket.name;
    const key = decodeURIComponent(event.Records[0].s3.object.key.replace(/\+/g, ' '));

    const quality = 80;

    try {
        // S3에서 이미지 가져오기
        const getObjectCmd = new GetObjectCommand({ Bucket: bucket, Key: key });
        const s3Object = await s3.send(getObjectCmd);
        const image = await s3Object.Body.transformToByteArray();

        // 새 키 생성 (확장자를 .webp로 변경)
        const newKey = key.replace(/\.[^/.]+$/, ".webp");

        // 이미지를 WebP로 변환
        const webpBuffer = await sharp(image)
            .withMetadata()
            .toFormat('webp', { quality: quality, lossless: false })
            .toFile(newKey, (err, info) => console.log)
            .toBuffer();

        // 변환된 이미지를 S3에 업로드
        const putObjectCmd = new PutObjectCommand({
            Bucket: bucket,
            Key: newKey,
            Body: webpBuffer,
            ContentType: 'image/webp'
        });

        await s3.send(putObjectCmd);

        console.log(`Successfully compressed and uploaded: ${newKey}`);

        return {
            statusCode: 200,
            body: JSON.stringify('Image processed successfully')
        };
    } catch (error) {
        console.error('Error processing image:', error);
        return {
            statusCode: 500,
            body: JSON.stringify('Error processing image')
        };
    }
}