AWS Javascript S3 SDK를 사용하여 카페24 클라우드의 오브젝트 스토리지를 사용할 수 있습니다.
목차
1. AWS Javascript v3 S3 SDK 사용하기
2. Javascript v3 S3 SDK 설치
3. 카페24 클라우드 오브젝트 스토리지의 API Key 확인하기
4. 자격 증명 프로필 설정
5. 코드 예제
1. AWS Javascript v3 S3 SDK 사용하기
카페24 클라우드의 오브젝트 스토리지는 S3 API와 호환이 되므로 해당 SDK 사용이 가능합니다.
매뉴얼 테스트 버전
AWS Javascript SDK version : 3.231.0
Node.js version : 14.17.1
Npm version : 6.14.13
Javascript v3 S3 SDK 참고 링크
문서 : Developer guide - AWS SDK for Javascript 3.x
예제 : Javascript v3 S3 examples
2. Javascript v3 S3 SDK 설치
Javascript 개발을 위한 실행환경 Node.js 가 설치된 상태에서 진행합니다.
Npm 설치 : npm 프로젝트 디렉터리로 이동한 다음, AWS Javascript v3 SDK를 설치합니다.
npm install @aws-sdk/client-s3
3. 카페24 클라우드 오브젝트 스토리지의 API Key 확인하기
아래 매뉴얼을 참고하여 신청한 오브젝트 스토리지의 Access Key와 Secret Key를 확인합니다.
오브젝트 스토리지는 어떻게 사용하나요? > API 키 생성
4. 자격 증명 프로필 설정
인증 파일을 생성하여 Access Key와 Secret Key를 등록합니다.
자세한 정보는 AWS SDK for Java v2 - Using Credentials에서 확인할 수 있습니다.
인증 파일의 기본 경로는 "~/.aws/credentials"입니다.
$ cat >> ~/.aws/credentials << EOF
[default]
aws_access_key_id = [access_key]
aws_secret_access_key = [secret_key]
EOF
5. 코드 예제
※ 주의 사항 ※
사용하는 Javascript 및 SDK 버전에 따라 변경이 필요할 수 있습니다.
해당 내용은 AWS Javascript SDK를 사용하여 카페24클라우드의 오브젝트 스토리지를 이용하는 예제 코드로, 필요에 따라 응용할 수 있습니다.
(1) 버킷 생성
import {CreateBucketCommand, S3Client} from "@aws-sdk/client-s3";
const s3Client = new S3Client({endpoint: "https://kr.cafe24obs.com", forcePathStyle: true, region: "zone-group-cafe24cloud"});
export const bucketParams = {
Bucket: "test-bucket"
};
export const run = async () => {
try {
const data = await s3Client.send(new CreateBucketCommand(bucketParams));
console.log("Success : Bucket [" + bucketParams.Bucket + "] has been created.\n",)
console.log("Response :", JSON.stringify(data, null, 4));
} catch (err) {
console.log("Error", err);
}
};
run();
output 예시
Success : Bucket [test-bucket] has been created.
Response : {
"$metadata": {
"httpStatusCode": 200,
"requestId": "tx0000084051beac6c5643e-0063b28289-1682e4f-zone-cafe24cloud-prd-obs",
"attempts": 1,
"totalRetryDelay": 0
}
}
(2) 버킷 삭제
오브젝트가 모두 삭제된 빈 버킷에 대해서만 삭제가 가능합니다.
import { DeleteBucketCommand, S3Client } from "@aws-sdk/client-s3";
const s3Client = new S3Client({ endpoint: "https://kr.cafe24obs.com", forcePathStyle: true, region: "zone-group-cafe24cloud" });
export const bucketParams = { Bucket: "test-bucket" };
export const run = async () => {
try {
const data = await s3Client.send(new DeleteBucketCommand(bucketParams));
console.log("Success : Bucket ["+bucketParams.Bucket+"] has been deleted.");
console.log("Response : ",JSON.stringify(data, null, 4))
return data;
} catch (err) {
console.log("Error", err);
}
};
run();
output 예시
Success : Bucket [test-bucket] has been deleted.
Response : {
"$metadata": {
"httpStatusCode": 204,
"requestId": "tx000003362f71a7f0eb52a-0063b28242-168a1f1-zone-cafe24cloud-prd-obs",
"attempts": 1,
"totalRetryDelay": 0
}
}
(3) 버킷 리스트 조회
존재하는 모든 버킷을 조회합니다.
import { ListBucketsCommand, S3Client } from "@aws-sdk/client-s3";
const s3Client = new S3Client({ endpoint: "https://kr.cafe24obs.com", forcePathStyle: true, region: "zone-group-cafe24cloud" });
export const run = async () => {
try {
const data = await s3Client.send(new ListBucketsCommand({}));
console.log("Success", JSON.stringify(data.Buckets, null, 4));
} catch (err) {
console.log("Error", err);
}
};
run();
output 예시
Success [
{
"Name": "test-bucket",
"CreationDate": "2022-12-30T01:44:29.104Z"
},
{
"Name": "test-bucket1",
"CreationDate": "2022-12-29T06:04:09.457Z"
},
{
"Name": "test-bucket2",
"CreationDate": "2022-12-29T06:04:16.613Z"
}
]
(4) 오브젝트 업로드
파일을 오브젝트 스토리지의 특정 버킷에 업로드 합니다.
1) 새로운 파일을 업로드
코드상에서 파일명, 파일 내용(Body)을 선언하여 버킷에 업로드 하는 방법입니다.
import {PutObjectCommand, S3Client} from "@aws-sdk/client-s3";
const s3Client = new S3Client({endpoint: "https://kr.cafe24obs.com", forcePathStyle: true, region: "zone-group-cafe24cloud"});
export const bucketParams = {
Bucket: "test-bucket",
Key: "test-file.txt",
Body: "Content of test-file.txt - Hello World!"
};
export const run = async () => {
try {
await s3Client.send(new PutObjectCommand(bucketParams));
console.log("Success : Successfully uploaded newly created file: " + bucketParams.Bucket + "/" + bucketParams.Key);
return;
} catch (err) {
console.log("Error", err);
}
};
run()
output 예시
Success : Successfully uploaded newly created file: test-bucket/test-file.txt
2) 로컬에 있는 파일을 업로드
기존의 로컬에 있는 파일을 버킷에 업로드 하는 방법입니다.
import {PutObjectCommand, S3Client} from "@aws-sdk/client-s3";
import * as path from 'path';
import * as fs from 'fs';
const s3Client = new S3Client({endpoint: "https://kr.cafe24obs.com", forcePathStyle: true, region: "zone-group-cafe24cloud"});
# 로컬에 위치한 업로드할 파일의 경로
const file = "clients\\client-s3\\src\\commands\\cafe24-demo\\files\\test-file-local.txt"
const fileStream = fs.createReadStream(file);
export const uploadParams = {
Bucket: "test-bucket",
Key: path.basename(file),
Body: fileStream
};
export const run = async () => {
try {
await s3Client.send(new PutObjectCommand(uploadParams));
console.log("Success : Successfully uploaded exsisting file " + uploadParams.Bucket + "/" + uploadParams.Key);
return;
} catch (err) {
console.log("Error", err);
}
};
run()
output 예시
Success : Successfully uploaded exsisting file test-bucket/test-file-local.pdf
(5) 오브젝트 다운로드
버킷에 있는 파일을 로컬의 특정 경로로 다운로드 합니다.
import {GetObjectCommand, S3Client} from "@aws-sdk/client-s3"
import * as fs from 'fs';
const s3Client = new S3Client({endpoint: "https://kr.cafe24obs.com", forcePathStyle: true, region: "zone-group-cafe24cloud"});
export const run = async () => {
try {
const bucket_name = "test-bucket";
const key_name = "test-file.txt";
const download_bucket_params = {
Bucket: bucket_name,
Key: key_name
};
# 파일을 다운받을 경로
const downloadPath = 'clients\\client-s3\\src\\commands\\cafe24-demo\\files\\downloaded-file.txt';
const data = await s3Client.send(new GetObjectCommand(download_bucket_params));
console.log("\nDownloading " + key_name + " from " + bucket_name + " ...\n")
data.Body.pipe(fs.createWriteStream(downloadPath));
console.log(key_name + " is now downloaded to [" + downloadPath + "]")
} catch (err) {
console.log("Error creating and upload object to bucket", err);
process.exit(1);
};
};
run();
output 예시
Downloading test-file.txt from test-bucket ...
test-file.txt is now downloaded to [clients\client-s3\src\commands\cafe24-demo\files\downloaded-file.txt]
(6) 오브젝트 리스트 조회
버킷에 있는 모든 파일과 폴더를 조회합니다.
import { ListObjectsCommand, S3Client } from "@aws-sdk/client-s3";
const s3Client = new S3Client({ endpoint: "https://kr.cafe24obs.com", forcePathStyle: true, region: "zone-group-cafe24cloud" });
export const bucketParams = { Bucket: "test-bucket" };
export const run = async () => {
try {
const data = await s3Client.send(new ListObjectsCommand(bucketParams));
console.log("Success : \n", JSON.stringify(data, null, 4));
} catch (err) {
console.log("Error", err);
}
};
run();
output 예시
Success :
{
"$metadata": {
"httpStatusCode": 200,
"requestId": "tx00000ea81126555bcc2de-0063b27c2f-1682e4f-zone-cafe24cloud-prd-obs",
"attempts": 1,
"totalRetryDelay": 0
},
"Contents": [
{
"Key": "folder/",
"LastModified": "2023-01-01T14:09:25.283Z",
"ETag": "\"d41d8cd98f00b204e9800998ecf8427e\"",
"Size": 0,
"StorageClass": "STANDARD",
"Owner": {
"DisplayName": "clouduser",
"ID": "clouduser"
}
},
{
"Key": "folder/test-file-04",
"LastModified": "2023-01-01T14:10:04.636Z",
"ETag": "\"620f0b67a91f7f74151bc5be745b7110\"",
"Size": 4096,
"StorageClass": "STANDARD",
"Owner": {
"DisplayName": "clouduser",
"ID": "clouduser"
}
},
{
"Key": "test-file-01",
"LastModified": "2023-01-01T14:08:50.154Z",
"ETag": "\"620f0b67a91f7f74151bc5be745b7110\"",
"Size": 4096,
"StorageClass": "STANDARD",
"Owner": {
"DisplayName": "clouduser",
"ID": "clouduser"
}
}
],
"IsTruncated": false,
"Marker": "",
"MaxKeys": 1000,
"Name": "test-bucket",
"Prefix": ""
}
(7) 오브젝트 삭제
1) 하나의 오브젝트 삭제
특정 버킷에 있는 오브젝트를 삭제합니다.
import {DeleteObjectCommand, S3Client} from "@aws-sdk/client-s3";
const s3Client = new S3Client({endpoint: "https://kr.cafe24obs.com", forcePathStyle: true, region: "zone-group-cafe24cloud"});
export const bucketParams = {
Bucket: "test-bucket",
Key: "test-file.txt"
};
export const run = async () => {
try {
const data = await s3Client.send(new DeleteObjectCommand(bucketParams));
console.log("Success : Object [" + bucketParams.Key + "] has been deleted.");
console.log("Response : ", JSON.stringify(data, null, 4))
} catch (err) {
console.log("Error", err);
}
};
run();
output 예시
Success : Object [test-file.txt] has been deleted.
Response : {
"$metadata": {
"httpStatusCode": 204,
"requestId": "tx000008ed66bc303224d6c-0063b3e19b-168a1f1-zone-cafe24cloud-prd-obs",
"attempts": 1,
"totalRetryDelay": 0
}
2) 버킷의 모든 오브젝트 삭제
특정 버킷의 모든 오브젝트를 삭제합니다.
import {ListObjectsCommand, DeleteObjectCommand, S3Client} from "@aws-sdk/client-s3";
const s3Client = new S3Client({endpoint: "https://kr.cafe24obs.com", forcePathStyle: true, region: "zone-group-cafe24cloud"});
export const bucketParams = {
Bucket: "test-bucket"
};
export const run = async () => {
try {
console.log("Deleting all objects in the bucket.");
const data = await s3Client.send(new ListObjectsCommand(bucketParams));
let noOfObjects = data.Contents;
for (let i = 0; i < noOfObjects.length; i++) {
await s3Client.send(new DeleteObjectCommand({Bucket: bucketParams.Bucket, Key: noOfObjects[i].Key}));
}
console.log("Success. All objects in bucket [" + bucketParams.Bucket + "] are deleted. : \n", JSON.stringify(data, null, 4));
} catch (err) {
console.log("Error", err);
}
};
run();
output 예시
Deleting all objects in the bucket.
Success. All objects in bucket [test-bucket] are deleted. :
{
"$metadata": {
"httpStatusCode": 200,
"requestId": "tx0000042e054f120512bdb-0063b45ac4-1682e4f-zone-cafe24cloud-prd-obs",
"attempts": 1,
"totalRetryDelay": 0
},
"Contents": [
{
"Key": "folder/",
"LastModified": "2023-01-03T16:40:55.335Z",
"ETag": "\"d41d8cd98f00b204e9800998ecf8427e\"",
"Size": 0,
"StorageClass": "STANDARD",
"Owner": {
"DisplayName": "clouduser",
"ID": "clouduser"
}
},
{
"Key": "folder/test-file-01",
"LastModified": "2023-01-03T16:41:07.694Z",
"ETag": "\"620f0b67a91f7f74151bc5be745b7110\"",
"Size": 4096,
"StorageClass": "STANDARD",
"Owner": {
"DisplayName": "clouduser",
"ID": "clouduser"
}
},
{
"Key": "test-file-02",
"LastModified": "2023-01-03T16:41:35.762Z",
"ETag": "\"620f0b67a91f7f74151bc5be745b7110\"",
"Size": 4096,
"StorageClass": "STANDARD",
"Owner": {
"DisplayName": "clouduser",
"ID": "clouduser"
}
},
],
"IsTruncated": false,
"Marker": "",
"MaxKeys": 1000,
"Name": "test-bucket",
"Prefix": ""
}
(8) 오브젝트를 다른 버킷으로 복사
import {CopyObjectCommand, S3Client} from "@aws-sdk/client-s3";
const s3Client = new S3Client({endpoint: "https://kr.cafe24obs.com", forcePathStyle: true, region: "zone-group-cafe24cloud"});
# Bucket : 복사한 파일을 붙여넣기 할 버킷
# Key : 붙여넣기 할 파일의 이름
# CopySource : 복사할 파일을 지정. "버킷명/파일경로"
export const bucketParams = {
Bucket: "test-bucket",
CopySource: "test-bucket1/bucket-1-file.txt",
Key: "copied-file.txt"
};
export const run = async () => {
try {
const data = await s3Client.send(new CopyObjectCommand(bucketParams));
console.log("Success : \n", JSON.stringify(data, null, 4));
} catch (err) {
console.log("Error", err);
}
};
run();
output 예시
Success :
{
"$metadata": {
"httpStatusCode": 200,
"requestId": "tx000007c0798553d2790ae-0063b45773-1682e4f-zone-cafe24cloud-prd-obs",
"attempts": 1,
"totalRetryDelay": 0
},
"CopyObjectResult": {
"ETag": "d9ebe4d6aeb33dea41ddb2b57e7b6d80",
"LastModified": "2023-01-03T16:27:31.755Z"
}
}