评估 DynamoDB 流使用情况

本节概述如何评估您的 DynamoDB Streams 使用情况。有些使用模式对于 DynamoDB 来说不是最佳的，在性能和成本方面还有优化的空间。

对于流式传输和事件驱动的使用场景，您有两个原生流式传输集成：

本页仅侧重介绍这些选项的成本优化策略。如果您只是想知道如何在这两个选项之间作出选择，请参阅 更改数据捕获的流式传输选项。

优化 DynamoDB Streams 的成本

正如 DynamoDB Streams 的定价页面所述，无论表的吞吐能力模式，DynamoDB 都基于对表的 DynamoDB Stream 的读取请求量来收费。对 DynamoDB Stream 的读取请求与对 DynamoDB 表的读取请求不同。

对 Stream 的每个读取请求采用的是 GetRecords API 调用形式，响应中可以返回最多 1000 条记录或 1MB 的记录，以先到达者为准。其他 DynamoDB Stream API 均不收费，也不对闲置的 DynamoDB Streams 收费。换言之，如果不对 DynamoDB Stream 发出读取请求，则表上启用了 DynamoDB Stream 并不会产生任何费用。

以下是 DynamoDB Streams 的一些使用器应用程序：

由 DynamoDB Streams 的基于 AWS Lambda 的使用器发出的读取请求是免费的，而由任何其他类型的使用器发出的调用都是收费的。每个月，由非 Lambda 使用器发出的前 250 万次读取请求也是免费的。这适用于每个 AWS 区域的一个 AWS 账户中对于任何 DynamoDB Streams 发出的所有读取请求。

监控您的 DynamoDB Streams 使用情况

在账单控制台上，AWS 区域内一个 AWS 账户中的所有 DynamoDB Streams 费用集中组成一组。目前，暂不支持标记 DynamoDB Streams，因此不能使用成本分配标签来进一步细分 DynamoDB Streams 的成本。可以获得 DynamoDB Stream 级别的 GetRecords 调用量来计算每个流的费用。该调用量用 DynamoDB Stream 的 CloudWatch 指标 SuccessfulRequestLatency 及其 SampleCount 统计数据来表示。该指标还将包括全局表为执行持续复制而进行的 GetRecords 调用，以及 AWS Lambda 使用器进行的调用，两者均不收费。有关 DynamoDB Streams 发布的其他 CloudWatch 指标的信息，请参阅 DynamoDB 指标与维度。

使用 AWS Lambda 作为使用器

评估使用 AWS Lambda 函数作为 DynamoDB Streams 的使用器是否可行，因为这可以消除与读取 DynamoDB Stream 相关的成本。另一方面，对于基于 DynamoDB Streams Kinesis Adapter 或 SDK 的使用器应用程序，将根据它们对 DynamoDB Stream 的 GetRecords 调用次数来收费。

将根据标准 Lambda 定价对 Lambda 函数调用收费，但是 DynamoDB Streams 不会产生任何费用。Lambda 将以每秒 4 次的基本频率轮询 DynamoDB Stream 中的分片来获取记录。如果记录可用，Lambda 会调用函数并等待结果。如果处理成功，Lambda 会恢复轮询，直到其收到更多记录。

调整基于 DynamoDB Streams Kinesis Adapter 的使用器应用程序

因为对基于非 Lambda 的使用器发出的读取请求要收取 DynamoDB Streams 费用，所以，如何在近实时要求和使用者应用程序必须轮询 DynamoDB Stream 的次数之间找到一个平衡点非常重要。

使用基于 DynamoDB Streams Kinesis Adapter 的应用程序轮询 DynamoDB Streams 的频率由配置的 idleTimeBetweenReadsInMillis 值决定。该参数决定了使用器在对某个分片的 GetRecords 调用未返回任何记录时，需等待多久（以毫秒为单位）才能再次处理该分片。该参数的默认值为 1000ms。如果不需要近实时处理，则可以提高该参数值，以减少使用器应用程序的 GetRecords 调用次数，并对 DynamoDB Streams 调用进行优化。

优化 Kinesis Data Streams 的成本

将一个 Kinesis Data Stream 设置为目的地来传送 DynamoDB 表的变化数据捕获事件时，该 Kinesis Data Stream 可能需要单独的规模调整管理，而这将影响总体成本。DynamoDB 费用按变化数据捕获单位 (CDU) 来收取，每个单位由 DynamoDB 服务向目的地 Kinesis Data Stream 尝试传送的一个 DynamoDB 项目（大小最多 1KB）构成。

除了 DynamoDB 服务费用，还将产生标准 Kinesis Data Stream 费用。如定价页面所述，服务定价因容量模式（预置和按需模式）而异，这种容量模式与 DynamoDB 表容量模式不同，它们是由用户定义的。概言之，Kinesis Data Streams 费用是一种小时费率，基于容量模式以及 DynamoDB 服务摄取到流中的数据量。根据用户对 Kinesis Data Stream 的配置，可能会存在其他费用，例如数据检索（对于按需模式）、数据留存时间延长（超过默认的 24 小时）和增强的扇出式使用器检索等。

监控 Kinesis Data Streams 使用情况

除了标准的 Kinesis Data Stream CloudWatch 指标外，Kinesis Data Streams for DynamoDB 还发布了来自 DynamoDB 的指标。DynamoDB 服务的 Put 尝试受到 Kinesis 服务节流（因 Kinesis Data Streams 容量不足），或者受到依赖组件（例如可能配置为加密静态 Kinesis Data Stream 数据的 AWS KMS 服务）节流是有可能的。

要了解 DynamoDB 服务针对 Kinesis Data Stream 发布的 CloudWatch 指标的更多信息，请参阅 使用 Kinesis Data Streams 监控更改数据捕获。为避免因节流而导致额外的服务重试费用，在预置模式下适当调整 Kinesis Data Stream 的大小非常重要。

为 Kinesis Data Streams 选择适当的容量模式

Kinesis Data Streams 有两种受支持的容量模式 - 预置模式和按需模式。

优化成本的一种最佳实践是，评估与 Kinesis Data Stream 关联的 DynamoDB 表是否具有可预测的流量模式，且该模式可以利用 Kinesis Data Streams 的预置模式。如果工作负载是新的，则您可以在最初的几周使用 Kinesis Data Streams 的按需模式，查看 CloudWatch 指标以了解流量模式，然后根据工作负载的性质将相同的 Stream 切换到预置模式。在预置模式下，遵循 Kinesis Data Streams 的分片管理注意事项来估算分片数量。

使用 Kinesis Data Streams for DynamoDB 评估使用器应用程序

由于 Kinesis Data Streams 不对像 DynamoDB Streams 这样的 GetRecords 调用收费，所以使用器应用程序可以进行任意次调用，但前提是频率低于 GetRecords 的节流限制。在 Kinesis Data Streams 的按需模式下，按 GB 量收取数据读取费。对于 Kinesis Data Streams 的预置模式，如果数据存储时间少于 7 天，则不收取读取费用。当 Lambda 函数作为 Kinesis Data Streams 使用器时，Lambda 按每秒一次的基本频率轮询 Kinesis Stream 中的每个分片以获取记录。

两种 Streams 使用模式的成本优化策略

用于 AWS Lambda 使用器的事件筛选

Lambda 事件筛选允许您基于筛选条件丢弃 Lambda 函数调用批处理中的事件。这将优化在使用者函数逻辑中处理或丢弃不需要的流记录的 Lambda 成本。要了解有关配置事件筛选和编写筛选条件的更多信息，请参阅 Lambda 事件筛选。

调整 AWS Lambda 使用器

可以通过调整 Lambda 配置参数来进一步优化成本，例如提高 BatchSize 来增加每次调用的处理量，启用 BisectBatchOnFunctionError 来防止处理重复项（这会产生额外成本），以及设置 MaximumRetryAttempts 以免过多重试。默认情况下，失败的使用器 Lambda 调用会重试无限次，直到记录在流中过期，对于 DynamoDB Streams，记录的过期时间大约为 24 小时，对于 Kinesis Data Streams，过期时间可以配置为从 24 小时到最长 1 年。有关其他可用的 Lambda 配置选项，包括上面提到的 DynamoDB Stream 使用器的配置选项，请参阅 AWS Lambda 开发人员指南。