Tutorial #1: Verwenden von Filtern zur Verarbeitung aller Ereignisse mit Amazon DynamoDB und AWS Lambda Verwendung der AWS CLI

Verwenden Sie den folgenden Befehl, um die Tabelle zu erstellen.

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

Suchen Sie in der Ausgabe nach dem LatestStreamArn.

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

Notieren Sie sich die region und die accountID, da Sie sie für die anderen Schritte in diesem Tutorial benötigen.

Erstellen Sie eine Datei mit dem Namen trust-relationship.json und dem folgenden Inhalt.

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

Geben Sie den folgenden Befehl ein, um WooferLambdaRole zu erstellen.

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

Erstellen Sie eine Datei mit dem Namen role-policy.json und dem folgenden Inhalt. (Ersetzen Sie region und accountID durch Ihre AWS Region und Konto-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": [
                "*"
            ]
        }
    ]
}                

Die Richtlinie enthält vier Anweisungen, damit WooferLambdaRole folgende Aufgaben ausführen kann:

Führen Sie den folgenden Befehl aus, um die Richtlinie WooferLambdaRole anzufügen:

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

Geben Sie den folgenden Befehl ein, um ein neues Amazon-SNS-Thema zu erstellen.

aws sns create-topic --name wooferTopic

Geben Sie den folgenden Befehl ein, um wooferTopic für eine E-Mail-Adresse zu abonnieren. (Ersetzen Sie region bzw. accountID durch Ihre AWS -Region bzw. die Konto-ID und example@example.com durch eine gültige E-Mail-Adresse.)

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

Amazon SNS sendet eine Bestätigungsnachricht an Ihre E-Mail-Adresse. Klicken Sie auf den Link Confirm subscription (Abonnement bestätigen) in dieser E-Mail, um Ihr Abonnement abzuschließen.

Erstellen Sie eine Datei mit dem Namen publishNewBark.js und dem folgenden Inhalt. Ersetzen Sie region und accountID durch Ihre AWS Region und Konto-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.`);
};   

Erstellen Sie eine ZIP-Datei mit publishNewBark.js. Wenn Sie das ZIP-Befehlszeilen-Dienstprogramm verwenden, geben Sie dazu den folgenden Befehl ein.

zip publishNewBark.zip publishNewBark.js

Beim Erstellen der Lambda-Funktion geben Sie den Amazon-Ressourcennamen (ARN) für WooferLambdaRole an, den Sie in Schritt 2: Erstellen einer Lambda-Ausführungsrolle erstellt haben. Geben Sie den folgenden Befehl ein, um diesen ARN abzurufen.

aws iam get-role --role-name WooferLambdaRole

Suchen Sie in der Ausgabe nach dem ARN für WooferLambdaRole.

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

Verwenden Sie den folgenden Befehl, um die Lambda-Funktion zu erstellen. roleARNErsetzen Sie es durch den ARN fürWooferLambdaRole.

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

Testen Sie die publishNewBark-Funktion. Stellen Sie dazu eine Eingabe bereit, die einem echten Datensatz aus DynamoDB Streams ähnelt.

Erstellen Sie eine Datei mit dem Namen payload.json und dem folgenden Inhalt. Ersetzen Sie region und accountID durch Ihre AWS-Region Konto-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"
        }
    ]
}

Verwenden Sie den folgenden Befehl, um die publishNewBark-Funktion zu erstellen.

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

Wenn der Test erfolgreich war, sehen Sie die folgende Ausgabe.

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

Darüber hinaus enthält die output.txt-Datei folgenden Text.

"Successfully processed 1 records."

Außerdem erhalten Sie in wenigen Minuten eine neue E-Mail-Nachricht.

Wenn Sie den Auslöser erstellen, müssen Sie den ARN für den BarkTable-Stream angeben. Geben Sie den folgenden Befehl ein, um diesen ARN abzurufen.

aws dynamodb describe-table --table-name BarkTable

Suchen Sie in der Ausgabe nach dem LatestStreamArn.

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

Geben Sie den folgenden Befehl ein, um den Auslöser zu erstellen. Ersetzen Sie streamARN durch den tatsächlichen Stream-ARN.

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

Testen Sie den Auslöser. Geben Sie dazu den folgenden Befehl ein, um BarkTable ein Element hinzuzufügen.

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"}

Sie erhalten in wenigen Minuten eine neue E-Mail-Nachricht.

Öffnen Sie die DynamoDB-Konsole und fügen Sie BarkTable weitere Elemente hinzu. Sie müssen Werte für die Attribute Username und Timestamp angeben. (Sie sollten auch einen Wert für Message angeben, auch wenn er nicht erforderlich ist.) Sie erhalten eine neue E-Mail-Nachricht für jedes Element, das Sie BarkTable hinzufügen.

Die Lambda-Funktion verarbeitet nur neue Elemente, die Sie BarkTable hinzufügen. Wenn Sie ein Element in der Tabelle aktualisieren oder löschen, hat die Funktion keine Auswirkung.