SES -> SNS -> DynamoDB

index.js

var aws = require("aws-sdk");
var DynamoDB = new aws.DynamoDB.DocumentClient();

exports.handler = function (event, context, callback) {
  var SnsPublishTime = event.Records[0].Sns.Timestamp;
  var SESMessage = event.Records[0].Sns.Message;

  SESMessage = JSON.parse(SESMessage);

  var SESEventType = SESMessage.eventType;
  var SESMessageId = SESMessage.mail.messageId;
  var SESDestinationAddress = SESMessage.mail.destination.toString();
  var LambdaReceiveTime = new Date().toString();

  var params = {
    TableName: "boxhero-ses",
    Item: {
      SESMessageId: SESMessageId,
      SnsPublishTime: SnsPublishTime,

      LambdaReceiveTime: LambdaReceiveTime,
      Destination: SESDestinationAddress,

      EventType: SESEventType,
      message: SESMessage
    }
  }

  DynamoDB.put(params, function (err) {
    if (err) {
      console.log(err);
      callback(err)
    }
    else {
      callback(null, '')
    }
  });

};