dynamo-es-mapper

Maps dynamodb stream records into actions ready for the elasticsearch bulk API

Usage

npm install

var dynes = require('dynamo-es-mapper');

var esActions = dynes(dynamoRecords, 'custom_id');

...

Options

• api: index, update ( default ) - ES bulk api type

var options = {
    api: 'index' //defaults to 'update'
};
var esActions = dynes(dynamoRecords, 'id', options);