Amazon Kinesis Data Streams 功能

分片是 Kinesis 流的基本吞吐量单位。一个分片的吞吐量为每秒输入 1MB 数据和每秒输出 2MB 数据，并且每秒最多可支持 1000 个 PUT 记录。您需要在创建流时指定所需的分片数量。例如，您可以创建具有两个分片的流。此流的吞吐量为每秒输入 2MB 数据和每秒输出 4MB 数据，并且每秒最多支持 2000 个 PUT 记录。通过重新分片，您可以根据数据吞吐量的变化，在流中动态添加分片或从中移除分片。

记录是存储在 Kinesis 流中的数据单元。记录由序列号、分区键和数据 Blob 组成。数据 Blob 是数据创建器向流中添加的相关数据。数据 Blob 的最大大小（Base64 编码后的数据负载）为 1MB。

分区键用于分离出数据记录，并将其路由到流的不同分片。分区键由您的数据创建器在将数据添加到 Kinesis 流时指定。例如，假定您的 Kinesis 流具有两个分片（分片 1 和分片 2）。您可以将数据创建器配置为使用两个分区键（键 A 和键 B），以便将所有带键 A 的数据记录添加到分片 1 中，并将所有带键 B 的数据记录添加到分片 2 中。

序列号是各个数据记录的唯一标识符。当数据生成器调用 PutRecord 或 PutRecords API 向 Kinesis 流添加数据时，Amazon Kinesis Data Streams 会分配序列号。同一分区键对应的序列号通常会随着时间的推移而逐渐增加；PutRecord 或 PutRecords 请求之间的间隔时间越长，序列号就会越大。

注册 Amazon Web Services 后，您便可通过以下方式开始使用 Amazon Kinesis Data Streams：

• 通过 Kinesis Data Streams 管理控制台或 Kinesis Data Streams CreateStream API 创建 Kinesis 流。
• 将数据生成器配置为持续向 Kinesis 流添加数据。
• 生成 Kinesis 应用程序，用于读取和处理 Kinesis 流中的数据。
  

数据生成器可以通过 PutRecord 和 PutRecords API 或 Kinesis Producer Library (KPL) 向 Kinesis 流添加数据。PutRecord API 可便于在一次 API 调用中添加一个数据记录，而 PutRecords API 则可便于在一次 API 调用中添加多个数据记录。

Kinesis Producer Library (KPL) 是一种易于使用且高度可配置的库，可以帮助您向 Kinesis 流中添加数据。Kinesis Producer Library (KPL) 具有简单可靠的异步接口，这样您就可以快速实现非常高的创建器吞吐量，同时最大限度地减少的客户端资源使用。

Kinesis 应用程序是一种能读取和处理 Kinesis 流中数据的数据使用者。您可以使用 Kinesis Data Streams API 或 Kinesis Client Library (KCL) 生成 Kinesis 应用程序。

Kinesis Client Library (KCL) 是一个预建库，可帮助您轻松生成 Kinesis 应用程序，用于读取和处理 Kinesis 流中的数据。Kinesis Client Library (KCL) 可以处理各种复杂问题，如适应流量变化、均衡流数据负载、协调分布式服务和以容错方式处理数据。从而使您能够在专注业务逻辑的同时构建 Kinesis 应用程序。

Kinesis Connector Library 是一种预建库，可帮助您轻松地将 Amazon Kinesis Data Streams 与其他 亚马逊云科技 服务和第三方工具集成。使用 Kinesis Connector Library 时，也需要使用 Kinesis Client Library (KCL)。此库最新版本中的连接器可方便您与 Amazon DynamoDB、Amazon S3 和 Elasticsearch 集成。此库还包括各种类型的示例连接器，外加可运行示例的 Apache Ant 生成文件。

Kinesis Storm Spout 是一种预建库，可帮助您轻松地将 Amazon Kinesis Data Streams 与 Apache Storm 集成。当前版本的 Kinesis Storm Spout 可从 Kinesis 流中提取数据，然后将它作为元组发送出去。您需要将此 Spout 添加到 Storm 拓扑中，以便将 Amazon Kinesis Data Streams 用作可靠且可缩放的流捕获、存储和重放服务。

Amazon Kinesis Data Streams 与 Amazon CloudWatch 集成，以便您可以针对 Kinesis 流收集、查看和分析 CloudWatch 指标。有关 Amazon Kinesis Data Streams 指标的更多信息，请参阅使用 Amazon CloudWatch 监控 Amazon Kinesis。

Amazon Kinesis Data Streams 与 Amazon Identity and Access Management (IAM) 集成，后者是让您能够安全地控制用户对 亚马逊云科技 服务和资源的访问权限的服务。例如，您可以创建一个策略，只允许特定用户或组向 Kinesis 流添加数据。有关 Kinesis 流的访问权限管理和控制的更多信息，请参阅使用 IAM 控制对 Amazon Kinesis 资源的访问权限。

Amazon Kinesis Data Streams 与 Amazon CloudTrail 集成，后者是记录您账户的 Amazon API 调用并向您提供日志文件的服务。有关 API 调用日志记录和支持的 Amazon Kinesis Data Streams API 列表的更多信息，请参阅使用 Amazon CloudTrail 记录 Kinesis Streams API 调用。

借助 Amazon Kinesis Data Streams，您可以标记 Kinesis 流，从而简化资源和成本的管理。标记是用户定义的标签，以键值对的形式表示，有助于整理 亚马逊云科技 资源。例如，您可以按成本中心标记 Kinesis 流，这样就能根据成本中心对 Amazon Kinesis Data Streams 成本进行分类和跟踪。有关 Kinesis Data Streams 标记的更多信息，请参阅标记您的 Kinesis Streams。

使用本服务需遵守 亚马逊云科技 客户协议。