Performance oriented node.js lambda handler for DynamoDB to Elastic search using DynamoDB streams. This module uses Bulk processing. Compatible with node 12.x and above.
Install:
npm i dynamo-to-elasticsearch-nodejs
Use it in your lambda:
const DynamoToES = require('dynamo-to-elasticsearch-nodejs');
exports.handler = async function handler(event) {
const client = new DynamoToES({ node: process.env.ES_ENDPOINT });
const response = await client.bulkHandler(event);
return response;
};
star this repository if it works as expected!!
Tests are written in using jest. Tests can be launched using:
npm test
This project is licensed under the GNU GPL v3 License - see the LICENSE.md file for details