DynamoDB StreamsのストリームデータをLambdaで読み込む方法を記載します．

1. DynamoDB Streamsについて

一言で言うと，DynamoDBテーブル内の変更を時系列順に最大24時間保存する．

DynamoDB Streamsは下記を保守する

変更内容はストリームに 1 回だけ出現する
変更された各項目について、実際の変更と同じ順序で出現する

2. ストリームの有効化

DynamoDB Streamsを有効化する前に，まずテスト用のテーブルを作成する．

プライマリーキーはnameで，その他項目はvalueとする．

DynamoDB Streamsを有効化するのは非常に簡単です．
DynamoDBコンソールのダッシュボードから、[テーブル]を選択．

[概要]タブで、[ストリームの管理]を選択．

[ストリームの管理]ウィンドウで、テーブルのデータが変更されるたびにストリームに書き込まれる情報を選択し，[有効化]をクリック

各ストリームは，Amazonリソースネームで一意に識別されます．

arn:aws:dynamodb:ap-northeast-1:111122223333:table/height/stream/2018-07-13T12:38:41.050

3. ストリームの読み込み

読み込む方法としてLambdaからDynamoDBをトリガーとして読み込む方法がある．

3.1. Lambda関数を作成

Lambda関数を作成する．設計図を選択し，「dynamodb-process-stream-python3」を選択する．

Lambda関数名やIAMなどは必要な情報を埋める．

DynamoDB トリガーはトリガーの有効化を選択するとDynamoDB Streamsからデータを読み込む設定が完了する．

Lambda関数を作成する．下記は既存のテンプレート．

3.2. DynamoDBにデータを挿入し動作確認

実際にDynamoDBに下記の通り値を挿入してみる．

下記の通りログが流れていることがわかる．

下記がログの抜粋

{
    "ApproximateCreationDateTime": 1531488480,
    "Keys": {
        "name": {
            "S": "tarou"
        }
    },
    "NewImage": {
        "name": {
            "S": "tarou"
        },
        "height": {
            "N": "160"
        }
    },
    "SequenceNumber": "17700000000000480644429",
    "SizeBytes": 27,
    "StreamViewType": "NEW_AND_OLD_IMAGES"
}

4. 参考リンク

DynamoDB ストリームを使用したテーブルアクティビティのキャプチャ