チュートリアル #1: AWS CLI を使用した Amazon DynamoDB と AWS Lambda での、フィルターを使ったすべてのイベントの処理

次のコマンドを入力して、テーブルを作成します。

aws dynamodb create-table \
    --table-name BarkTable \
    --attribute-definitions AttributeName=Username,AttributeType=S AttributeName=Timestamp,AttributeType=S \
    --key-schema AttributeName=Username,KeyType=HASH  AttributeName=Timestamp,KeyType=RANGE \
    --provisioned-throughput ReadCapacityUnits=5,WriteCapacityUnits=5 \
    --stream-specification StreamEnabled=true,StreamViewType=NEW_AND_OLD_IMAGES

出力で、LatestStreamArn を探します。

...
"LatestStreamArn": "arn:aws:dynamodb:region:accountID:table/BarkTable/stream/timestamp
...

region と accountID をメモしておきます。これらは、このチュートリアルの他のステップで必要になります。

次の内容で、trust-relationship.json というファイルを作成します。

{
   "Version": "2012-10-17",
   "Statement": [
     {
       "Effect": "Allow",
       "Principal": {
         "Service": "lambda.amazonaws.com"
       },
       "Action": "sts:AssumeRole"
     }
   ]
 }

WooferLambdaRole を作成するため、以下のコマンドを入力します。

aws iam create-role --role-name WooferLambdaRole \
    --path "/service-role/" \
    --assume-role-policy-document file://trust-relationship.json

次の内容で、role-policy.json というファイルを作成します。(region および accountID をお客様の AWS リージョンとアカウント ID に置き換えます。)

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "logs:CreateLogGroup",
                "logs:CreateLogStream",
                "logs:PutLogEvents"
            ],
            "Resource": "arn:aws:logs:region:accountID:*"
        },
        {
            "Effect": "Allow",
            "Action": [
                "dynamodb:DescribeStream",
                "dynamodb:GetRecords",
                "dynamodb:GetShardIterator",
                "dynamodb:ListStreams"
            ],
            "Resource": "arn:aws:dynamodb:region:accountID:table/BarkTable/stream/*"
        },
        {
            "Effect": "Allow",
            "Action": [
                "sns:Publish"
            ],
            "Resource": [
                "*"
            ]
        }
    ]
}                

ポリシーには 4 つのステートメントがあり、これにより WooferLambdaRole は以下を実行できます。

次のコマンドを入力して、WooferLambdaRole にポリシーをアタッチします。

aws iam put-role-policy --role-name WooferLambdaRole \
    --policy-name WooferLambdaRolePolicy \
    --policy-document file://role-policy.json

次のコマンドを入力して、新しい Amazon SNS トピックを作成します。

aws sns create-topic --name wooferTopic

次のコマンドを入力して、wooferTopic に E メールアドレスをサブスクライブします (region および accountID は AWS リージョンとアカウント ID に置き換え、example@example.com は有効な E メールアドレスと置き換えます)。

aws sns subscribe \
    --topic-arn arn:aws:sns:region:accountID:wooferTopic \
    --protocol email \
    --notification-endpoint example@example.com

Amazon SNS は E メールアドレスに確認メッセージを送信します。そのメッセージの [サブスクリプションを確認] リンクを選択して、サブスクリプションプロセスを完了します。

次の内容で、publishNewBark.js というファイルを作成します。region および accountID をお客様の AWS リージョンとアカウント ID に置き換えます。

'use strict';
var AWS = require("aws-sdk");
var sns = new AWS.SNS();

exports.handler = (event, context, callback) => {

    event.Records.forEach((record) => {
        console.log('Stream record: ', JSON.stringify(record, null, 2));

        if (record.eventName == 'INSERT') {
            var who = JSON.stringify(record.dynamodb.NewImage.Username.S);
            var when = JSON.stringify(record.dynamodb.NewImage.Timestamp.S);
            var what = JSON.stringify(record.dynamodb.NewImage.Message.S);
            var params = {
                Subject: 'A new bark from ' + who,
                Message: 'Woofer user ' + who + ' barked the following at ' + when + ':\n\n ' + what,
                TopicArn: 'arn:aws:sns:region:accountID:wooferTopic'
            };
            sns.publish(params, function(err, data) {
                if (err) {
                    console.error("Unable to send message. Error JSON:", JSON.stringify(err, null, 2));
                } else {
                    console.log("Results from sending message: ", JSON.stringify(data, null, 2));
                }
            });
        }
    });
    callback(null, `Successfully processed ${event.Records.length} records.`);
};   

publishNewBark.js を含める zip ファイルを作成します。zip コマンドラインユーティリティがある場合は、次のコマンドを入力してこれを行うことができます。

zip publishNewBark.zip publishNewBark.js

Lambda 関数を作成する場合は、ステップ 2: Lambda 実行ロールを作成する で作成した WooferLambdaRole の Amazon リソースネーム (ARN) を指定します。この ARN を取得するには、次のコマンドを入力します。

aws iam get-role --role-name WooferLambdaRole

出力で、WooferLambdaRole の ARN を探します。

...
"Arn": "arn:aws:iam::region:role/service-role/WooferLambdaRole"
...

次のコマンドを入力して、Lambda 関数を作成します。roleARN を WooferLambdaRole の ARN に置き換えます。

aws lambda create-function \
    --region region \
    --function-name publishNewBark \
    --zip-file fileb://publishNewBark.zip \
    --role roleARN \
    --handler publishNewBark.handler \
    --timeout 5 \
    --runtime nodejs16.x

ここで、publishNewBark をテストして、これが動作することを確認します。これを行うには、DynamoDB Streams の実際のレコードに似た情報を入力します。

次の内容で、payload.json というファイルを作成します。region および accountID をお客様の AWS リージョンとアカウント ID に置き換えます。

{
    "Records": [
        {
            "eventID": "7de3041dd709b024af6f29e4fa13d34c",
            "eventName": "INSERT",
            "eventVersion": "1.1",
            "eventSource": "aws:dynamodb",
            "awsRegion": "region",
            "dynamodb": {
                "ApproximateCreationDateTime": 1479499740,
                "Keys": {
                    "Timestamp": {
                        "S": "2016-11-18:12:09:36"
                    },
                    "Username": {
                        "S": "John Doe"
                    }
                },
                "NewImage": {
                    "Timestamp": {
                        "S": "2016-11-18:12:09:36"
                    },
                    "Message": {
                        "S": "This is a bark from the Woofer social network"
                    },
                    "Username": {
                        "S": "John Doe"
                    }
                },
                "SequenceNumber": "13021600000000001596893679",
                "SizeBytes": 112,
                "StreamViewType": "NEW_IMAGE"
            },
            "eventSourceARN": "arn:aws:dynamodb:region:account ID:table/BarkTable/stream/2016-11-16T20:42:48.104"
        }
    ]
}

次のコマンドを入力して、publishNewBark 関数をテストします。

aws lambda invoke --function-name publishNewBark --payload file://payload.json --cli-binary-format raw-in-base64-out output.txt

テストが成功すると、次の出力が表示されます。

{
    "StatusCode": 200,
    "ExecutedVersion": "$LATEST"
}

さらに、output.txt ファイルには次のテキストが含まれます。

"Successfully processed 1 records."

また、数分以内に新しい E メールメッセージが届きます。

トリガーを作成する場合、BarkTable ストリーム用の ARN を指定する必要があります。この ARN を取得するには、次のコマンドを入力します。

aws dynamodb describe-table --table-name BarkTable

出力で、LatestStreamArn を探します。

...
 "LatestStreamArn": "arn:aws:dynamodb:region:accountID:table/BarkTable/stream/timestamp
...

次のコマンドを入力してトリガーを作成します streamARN を実際のストリーム ARN に置き換えます。

aws lambda create-event-source-mapping \
    --region region \
    --function-name publishNewBark \
    --event-source streamARN  \
    --batch-size 1 \
    --starting-position TRIM_HORIZON

トリガーをテストします。次のコマンドを入力して、BarkTable に項目を追加します。

aws dynamodb put-item \
    --table-name BarkTable \
    --item Username={S="Jane Doe"},Timestamp={S="2016-11-18:14:32:17"},Message={S="Testing...1...2...3"}

数分以内に新しい E メールメッセージが届きます。

DynamoDB コンソールを開き、さらにいくつかの項目を BarkTable に追加します。Username および Timestamp 属性の値を指定する必要があります (必須ではないものの、Message の値を指定する必要があります)。BarkTable に追加した各項目について、新しい E メールメッセージが届きます。

Lambda 関数は、BarkTable に追加した新しい項目のみを処理します。テーブル内の項目を更新または削除すると、この関数は何も行いません。