video-events-test-snippet1.js

// This function is boilerplate for replicating how Amazon Kinesis events are
// passed to Lambda for processing.
//
// payloadString - The String to package
//
// Returns an Object as the data would be passed to Lambda
function packageEvent(payloadString) {
  var encodedPayload = new Buffer(payloadString).toString('base64')
  return {
    "Records": [{
      "kinesis": {
        "partitionKey": "partitionKey-3",
        "kinesisSchemaVersion": "1.0",
        "data": encodedPayload,
        "sequenceNumber": "49545115243490985018280067714973144582180062593244200961"
      },
      "eventSource": "aws:kinesis",
      "eventID": "shardId-000000000000:49545115243490985018280067714973144582180062593244200961",
      "invokeIdentityArn": "arn:aws:iam::059493405231:role/testLEBRole",
      "eventVersion": "1.0",
      "eventName": "aws:kinesis:record",
      "eventSourceARN": "arn:aws:kinesis:us-east-1:35667example:stream/examplestream",
      "awsRegion": "us-east-1"
    }]
  };
}

// This object is boilerplate for the context passed to an Amazon Lambda
// function. Calling done() exits the process Lambda creates.
var context = {
  done: function(error, message) {
    console.log('done!');
    process.exit(1);
  }
};