このセクションでは、Amazon DynamoDB コンソール、AWS Command Line Interface (AWS CLI)、および API を活用して Amazon DynamoDB 用の Amazon Kinesis Data Streams テーブルを使用する方法について説明します。
アクティブな Amazon Kinesis Data Streams の作成
これらの例はすべて、DynamoDB の使用開始チュートリアルの一部として作成された Music
DynamoDB テーブルを使用しています。
コンシューマーを構築し、Kinesis データストリームを他の AWS のサービスに接続する詳細方法については、「Amazon Kinesis Data Streams デベロッパーガイド」の「Kinesis Data Streams からのデータの読み込み」を参照してください。
注記
KDS シャードを初めて使用するときは、使用パターンに合わせてシャードをスケールアップまたはスケールダウンするように設定することをお勧めします。使用パターンに関するデータをさらに蓄積したら、それに合わせてストリーム内のシャードを調整できます。
-
AWS Management Console にサインインし、Kinesis コンソール (https://console.aws.amazon.com/kinesis/
) を開きます。 -
[Create data stream (データストリーミングの作成)] を選択し、指示に従って
samplestream
というストリーミングを作成します。 -
DynamoDB コンソール (https://console.aws.amazon.com/dynamodb/
) を開きます。 -
コンソールの左側のナビゲーションペインで、[テーブル] を選択します。
-
[Music] テーブルを選択します。
-
[エクスポートとストリーム] タブを選択します。
-
(オプション) [Amazon Kinesis データストリームの詳細] で、レコードのタイムスタンプの精度をマイクロ秒 (デフォルト) からミリ秒に変更できます。
-
ドロップダウンリストから samplestream を選択します。
-
[オンにする] ボタンを選択します。
アクティブな Amazon Kinesis データストリームに変更を加える
このセクションでは、コンソール、AWS CLI、API を使用して DynamoDB 用 Kinesis Data Streams のセットアップを変更する方法について説明します。
AWS Management Console
-
DynamoDB コンソール (https://console.aws.amazon.com/dynamodb/
) を開きます。 -
テーブルに移動します。
-
[エクスポートおよびストリーム] タブを選択します。
AWS CLI
-
describe-kinesis-streaming-destination
を呼び出して、ストリームがACTIVE
であることを確認します。 -
次の例のように、
UpdateKinesisStreamingDestination
を呼び出します。aws dynamodb update-kinesis-streaming-destination --table-name enable_test_table --stream-arn arn:aws:kinesis:us-east-1:12345678901:stream/enable_test_stream --update-kinesis-streaming-configuration ApproximateCreationDateTimePrecision=MICROSECOND
-
describe-kinesis-streaming-destination
を呼び出して、ストリームがUPDATING
であることを確認します。 -
ストリーミングステータスが再び
ACTIVE
になるまでdescribe-kinesis-streaming-destination
を定期的に呼び出します。タイムスタンプの精度の更新が有効になるまで、最大 5 分かかることがあります。このステータスが更新されると、更新が完了したことを表し、新しい精度値が今後のレコードに適用されます。 -
putItem
を使用してテーブルに書き込みます。 -
Kinesis
get-records
コマンドを使用して、Kinesis ストリームコンテンツを取得します。 -
書き込みの
ApproximateCreationDateTime
の精度が希望どおりであることを確認します。
Java API
-
UpdateKinesisStreamingDestination
リクエストとUpdateKinesisStreamingDestination
レスポンスを構成するコードスニペットを提供します。 -
DescribeKinesisStreamingDestination
リクエストとDescribeKinesisStreamingDestination response
を構成するコードスニペットを提供します。 -
ストリーミングのステータスが、更新が完了し、将来のレコードに新しい精度値が適用されることを示す
ACTIVE
に戻るまで、describe-kinesis-streaming-destination
を定期的に呼び出します。 -
テーブルへの書き込みを実行します。
-
ストリームから読み取り、ストリームコンテンツを逆シリアル化します。
-
書き込みの
ApproximateCreationDateTime
の精度が希望どおりであることを確認します。