チュートリアル: trigger からサードパーティAPIを呼び出す

[ Values（値） ] ページに移動します。

Atlas で、 Triggers ページに移動します。

1. まだ表示されていない場合は、プロジェクトを含む組織をナビゲーション バーの Organizations メニューで選択します。

2. まだ表示されていない場合は、ナビゲーション バーの Projects メニューからプロジェクトを選択します。

3. サイドバーで、 Streaming Data見出しの下のTriggersをクリックします。

Triggersページが表示されます。

1. View All Appsボタンをクリックします。

2. trigger を作成するアプリをクリックします。

3. サイドバーで、 Build見出しの下のValuesをクリックします。

アクセスキーIDを保存します。

1. [Create a Value] をクリックします。

2. Value Name として AwsAccessKeyId を入力します。

3. Valueタイプを選択します。

4. Custom Contentオプションを選択し、 AWSアクセスキーIDを入力します。

   注意

   アクセス キーID は、引用符（"<accessKeyId>"）を含む string 値として入力する必要があります。

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 をクリックします。

[ trigger ] ページに移動します。

Atlas で、 Triggers ページに移動します。

1. まだ表示されていない場合は、プロジェクトを含む組織をナビゲーション バーの Organizations メニューで選択します。

2. まだ表示されていない場合は、ナビゲーション バーの Projects メニューからプロジェクトを選択します。

3. サイドバーで、 Streaming Data見出しの下のTriggersをクリックします。

Triggersページが表示されます。

trigger を作成します。

1. Add Triggerをクリックしてトリガー設定ページを開きます。

2. Databasetrigger タイプを選択し、次の値を使用して trigger を構成します。

   設定	値
   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_REGIONYOUR_S3_BUCKET_NAMEと を独自のAWSリージョンと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 クライアントを作成します。

• ドキュメントを <_id>.json としてバケットの inserted-documents/ プレフィックスに書込みます。

Savetrigger を作成するには、 をクリックします。

mongoshを使用してクラスターに接続します。

方法については、 「 mongosh経由でクラスターに接続する 」を参照してください。

trigger が監視するドキュメントをコレクションに挿入します。

次の例では、テストコレクションに 1 つのドキュメントを挿入します。 YOUR_DATABASE_NAME と YOUR_COLLECTION_NAME を、trigger の作成時に入力したデータベースとコレクションに置き換えます。

// 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 オブジェクトの名前としてこの値を使用します。

オブジェクトが S3 バケットに存在することを確認します。

AWSマネジメント コンソールで、S3 バケットを開き、inserted-documents/ プレフィックスに移動します。 という名前のオブジェクトが表示されます。<insertedId>.json <insertedId>insertedIdは前の手順の 値です。