Simple cloudformation example Don’t use EventSourceMapping. Just add event trigger with lambda function definition.
Simple write example:
const AWS = require('aws-sdk');
exports.handler = function(event, context) {
try {
const kinesis = new AWS.Kinesis({
apiVersion: '2013-12-02',
region: process.env.region
});
const kinesisStreamName = "KinesisStream1";
let date_ob = new Date();
let params = {
Data: date_ob.toString(),
PartitionKey: '1',
StreamName: kinesisStreamName
};
kinesis.putRecord(params, function(err, data) {
if (err) {
console.log('Kinesis Record Error: ' + JSON.stringify(err, err.stack));
} else {
console.log('Kinesis Record added: ');
}
return;
});
}catch(error){
console.log("Error: " + error.message);
return;
}
}