aws dynamodb streams - a quick introduction

@crichardson

AWS DynamoDB StreamsA quick introduction

Chris Richardson

Author of POJOs in ActionFounder of the original CloudFoundry.com

@crichardsonchris@chrisrichardson.nethttp://plainoldobjects.comhttp://microservices.io

@crichardson

What is a DynamoDB Stream?

An ordered sequence of changes to items in a DynamoDB table:

Puts, updates, and deletes performed in last 24 hours

Sharded for scalability

Kinda like: message queue or Kafka topic

Similar to Kinesis streams

Subscribe to a stream to track the changes made to a table

Real time analytics

Cross region replication

Maintain materialized view tables

...

@crichardson

Creating a table with a streamKEYS,

OLD_IMAGE and/or

NEW_IMAGE

@crichardson

Getting the stream id

@crichardson

Getting the shards in a stream

@crichardson

Reading change records

@crichardson

Change records

@crichardson

@crichardson

Kinesis adapter

http://dynamodb-preview.s3-website-us-west-2.amazonaws.com/docs/streams-dg/Streams.KCLAdapter.html

Scalable, fault tolerant programming

model for stream processing

https://github.com/awslabs/amazon-kinesis-client

@crichardson

Lambda integration

http://dynamodb-preview.s3-website-us-west-2.amazonaws.com/docs/streams-dg/Streams.Lambda.Walkthrough.Basic.html#Streams.Lambda.Walkthrough.Basic.Step3

@crichardson

@crichardson chris@chrisrichardson.net

http://plainoldobjects.com http://microservices.io