Amazon Kinesis Data Streams のソース設定を構成する

Amazon Kinesis Data Streams のソース設定を次のように設定して、Firehose ストリームに情報を送信します。

重要

Kinesis Producer Library (KPL) を使用して Kinesis データストリームにデータを書き込む場合は、集約を使用して、その Kinesis データストリームに書き込むレコードを結合できます。次に、そのデータストリームを Firehose ストリームのソースとして使用すると、Amazon Data Firehose はレコードを宛先に配信する前にレコードの集約を解除します。データを変換するように Firehose ストリームを設定すると、Amazon Data Firehose はレコードを に配信する前にレコードの集約を解除します。 AWS Lambda。 詳細については、「Kinesis プロデューサーライブラリを使用した Amazon Kinesis Data Streams プロデューサーの開発」および「集約」を参照してください。

ソース設定 で、Kinesis データストリームリストで既存のストリームを選択するか、 ARN形式でデータストリームを入力しますarn:aws:kinesis:[Region]:[AccountId]:stream/[StreamName]。

既存のデータストリームがない場合は、作成 を選択して Amazon Kinesis コンソールから新しいデータストリームを作成します。 Amazon Kinesis Kinesis ストリームに必要なアクセス許可を持つ IAMロールが必要になる場合があります。詳細については、「Firehose に Amazon S3 送信先へのアクセスを許可する」を参照してください。新しいストリームを作成したら、更新アイコンを選択して Kinesis ストリームリストを更新します。多数のストリームがある場合は、[Filter by name] を使用してリストをフィルタリングします。

注記

Firehose ストリームのソースとして Kinesis データストリームを設定すると、Amazon Data Firehose PutRecordおよび PutRecordBatchオペレーションは無効になります。この場合に Firehose ストリームにデータを追加するには、Kinesis Data Streams PutRecordおよび PutRecordsオペレーションを使用します。

Amazon Data Firehose は、Kinesis ストリームLATESTの位置からデータの読み取りを開始します。Kinesis Data Streams の位置の詳細については、「」を参照してくださいGetShardIterator。

Amazon Data Firehose は、シャードごとに Kinesis Data Streams GetRecordsオペレーションを 1 秒に 1 回呼び出します。ただし、フルバックアップが有効になっている場合、Firehose はシャードごとに 1 秒に 2 回 Kinesis Data Streams GetRecordsオペレーションを呼び出します。1 つはプライマリ配信先、もう 1 つはフルバックアップ用です。

複数の Firehose ストリームが同じ Kinesis ストリームから読み取ることができます。他の Kinesis アプリケーション (コンシューマー) も同じストリームから読み取ることができます。Firehose ストリームまたは他のコンシューマーアプリケーションからの各呼び出しは、シャードの全体的なスロットリング制限にカウントされます。スロットリングを回避するため、アプリケーションを注意深く計画してください。Kinesis Data Streams の制限事項の詳細については、「Amazon Kinesis Streams の制限」を参照してください。

次のステップに進み、レコード変換と形式変換を設定します。