教程：从触发器调用第三方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. 输入 AwsAccessKeyId 作为 Value Name。

3. 选择 Value 类型。

4. 选择 Custom Content 选项并输入您的 AWS访问权限密钥ID。

   注意

   您必须以带引号的字符串值形式输入访问权限密钥ID ("<accessKeyId>")。

5. 单击 Save Draft（连接）。

存储秘密访问权限密钥。

1. 单击 Create a Value（连接）。

2. 输入 AwsSecretAccessKey 作为 Value Name。

3. 选择 Value 类型。

4. 选择 Link to Secret 选项。

5. 输入 AwsSecretAccessKeySecret 并单击 Create "AwsSecretAccessKeySecret" 以命名密钥。

   将您的 AWS 秘密访问权限密钥粘贴到密钥名称下方显示的字段中。

6. 单击 Save Draft 以创建密钥和值。

导航到“触发器”页面。

在 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窗口中，输入 aws-sdk 作为 Define a Package Name 并将 Package Version 留空以使用最新版本。

3. 单击Add添加包。

输入以下代码以定义函数。

将 YOUR_AWS_REGION 和 YOUR_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字段读取插入的文档。

• 创建一个 S3客户端，使用存储在值中的 AWS凭证进行身份验证。

• 将文档作为 <_id>.json 写入存储桶的 inserted-documents/ 前缀。

单击 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对象的名称。

确认该对象存在于您的 S3 存储桶中。

在 AWS 管理控制台中，打开 S3 存储桶并导航到 inserted-documents/ 前缀。此时会出现一个名为 <insertedId>.json 的对象，其中 <insertedId> 是上一步中的 insertedId 值。