튜토리얼: 트리거에서 타사 API 호출

값 페이지로 이동합니다.

Atlas에서 Triggers 페이지로 이동합니다.

1. 아직 표시되지 않은 경우 탐색 표시줄의 Organizations 메뉴에서 프로젝트가 포함된 조직을 선택합니다.

2. 아직 표시되지 않은 경우 내비게이션 바의 Projects 메뉴에서 프로젝트를 선택합니다.

3. 사이드바에서 Streaming Data 제목 아래의 Triggers를 클릭합니다.

트리거 페이지가 표시됩니다.

1. View All Apps 버튼을 클릭합니다.

2. 트리거를 생성하려는 앱 클릭합니다.

3. 사이드바에서 Build 제목 아래의 Values를 클릭합니다.

액세스 키 ID 저장합니다.

1. Create a Value를 클릭합니다.

2. Value Name(으)로 AwsAccessKeyId 을(를) 입력합니다.

3. Value 유형을 선택합니다.

4. Custom Content 옵션을 선택하고 AWS 액세스 키 ID 입력합니다.

   참고

   액세스 키 ID 따옴표("<accessKeyId>")가 포함된 문자열 값으로 입력해야 합니다.

5. Save Draft를 클릭합니다.

시크릿 액세스 키를 저장합니다.

1. Create a Value를 클릭합니다.

2. Value Name(으)로 AwsSecretAccessKey 을(를) 입력합니다.

3. Value 유형을 선택합니다.

4. Link to Secret 옵션을 선택합니다.

5. AwsSecretAccessKeySecret을 입력하고 Create "AwsSecretAccessKeySecret"을 클릭하여 시크릿의 이름을 지정합니다.

   AWS 시크릿 액세스 키를 시크릿 이름 아래에 표시되는 필드 에 붙여넣습니다.

6. Save Draft 를 클릭하여 Secret과 Value를 모두 생성합니다.

트리거 페이지로 이동합니다.

Atlas에서 Triggers 페이지로 이동합니다.

1. 아직 표시되지 않은 경우 탐색 표시줄의 Organizations 메뉴에서 프로젝트가 포함된 조직을 선택합니다.

2. 아직 표시되지 않은 경우 내비게이션 바의 Projects 메뉴에서 프로젝트를 선택합니다.

3. 사이드바에서 Streaming Data 제목 아래의 Triggers를 클릭합니다.

트리거 페이지가 표시됩니다.

트리거를 생성합니다.

1. Add Trigger을 클릭하여 트리거 구성 페이지를 엽니다.

2. Database 트리거 유형을 선택한 후 다음 값을 사용하여 트리거를 구성합니다:

   설정	값
   Trigger Name	WriteDocumentToS3Trigger
   Watch Against	Collection
   Cluster Name	테스트 클러스터 의 이름
   Database Name	테스트 데이터베이스 의 이름
   Collection Name	테스트 컬렉션 의 이름
   Operation Type	Insert만 선택합니다.
   Event Type	Function

3. Function 섹션에서 + New Function를 선택합니다.

aws-sdk 종속성을 추가합니다.

1. Function 섹션에서 Add Dependency을 클릭합니다.

2. Add Dependency 창 에서 Define a Package Name로 aws-sdk을 입력하고 Package Version을 비워 두어 최신 버전을 사용합니다.

3. 패키지 를 추가하려면 Add 를 클릭합니다.

다음 코드를 입력하여 함수를 정의합니다.

YOUR_AWS_REGION 및 YOUR_S3_BUCKET_NAME를 AWS Management Console의 자체 AWS 리전과 전체 버킷 이름으로 바꿉니다.

1
/*
2
 * Write a newly-inserted document to an S3 bucket as an Extended JSON object.
3
 */
4
exports = async function writeDocumentToS3(changeEvent) {
5
  const { fullDocument } = changeEvent;
6
7
  // require calls must be in the exports function
8
  const S3 = require("aws-sdk/clients/s3");
9
  const s3 = new S3({
10
    accessKeyId: context.values.get("AwsAccessKeyId"),
11
    secretAccessKey: context.values.get("AwsSecretAccessKey"),
12
    region: "YOUR_AWS_REGION",
13
  });
14
15
  const key = `inserted-documents/${fullDocument._id.toString()}.json`;
16
17
  // https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/S3.html#putObject-property
18
  await s3.putObject({
19
    Bucket: "YOUR_S3_BUCKET_NAME",
20
    Key: key,
21
    Body: EJSON.stringify(fullDocument),
22
    ContentType: "application/json",
23
  }).promise();
24
25
  return `Wrote document ${fullDocument._id} to ${key}`;
26
};

문서 삽입될 때마다 함수는 다음을 수행합니다.

• 변경 이벤트의 fullDocument 필드 에서 삽입된 문서 읽습니다.

• 값에 저장된 AWS 자격 증명 으로 인증하는 S3 클라이언트 생성합니다.

• 버킷의 inserted-documents/ 접두사에 문서 <_id>.json(으)로 씁니다.

Save를 클릭하여 트리거를 생성합니다.

mongosh을(를) 사용하여 클러스터 에 연결합니다.

방법을 학습 mongosh 통해 클러스터에 연결하기를 참조하세요.

트리거가 감시하는 컬렉션 에 문서 삽입합니다.

다음 예시 에서는 테스트 컬렉션 에 문서 하나를 삽입합니다. YOUR_DATABASE_NAME 및 YOUR_COLLECTION_NAME을 트리거를 생성할 때 입력한 데이터베이스 및 컬렉션 으로 바꿉니다.

// Replace YOUR_DATABASE_NAME and YOUR_COLLECTION_NAME with the
// database and collection that the Trigger watches.
use YOUR_DATABASE_NAME
db.YOUR_COLLECTION_NAME.insertOne({
  tutorialTest: "atlas-trigger-s3",
  createdAt: new Date()
})

{
  acknowledged: true,
  insertedId: ObjectId('6accda8d1bed071fd18dc505')
}

출력에서 insertedId 값을 확인합니다. 함수는 이 값을 S3 객체 의 이름으로 사용합니다.

Confirm that the object exists in your S3 bucket.

AWS Management Console에서 S3 버킷을 열고 inserted-documents/ 접두사로 이동합니다. <insertedId>.json라는 객체 표시되며, 여기서 <insertedId>는 이전 단계의 insertedId 값입니다.