var Aws = require('aws-sdk'); var DynamoClient = require('dynamodb-doc').DynamoDB; // This script uses the Shared Credentials File. See reference below for more: // http://docs.aws.amazon.com/AWSJavaScriptSDK/guide/node-configuring.html Aws.config.update({ region: 'us-east-1' }); var internals = {}; internals.dynamoClient = new DynamoClient(); internals.writeToDynamo = function () { var params = { TableName: 'test', }; params.Item = { ts: Number(Date.now()), name: 'test', }; internals.dynamoClient.putItem(params, function (err, data) { if (err) { console.error(err); console.error(err.stack); } else { console.log(data); } }); }; internals.dynamoClient.scan({ TableName: 'test' }, function (err, result) { if (err) { throw err; } console.log(result); setInterval(internals.writeToDynamo, 2000); });