Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

将 Amazon Lambda 与 Amazon DocumentDB 结合使用

您可以通过将 Amazon DocumentDB 集群配置为事件源，从而使用 Amazon Lambda 函数来处理 Amazon DocumentDB（与 MongoDB 兼容）更改流 中的事件。然后，您可以在 Amazon DocumentDB 集群每次发生数据更改时调用 Lambda 函数，从而实现事件驱动型工作负载的自动化。

Amazon DocumentDB 事件示例

{
    "eventSourceArn": "arn:aws:rds:us-east-1:123456789012:cluster:canaryclusterb2a659a2-qo5tcmqkcl03",
    "events": [
        {
            "event": {
                "_id": {
                    "_data": "0163eeb6e7000000090100000009000041e1"
                },
                "clusterTime": {
                    "$timestamp": {
                        "t": 1676588775,
                        "i": 9
                    }
                },
                "documentKey": {
                    "_id": {
                        "$oid": "63eeb6e7d418cd98afb1c1d7"
                    }
                },
                "fullDocument": {
                    "_id": {
                        "$oid": "63eeb6e7d418cd98afb1c1d7"
                    },
                    "anyField": "sampleValue"
                },
                "ns": {
                    "db": "test_database",
                    "coll": "test_collection"
                },
                "operationType": "insert"
            }
        }
    ],
    "eventSource": "aws:docdb"
}

有关事件类型及其形状的更多信息，请参阅 MongoDB 文档。

先决条件和权限

将 Amazon DocumentDB 用作 Lambda 函数的事件源之前，请注意以下先决条件：

网络配置

Lambda 必须具有访问与您的 DocumentDB 集群关联的 Amazon VPC 资源的权限。如果您在 Secrets Manager 中配置了密钥，以便 Lambda 进行集群身份验证，则还应部署一个 用于 Secrets Manager 的 VPC 端点。

或者，请确保与您的 DocumentDB 集群关联的 VPC 在每个公有子网中都包含一个 NAT 网关。有关更多信息，请参阅VPC 连接函数的 Internet 和服务访问。

使用以下规则配置您的 Amazon VPC 安全组（至少）：

将 DocumentDB 更改流配置为事件源

要配置函数以从 DocumentDB 集群更改流中读取数据，请创建一个 DocumentDB 事件源映射。这一部分介绍了如何从控制台执行此操作。有关使用 Amazon CLI 配置 DocumentDB 更改流的信息，请参阅事件源映射 API。

Lambda 支持 DocumentDB 事件源的以下选项：

事件源映射 API

要使用 Amazon CLI 或 Amazon SDK 来管理 DocumentDB 事件源，您可以使用以下 API 操作：

要使用 Amazon CLI 创建事件源映射，请使用 create-event-source-mapping 命令。以下示例使用 Amazon CLI 将名为 my-function 的函数映射到一个 DocumentDB 更改流。事件源由 Amazon 资源名称（ARN）指定，批处理大小为 500，从以 Unix 时间表示的时间戳开始。该命令还指定了 Lambda 用于连接到 DocumentDB 的 Secrets Manager 密钥，以及用于指定要从中读取的数据库和集合的 document-db-event-source-config 参数：

aws lambda create-event-source-mapping --function-name my-function \
    --event-source-arn arn:aws:rds:us-west-2:123456789012:cluster:privatecluster7de2-epzcyvu4pjoy
    --batch-size 500 \
    --starting-position AT_TIMESTAMP \
    --starting-position-timestamp 1541139109 \
    --source-access-configurations '[{"Type":"BASIC_AUTH","URI":"arn:aws:secretsmanager:us-east-1:123456789012:secret:DocDBSecret-BAtjxi"}]' \
    --document-db-event-source-config '{"DatabaseName":"test_database", "CollectionName": "test_collection"}' \

应看到类似如下内容的输出：

{
    "UUID": "2b733gdc-8ac3-cdf5-af3a-1827b3b11284",
    "BatchSize": 500,
    "DocumentDBEventSourceConfig": {
        "CollectionName": "test_collection",
        "DatabaseName": "test_database",
        "FullDocument": "Default"
    },
    "MaximumBatchingWindowInSeconds": 0,
    "EventSourceArn": "arn:aws:rds:us-west-2:123456789012:cluster:privatecluster7de2-epzcyvu4pjoy",
    "FunctionArn": "arn:aws:lambda:us-west-2:123456789012:function:my-function",
    "LastModified": 1541348195.412,
    "LastProcessingResult": "No records processed",
    "State": "Creating",
    "StateTransitionReason": "User action"
}

创建后，您可以使用 update-event-source-mapping 命令更改与您的 DocumentDB 事件源相关的更新设置。例如，以下命令会将批处理大小更新为 1000，并将批处理时间窗口更新为 10 秒。对于此命令，您需要有事件源映射的 UUID，并且您可以通过 list-event-source-mapping 调用或控制台检索该值：

aws lambda update-event-source-mapping --function-name my-function \
    --uuid f89f8514-cdd9-4602-9e1f-01a5b77d449b \
    --batch-size 1000 \
    --batch-window 10

您应该看到此输出内容：

{
    "UUID": "2b733gdc-8ac3-cdf5-af3a-1827b3b11284",
    "BatchSize": 500,
    "DocumentDBEventSourceConfig": {
        "CollectionName": "test_collection",
        "DatabaseName": "test_database",
        "FullDocument": "Default"
    },
    "MaximumBatchingWindowInSeconds": 0,
    "EventSourceArn": "arn:aws:rds:us-west-2:123456789012:cluster:privatecluster7de2-epzcyvu4pjoy",
    "FunctionArn": "arn:aws:lambda:us-west-2:123456789012:function:my-function",
    "LastModified": 1541359182.919,
    "LastProcessingResult": "OK",
    "State": "Updating",
    "StateTransitionReason": "User action"
}

Lambda 会异步更新设置，并且在更新完成之前，您可能无法在输出中看到这些更改。使用 get-event-source-mapping 命令查看当前状态。

aws lambda get-event-source-mapping --uuid f89f8514-cdd9-4602-9e1f-01a5b77d449b

您应该看到此输出内容：

{
    "UUID": "2b733gdc-8ac3-cdf5-af3a-1827b3b11284",
    "DocumentDBEventSourceConfig": {
        "CollectionName": "test_collection",
        "DatabaseName": "test_database",
        "FullDocument": "Default"
    },
    "BatchSize": 1000,
    "MaximumBatchingWindowInSeconds": 10,
    "EventSourceArn": "arn:aws:rds:us-west-2:123456789012:cluster:privatecluster7de2-epzcyvu4pjoy",
    "FunctionArn": "arn:aws:lambda:us-west-2:123456789012:function:my-function",
    "LastModified": 1541359182.919,
    "LastProcessingResult": "OK",
    "State": "Enabled",
    "StateTransitionReason": "User action"
}

要删除 DocumentDB 事件源映射，请使用 delete-event-source-mapping 命令：

aws lambda delete-event-source-mapping \
    --uuid 2b733gdc-8ac3-cdf5-af3a-1827b3b11284

监控 DocumentDB 事件源

为便于您监控 DocumentDB 事件源，在您的函数处理完一批记录后，Lambda 将发出 IteratorAge 指标。IteratorAge 是最近一个事件的时间戳和当前时间戳之间的差。基本上，该指标会说明处理该批处理中最后一条记录后经过的时间。如果您的函数当前正在处理新事件，则可使用迭代器龄期来估算新记录的添加时间与函数处理新记录的时间之间的延迟。

如果 IteratorAge 呈上升趋势，则可能说明您的函数存在问题。有关更多信息，请参阅使用 Lambda 函数指标。

Lambda 仅支持最大 6MB 的负载。但是，DocumentDB 更改流事件的大小可达 16MB。如果您的更改流尝试向 Lambda 发送大于 6MB 的更改流事件，Lambda 会丢弃该消息并发送 OversizedRecordCount 指标。Lambda 将尽力发送所有指标。