Short aws lambda sample program that puts an item into dynamodb

lambda-dynamo

// create an IAM Lambda role with access to dynamodb
// Launch Lambda in the same region as your dynamodb region
// (here: us-east-1)
// dynamodb table with hash key = user and range key = datetime

console.log('Loading event');
var AWS = require('aws-sdk');
var dynamodb = new AWS.DynamoDB({apiVersion: '2012-08-10'});

exports.handler = function(event, context) {
    console.log(JSON.stringify(event, null, '  '));
    dynamodb.listTables(function(err, data) {
      console.log(JSON.stringify(data, null, '  '));
    });
    var tableName = "chat";
    var datetime = new Date().getTime().toString();
    dynamodb.putItem({
        "TableName": tableName,
        "Item" : {
            "user": {"S": event.user },
            "date": {"S": datetime },
            "msg": {"S": event.msg}
        }
    }, function(err, data) {
        if (err) {
            context.done('error','putting item into dynamodb failed: '+err);
        }
        else {
            console.log('great success: '+JSON.stringify(data, null, '  '));
            context.done('K THX BY');
        }
    });
};

// sample event
//{
//  "user": "bart",
//  "msg": "hey otto man"
//}

Sweet guide, thanks.

If anybody's watching this after February 2015, use:

var doc = require('dynamodb-doc');
var dynamo = new doc.DynamoDB();

INSTEAD OF:

var AWS = require('aws-sdk');
var dynamodb = new AWS.DynamoDB({apiVersion: '2012-08-10'});

I spent a lot of time very confused because things werent working out because of this.

Hi, could you actually get this to work? I changed the example accordingly with subsequent correction of the variable name dynamodb.listTables to dynamo.listTables etc. Though I can't seem to get the Lambda to execute the dynamodb functions. Neither the err or data. Also I can't seem to figure out how to find what the error is, if permission related or otherwise.

To see the actual error change:
context.done('error','putting item into dynamodb failed: '+err);
to
context.done('error putting item into dynamodb failed: '+err);

The fix is to change:
"date": {"S": datetime },
to
"datetime": {"S": datetime },

I also had trouble with this. Item should be defined as follows:

"Item" : {
"user": event.user ,
"date": datetime,
"msg": event.msg
}

i tried this.. i didn't get any errors,but data not getting inserted

then I tried this

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 = "jobs";

dynamodb.putItem({
        "TableName": tableName,
        "Item": {
            "id": {
                "S": 5
            }, 
            "name": {
                "S": "user-1"
            }
        }
    }, function(err, data) {
        if (err) {
            context.fail('ERROR: Dynamo failed: ' + err);
        } else {
            console.log('Dynamo Success: ' + JSON.stringify(data, null, '  '));
            context.succeed('SUCCESS');
        }
    });

}

Even I didn't get any errors or data. Whatever is outside of the dynamodb block is getting printed fine.

A lot has been changed in the AWSDynamoDB for Lambda. There is an working example

`console.log('Loading function');
      var doc = require('dynamodb-doc');
      var db = new doc.DynamoDB();

exports.handler = function(event, context) 
{
     var username  = event.username;
     var email = event.email;
     var userId = event.userId;
    console.log(username + "," + email +","+ userId);

var tableName = "User";
var item = {
     "username":username,
     "email":  email,
     "userId": userId
};
 var params = {
     TableName:tableName, 
     Item: item
 };

     console.log(params);
 db.putItem(params,function(err,data){
     if (err) console.log(err);
     else console.log(data);
 });
};`

And the test event code
{
"username":"admin",
"email":"admin@admin.com",
"userId": "AD87S"
}

Slight update here https://gist.github.com/aaronhoffman/c2b7ef532b7a28e99aae

More info: http://aaron-hoffman.blogspot.com/2016/03/store-amazon-ses-delivery-notifications.html

Sorry guys, didn't look at this gist for a while. Thanks for the update @LamourBt

I have built a little sample application yesterday with the serverless framwork, lambda (nodejs), api gateway and dynamodb: https://github.com/markusklems/serverless-node-dynamodb-example Maybe the code helps and is more up to date than the one in this gist.

How do you write records to the account database? I've been able to successfully do this with a local version, but how can I add a record to the remotely hosted database?

How to return the inserted item? I want to return the inserted item as response.

@LamourBt your example is non-functional and it also doesn't align with the AWS Dynamo docs.

Hi guys, thanks to everyone that's contributed to this thread. It was helpful in getting things to work. I got writes to Dynamodb working using the Serverless framework. Link to gist below. 👇

https://gist.github.com/martimatix/06481e1321ab99bf4a501705235b261f

Hi

I found this tutorial most helpful nut I now find myself wanting to take it a step further by using less hardcoding of the Item values if possible.

Consider some incoming data that is not consistent in the types of data being received. Is it possible to iterate thru the JSON to determine the names of the items and then use them instead of hardcoding them?

ie

dynamodb.putItem({
"TableName": tableName,
"Item" : {
event1.name: {"S": event.1.data },
event2.name: {"S": event.2.data },
event3.name: {"S": event.3.data}
}

there is no putItem() method in DocumentClient anymore: http://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/DynamoDB/DocumentClient.html#update-property
There is put(), update(), etc instead

Plus, if you use the DocumentClient, you can use normal JSON objects and the SDK will handle the object model for you.

Therefore

dynamodbDocClient.put({
    'TableName': 'table',
    'Item': {
        'test': 'test',
        'number': 1
    }
}, function(err, data) {
    if (err) {
        console.log(err);
    } else {
        console.log(data);
    }
});

Should work perfectly fine.

@deibid Thanks for the tip suggesting to use:

var doc = require('dynamodb-doc');
var dynamo = new doc.DynamoDB();

INSTEAD OF:

var AWS = require('aws-sdk');
var dynamodb = new AWS.DynamoDB({apiVersion: '2012-08-10'});

I was getting "Task timed out after 3.00 seconds" on my DynamoDB calls until I followed your recommendation.

In case anyone gets here and is still seeing the "Task timed out after 3.00 seconds" thing -- I had to move my require and new doc.DynamicDB() lines to the very top of the lambda code -- outside of the exports.handler.