Amazon Kinesis Data Streams
開発者ガイド

Amazon Kinesis Data Streams からのデータの読み取り

コンシューマーは、Kinesis データストリームからのすべてのデータを処理するアプリケーションです。コンシューマーで拡張ファンアウトを使用すると、独自の 2 MiB/秒の読み込みスループットが割り当てられ、読み取りスループットが他のコンシューマーと競合することなく、複数のコンシューマーが並行して同じストリームからデータを読み取ることができます。シャードの拡張ファンアウト機能を使用するには、「拡張ファンアウトでコンシューマーを使用する 」を参照してください。

デフォルトでは、ストリーム内のシャードの読み込みスループットは 2 MiB/秒 (シャードあたり) です。このスループットは、指定されたシャードから読み取りを行うすべてのコンシューマー間で共有されます。つまり、デフォルトの 2 MiB/秒のシャードあたりのスループットは、そのシャードから読み取りを行う複数のコンシューマーがある場合でも、固定です。このデフォルトのシャードのスループットを使用するには、「Amazon Kinesis Data Streams コンシューマーの開発」を参照してください。

次の表で、拡張ファンアウトのデフォルトのスループットを比較します。メッセージ伝達遅延時間は、ペイロードを送信する API (PutRecord や PutRecords など) を使用して送信されたペイロードが、ペイロードを消費する API (GetRecords や SubscribeToShard など) を経由してコンシューマーアプリケーションに到達するまでにかかった時間 (ミリ秒) として定義されます。

特徴 拡張ファンアウトを使用しない未登録コンシューマー 拡張ファンアウトを使用する登録済みコンシューマー
シャードの読み取りスループット シャードあたり合計 2MiB/秒で固定。同じシャードから読み取るコンシューマーが複数ある場合、それらのすべてがこのスループットを共有します。これらがシャードから受け取るスループットの合計は、2 MiB/秒を超えません。 拡張ファンアウトを使用するコンシューマーが登録されるにつれてスケールされます。拡張ファンアウトを使用するように登録された各コンシューマーは、他のコンシューマーとは関係なく、シャードごとに独自の読み取りスループットを最大 2MiB/秒まで受け取ります。
メッセージ伝達遅延 ストリームから読み取るコンシューマーが 1 つの場合は平均約 200 ms です。コンシューマーが 5 つの場合、この平均は最大約 1000 ms まで上がります。 コンシューマーが 1 つまたは 5 つかによって、一般的に平均 70 ms です。
Cost 該当なし データ取得コストおよびコンシューマー - シャード時間料金がかかります。詳細については、Amazon Kinesis Data Streams の料金表を参照してください。
レコードの配信モデル GetRecords を使用した HTTP 経由のプルモデル。 Kinesis Data Streams は、SubscribeToShard を使用し、HTTP/2 経由でレコードをユーザーにプッシュします。