[NestJS] 21. AWS 클라우드 서비스와 배포

npm install @aws-sdk/client-s3 @aws-sdk/s3-request-presigner

import { Injectable } from '@nestjs/common'; import { S3 } from '@aws-sdk/client-s3'; import { PutObjectCommand } from '@aws-sdk/client-s3'; @Injectable() export class S3Service { private s3: S3; constructor() { this.s3 = new S3({ region: 'ap-northeast-2', credentials: { accessKeyId: process.env.AWS_ACCESS_KEY_ID, secretAccessKey: process.env.AWS_SECRET_ACCESS_KEY, }, }); } async uploadFile(file: Express.Multer.File, bucketName: string): Promise<string> { const encodedFileName = encodeURIComponent(`${Date.now()}-${file.originalname}`); const command = new PutObjectCommand({ Bucket: bucketName, Key: encodedFileName, Body: file.buffer, ContentType: file.mimetype, }); await this.s3.send(command); return `https://${bucketName}.s3.amazonaws.com/${encodedFileName}`; // 반환 URL } }

@Injectable() export class AttachmentUploadService { constructor( @InjectRepository(Attachment) private readonly attachmentRepository: Repository<Attachment>, private readonly s3Service: S3Service, ) {} // 파일 업로드 async uploadFile(file: Express.Multer.File) { try { const fileUrl = await this.s3Service.uploadFile(file, 's3-bucket-boardapp'); return { message: 'File uploaded successfully', url: fileUrl, }; } catch (err) { console.error('S3 Upload Error:', err); throw new HttpException('Failed to upload file', HttpStatus.INTERNAL_SERVER_ERROR); } } // 파일 엔터티 데이터베이스에 저장 async save(file: Attachment) { try { return await this.attachmentRepository.save(file); } catch (err) { throw new HttpException('Failed to save file', HttpStatus.INTERNAL_SERVER_ERROR); } } }

@Injectable() export class ProfilePictureUploadService { constructor( @InjectRepository(ProfilePicture) private readonly profilePictureRepository: Repository<ProfilePicture>, private readonly s3Service: S3Service, ) {} // 프로필 사진 파일 업로드 async uploadProfilePicture(file: Express.Multer.File) { try { const fileUrl = await this.s3Service.uploadFile(file, 's3-bucket-boardapp'); return { message: 'File uploaded successfully', url: fileUrl, }; } catch (err) { console.error('S3 Upload Error:', err); throw new HttpException('Failed to upload file', HttpStatus.INTERNAL_SERVER_ERROR); } } // 프로필 사진 엔터티 데이터베이스에 저장 async save(file: ProfilePicture) { try { return await this.profilePictureRepository.save(file); } catch (err) { throw new HttpException('Failed to save file', HttpStatus.INTERNAL_SERVER_ERROR); } } }

import { Injectable } from '@nestjs/common'; import { S3 } from '@aws-sdk/client-s3'; import { PutObjectCommand } from '@aws-sdk/client-s3'; @Injectable() export class S3Service { private s3: S3; constructor() { this.s3 = new S3({ region: process.env.AWS_S3_REGION, credentials: { accessKeyId: process.env.AWS_ACCESS_KEY_ID, secretAccessKey: process.env.AWS_SECRET_ACCESS_KEY, }, }); } async uploadFile(file: Express.Multer.File, prefix: string): Promise<any> { const normalizeFileName = this.normalizeFileName(file.originalname); const filePath = `${prefix}/${normalizeFileName}`; const command = new PutObjectCommand({ Bucket: process.env.AWS_S3_BUCKET_NAME, Key: filePath, Body: file.buffer, ContentType: file.mimetype, }); await this.s3.send(command); // CloudFront URL 반환 및 메타데이터 return { url: `https://${process.env.AWS_CLOUDFRONT_DOMAIN}/${filePath}`, filename: normalizeFileName, mimetype: file.mimetype, size: file.size, }; } private normalizeFileName(fileName: string): string { return fileName .replace(/[^a-zA-Z0-9.-]/g, '_') // 알파벳, 숫자, 점, 하이픈만 허용 .replace(/_{2,}/g, '_') // 연속된 언더바를 하나로 .replace(/^_|_$/g, ''); // 언더바로 시작하거나 끝나는 경우 제거 } }