-
Notifications
You must be signed in to change notification settings - Fork 30
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Adaptor for dynamodb streams #347
Conversation
A few information on some of the choices:
|
Hey @sakthivel-tw. Thank you so much for your contribution! I'm currently on leave for 2 weeks, I'll aim to have a look into this one at the end of next week. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Hi @sakthivel-tw. Thanks for your patience as I just got back from my holiday. This PR looks perfect to me and I'm happy to merge it (it's in Draft status at the moment).
The choice of using AWS.DynamoDB.Convert to unmarshall is great, I didn't know that such utility exist.
@@ -7,5 +8,6 @@ const createEventAdapter = require("./createEventAdapter"); | |||
exports.sns = createEventAdapter(new SnsJsonInputConverter()); | |||
exports.sqs = createEventAdapter(new SqsJsonInputConverter()); | |||
exports.kinesis = createEventAdapter(new KinesisJsonInputConverter()); | |||
exports.dynamodb = createEventAdapter(new DynamoDbStreamJsonInputConvertor()); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Typo: Converter instead of Convertor
@@ -0,0 +1,97 @@ | |||
const merge = require("lodash/merge"); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Great test!
@all-contributors please add @sakthivel-tw for code |
I've put up a pull request to add @sakthivel-tw! 🎉 |
Adaptor support for dynamodb streams #152