使用 Kinesis Data Streams 写入 Kinesis Data Firehose - Amazon Kinesis Data Firehose
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 Amazon Web Services 服务入门

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

使用 Kinesis Data Streams 写入 Kinesis Data Firehose

您可以配置 Amazon Kinesis Data Streams 将信息发送到 Kinesis Data Firehose 传输流。

重要

如果使用 Kinesis 创建器库 (KPL) 将数据写入到 Kinesis 数据流,您可以使用聚合整合您写入 Kinesis 数据流的记录。如果随后将该数据流用作 Kinesis Data Firehose 传输流的来源,Kinesis Data Firehose 将在记录传送到目标之前取消聚合。如果配置传输流来转换数据,Kinesis Data Firehose 将在记录传送到之前取消聚合。Amazon Lambda. 有关更多信息,请参阅使用 Kinesis 创建者库开发 Amazon Kinesis Data Streams 创建者聚合

  1. 登录Amazon Web Services Management Console并打开 Kinesis Data Firehose 控制台,网址为 https://console.aws.amazon.com/firehose/

  2. 选择 Create Delivery Stream (创建传输流)。在 Name and source (名称和来源) 页面上,为以下字段提供值:

    传输流名称

    您的 Kinesis Data Firehose 传输流的名称。

    Source (源)

    选择Kinesis 流配置使用 Kinesis Data Firehose 传输流,该流使用 Kinesis 数据流作为数据源。这样,您可以使用 Kinesis Data Firehose 从现有数据流轻松读取数据并将数据加载到目标。

    要使用 Kinesis 数据流作为数据源,请从Kinesis 流列出,或者选择创建新的创建一个新的 Kinesis 数据流。创建新流之后,请选择Refresh(刷新)要更新Kinesis 流列表。如果您有大量的流,可使用 Filter by name 筛选列表。

    注意

    如果将 Kinesis 数据流配置为 Kinesis Data Firehose 传输流的来源,Kinesis Data FirehosePutRecordPutRecordBatch操作已禁用。在这种情况下,要将数据添加到 Kinesis Data Firehose 传输流中,请使用 Kinesis Data StreamsPutRecordPutRecords操作。

    Kinesis Data Firehose 开始从LATEST你的 Kinesis 流的位置。有关 Kinesis Data Streams 位置的更多信息,请参阅GetShardIterator. Kinesis Data Firehose 称之为 Kinesis Data StreamsGetRecords每秒为每个分区运算一次。

    多个 Kinesis Data Firehose 传输流可从同一 Kinesis 流读取数据。其他 Kinesis 应用程序(使用器)也可以从同一流读取数据。来自任何 Kinesis Data Firehose 传输流或其他使用器应用程序的每个调用都会计入该分区的总体限制。为了避免受限,请小心计划您的应用程序。有关 Kinesis Data Streams 限制的更多信息,请参阅Amazon Kinesis Streams 限制.

  3. 选择 Next 前进至记录转换和记录格式转换页面。