LambdaToDynamoDB

gistfile1.txt

console.log('Loading event');
var AWS = require('aws-sdk');
var dynamodb = new AWS.DynamoDB();
 
exports.handler = function(event, context) {
    
    console.log("Request received:\n", JSON.stringify(event));
    console.log("Context received:\n", JSON.stringify(context));

    var tableName = "CommonDynamoDBTable";
    var datetime = new Date().getTime().toString();

    payload = event;
  
        dynamodb.putItem({
            "TableName": tableName,
            "Item" : {
                "device_id": {"S": payload.device_id },
                "time": {"N": JSON.stringify(datetime) },
                "device": {"S": payload.device },
                "source": {"S": "from lambda" }
            }
        }, function(err, data) {
            if (err) {
                context.fail('ERROR: Putting item into dynamodb failed: '+err);
            }
            else {
                console.log('great success: '+JSON.stringify(data, null, '  '));
                context.succeed('SUCCESS');
            }
        });
};