Setup DynamoDB Trigger using Lambda

Question

I'm trying to create a DynamoDB trigger using DynamoDB Streams and AWS Lambda. I researched a lot but I couldn't find any way to read and process a DynamoDB Stream event in Java 8. I'm completely new to both these technologies so don't know how to work with this.

Essentially, what I want to do is create a record in table B whenever a record is created in table A.

Could any of you please point me to a code or post that handles this use case in Java?

Thanks :)

Your stream event should look just like a regular SNS event inside that your Lambda. What is the problem exactly? — adamkonrad

Rohan Rohan · Accepted Answer · 2015-12-29T08:52:59

This code worked for me. You can use it to receive and process DynamoDB events in a Lambda function -

public class Handler implements RequestHandler<DynamodbEvent, Void> {

    @Override
    public Void handleRequest(DynamodbEvent dynamodbEvent, Context context) {

        for (DynamodbStreamRecord record : dynamodbEvent.getRecords()) {

            if (record == null) {
                continue;
            }

            // Your code here
            // Write to Table B using DynamoDB Java API
        }

        return null;
    }
}

When you create your Lambda, add the stream from table A as your event source, and you're good to go

Setup DynamoDB Trigger using Lambda

3 Answers