diff --git a/aws-modules/aws-lambda/lambda/pom.xml b/aws-modules/aws-lambda/lambda/pom.xml index edf52d0581..16f1c29f2d 100644 --- a/aws-modules/aws-lambda/lambda/pom.xml +++ b/aws-modules/aws-lambda/lambda/pom.xml @@ -95,8 +95,8 @@ 1.1.1 - 1.3.0 - 1.2.0 + 3.11.0 + 1.2.1 2.8.2 diff --git a/aws-modules/aws-lambda/lambda/src/main/java/com/baeldung/lambda/dynamodb/SavePersonHandler.java b/aws-modules/aws-lambda/lambda/src/main/java/com/baeldung/lambda/dynamodb/SavePersonHandler.java index 625da62efd..442e7ab4ef 100644 --- a/aws-modules/aws-lambda/lambda/src/main/java/com/baeldung/lambda/dynamodb/SavePersonHandler.java +++ b/aws-modules/aws-lambda/lambda/src/main/java/com/baeldung/lambda/dynamodb/SavePersonHandler.java @@ -1,12 +1,12 @@ package com.baeldung.lambda.dynamodb; -import com.amazonaws.regions.Region; +import java.util.HashMap; +import java.util.Map; + import com.amazonaws.regions.Regions; -import com.amazonaws.services.dynamodbv2.AmazonDynamoDBClient; -import com.amazonaws.services.dynamodbv2.document.DynamoDB; -import com.amazonaws.services.dynamodbv2.document.Item; -import com.amazonaws.services.dynamodbv2.document.PutItemOutcome; -import com.amazonaws.services.dynamodbv2.document.spec.PutItemSpec; +import com.amazonaws.services.dynamodbv2.AmazonDynamoDB; +import com.amazonaws.services.dynamodbv2.AmazonDynamoDBClientBuilder; +import com.amazonaws.services.dynamodbv2.model.AttributeValue; import com.amazonaws.services.dynamodbv2.model.ConditionalCheckFailedException; import com.amazonaws.services.lambda.runtime.Context; import com.amazonaws.services.lambda.runtime.RequestHandler; @@ -15,7 +15,7 @@ import com.baeldung.lambda.dynamodb.bean.PersonResponse; public class SavePersonHandler implements RequestHandler { - private DynamoDB dynamoDb; + private AmazonDynamoDB amazonDynamoDB; private String DYNAMODB_TABLE_NAME = "Person"; private Regions REGION = Regions.US_WEST_2; @@ -30,20 +30,22 @@ public class SavePersonHandler implements RequestHandler attributesMap = new HashMap<>(); + + attributesMap.put("id", new AttributeValue(String.valueOf(personRequest.getId()))); + attributesMap.put("firstName", new AttributeValue(personRequest.getFirstName())); + attributesMap.put("lastName", new AttributeValue(personRequest.getLastName())); + attributesMap.put("age", new AttributeValue(String.valueOf(personRequest.getAge()))); + attributesMap.put("address", new AttributeValue(personRequest.getAddress())); + + amazonDynamoDB.putItem(DYNAMODB_TABLE_NAME, attributesMap); } private void initDynamoDbClient() { - AmazonDynamoDBClient client = new AmazonDynamoDBClient(); - client.setRegion(Region.getRegion(REGION)); - this.dynamoDb = new DynamoDB(client); + this.amazonDynamoDB = AmazonDynamoDBClientBuilder.standard() + .withRegion(REGION) + .build(); } } diff --git a/aws-modules/pom.xml b/aws-modules/pom.xml index 4d3ec4b6dd..72c5017c32 100644 --- a/aws-modules/pom.xml +++ b/aws-modules/pom.xml @@ -22,7 +22,7 @@ - 1.11.290 + 1.12.331 3.0.0