Amazon Kinesis Data Streams にデータを書き込む

プロデューサーは、Amazon Kinesis Data Streams にデータを書き込むアプリケーションです。 AWS SDK for Java と Kinesis Producer Library (KPL) を使用して、Kinesis Data Streams のプロデューサーを構築できます。

Kinesis Data Streams を初めて利用する場合は、Amazon Kinesis Data Streams とはおよびAWS CLI を使用して Amazon Kinesis Data Streams オペレーションを実行するで説明されている概念と用語について理解することから始めてください。

ストリームにデータを送信するには、ストリームの名前、パーティションキー、ストリームに追加するデータ BLOB を指定する必要があります。パーティションキーは、データレコードが追加されるストリーム内のシャードを決定するために使用されます。

シャード内のすべてのデータは、そのシャードを処理する同じワーカーに送信されます。使用するパーティションキーはアプリケーションのロジックによって異なります。パーティションキーの数は、通常、シャードカウントよりかなり大きくする必要があります。これは、データレコードを特定のシャードにマッピングする方法を決定するために、パーティションキーが使用されるからです。十分なパーティションキーがある場合、ストリーム内のシャードに均等にデータを分散することができます。