Lambda Function for DynamoDB Streams

exports.handler = async (event, context) => {
  for (const record of event.Records) {
    let platform = record.dynamodb['NewImage']['platform']['S'];
    let amount = record.dynamodb['NewImage']['amount']['N'];
    let data = ... // format according to your Redshift schema
    var params = {
      Data: data
      StreamName: 'test'
      PartitionKey: '1234'
    };
    kinesis.putRecord(params, function(err, data) {
      if (err) console.log(err, err.stack); // an error occurred
        else     console.log(data);           // successful response
    });
  }
  return `Successfully processed ${event.Records.length} records.`;
};