자습서 #1: 필터를 사용하여 AWS CLI로 AWS Lambda 및 Amazon DynamoDB에서 모든 이벤트 처리

테이블을 생성하려면 다음 명령을 입력합니다.

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": [
                "*"
            ]
        }
    ]
}                

정책은 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에 대한 이메일 주소를 구독합니다. (region 및 accountID를 AWS 리전 및 계정 ID로 바꾸고, example@example.com을 유효한 이메일 주소로 바꿉니다.)

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

Amazon SNS에서 사용자 이메일 주소로 확인 메시지를 보냅니다. 구독 프로세스를 완료하는 메시지와 연결된 구독 확인 링크를 클릭합니다.

다음 콘텐츠를 가진 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."

몇 분 안에 새 이메일 메시지가 전송됩니다.

트리거를 생성할 때 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"}

몇 분 이내에 새 이메일 메시지를 수신합니다.

DynamoDB 콘솔을 열어서 BarkTable에 몇 개 항목을 추가합니다. Username 및 Timestamp에 대한 속성값을 지정해야 합니다. (필수 사항은 아니지만 Message에 대한 값을 지정할 수도 있습니다.) 추가한 BarkTable의 각 항목에 대해 새 이메일 메시지를 수신하게 됩니다.

Lambda 함수는 BarkTable에 추가된 새 항목만을 처리합니다. 테이블에 업데이트되거나 삭제한 항목에 대해 이 함수는 별도의 작업을 하지 않습니다.