Articles of amazon dynamodb

如何从发电机数据生活图

我正在使用node.js和dynamodb.I需要使用node.js从dynamo db绘制活动图。 帮助我从发电机数据库绘制实时图

NodeJS:如果不存在,则在dynamodb中插入logging

我需要将用户的信息存储在DynamoDB中,并在DynamoDB表中不存在的情况下将邮件发送给同一用户。 我正在做循环。 该列表只包含2个logging。 问题是只有第二个logging被插入到表中,邮件被发送两次给同一个用户。 这里是代码: module.exports.AddUser = function(req, res, usersList, departmentId) { var _emailId = ""; var _userName = ""; var _departmentId = departmentId; for (var i = 0; i < usersList.length; i++) { _emailId = usersList[i].emailId; _userName = usersList[i].userName; var params = { TableName: "UsersTable", Key: { "emailId": _emailId, "departmentId": _departmentId } }; docClient.get(params, […]

无服务器:dynamodb删除条件

我正在尝试删除带有条件的logging,并且失败。 我不断收到此错误: The provided key element does not match the schema 。 这是我在yml中的定义: resources: Resources: vuelosTable: Type: 'AWS::DynamoDB::Table' DeletionPolicy: Delete Properties: AttributeDefinitions: – AttributeName: id AttributeType: S – AttributeName: vuelta AttributeType: S KeySchema: – AttributeName: id KeyType: HASH – AttributeName: vuelta KeyType: RANGE ProvisionedThroughput: ReadCapacityUnits: 1 WriteCapacityUnits: 1 TableName: ${self:provider.environment.DYNAMODB_TABLE} 这些是试图删除时的参数: params = { RequestItems: […]

Node.JS Dynamodb内存问题与put

现在我遇到了在文档客户端上使用Dynamodb的put方法的问题。 当我现在用put方法运行我的程序时,内存从70MB开始,跳到90MB,然后继续稳定到65MB左右。 Uncommented了我的程序的内存跳转到90MB,并不断增长。 var params; for (var i = 0; i < tuples.length; i++){ if(tuples[i][1] != ""){ params = { TableName: "wordTable2", Item:{ "word":tuples[i][1], "url":tuples[i][0], "info":tuples[i][2] } }; var dynamobd = new AWS.DynamoDB.DocumentClient(); dynamobd.put(params, function(err, data){ //if(err) console.error("Unable to add item. Error JSON:", JSON.stringify(err, null, 2)); //else console.log("Added item:", JSON.stringify(data, null, 2)); }); dynamobd = […]

页面不工作错误,节点js冻结

我第一次使用Node,在某个响应被触发时遇到麻烦。 在这种情况下,我正在检查用户名和密码是否与DynamoDB中的用户名和密码相匹配。 当用户名和密码不匹配我的数据库时,它redirect到我的页面,但是当它,我所有的console.log输出打印两次(这显然是与Chrome中的favicon有关),如“在线”和“ [pw] + database.js“,但它也冻结了我的IDE和terminal。 然后我在浏览器中看到“页面不工作,本地主机没有发送任何数据”错误。 忽略隐私问题:)想法? database.js: var myDB_lookup = function(username, password, route_callbck){ console.log('Looking up: ' + username); users.get(username, function (err, data) { if (err) { route_callbck(null, "Lookup error: "+err); } else if (data == null) { route_callbck(null, null); } else { // JSON object that stores password & fullname var value = […]

nodejs,发电机表获取操作callback或asynchronous

伙计们,我正在编写一个从DynamoDB表中获取结果的API,并将JSON放回浏览器。 下面的代码工作,并返回所需的结果…但是,在阅读了asynchronous和callback后,它变得重要,我知道我是否应该以另一种方式写这个? 以下几百个并发的API调用程序能够很好地扩展吗? 这段代码似乎没有使用callback。 它是asynchronous的吗? var restify = require('restify'); var AWS = require('aws-sdk'); AWS.config.update({region: 'us-east-1'}); var db = new AWS.DynamoDB(); function myFunction(req, res, next) { var params = { TableName : 'myTable', KeyConditions : { "number" : { "AttributeValueList" : [ { "S" : req.params.simethingid } ], "ComparisonOperator" : "EQ" } } } db.query(params, function(err, […]

node.jscallback函数dynamodb

伙计们,我正在编写一个API函数,需要对后端DynamoDB表进行多次调用。 返回的JSON结果需要合并,然后作为单个响应返回给调用者。 我怎么会写这个,因为我似乎不完全写这个asynchronous… 到目前为止,我已经能够编写函数来进行一个调用,然后返回它。 我将如何编程第二个db.query? var restify = require('restify'); var fs = require('fs'); var AWS = require('aws-sdk'); AWS.config.update({region: 'us-east-1'}); var db = new AWS.DynamoDB(); module.exports = { license: function (req, res, next) { var params = { TableName : 'tableA', KeyConditions : { "myHashKey": { "AttributeValueList" : [ { "S" : "1" } ], "ComparisonOperator" […]

将ConditionalOperator设置为OR的DynamoDB扫描仍在执行AND

根据API文档,我有以下scan参数: var params = { "TableName": "MyTable", "ScanFilter": { "id": { "AttributeValueList": [ { "S": "ID-A" }, { "S": "ID-D" } ], "ComparisonOperator": "IN" }, "facilityName": { "AttributeValueList": [ { "S": "Name A" } ], "ComparisonOperator": "IN" } }, "ConditionalOperator": "OR" }; dynamo.scan(params, function (err, data) { if (err) { console.log(err, err.stack); } else { […]

DynamoDB在过去24小时内的下滑?

无论如何计算DynamoDB的吞吐量(写单位/读单位)在过去24小时内是如何缩减的? 我的想法是一旦人为下降,例如在需要的configuration写入单元中发生50%的下降。 我真的是高峰stream量。 因此,在每个高峰之后,我认为要缩小比例。 然而,我有一个晚上运行的分析工作,它提供了大量的读取单元,使得在它之后能够降级。 因此,我需要在24小时内将缩减比例限制为3倍。

AWS Lambda:我是否可以返回上下文并让任务仍在运行?

现在我在生产中有一个lambda函数来处理日志string,然后将它们返回给客户端,所以: 1) string received by lambda 2) lambda transforms string 3) lambda returns via context.succeed the transformed string 现在我添加一个额外的步骤,将string保存在dynamodb表中,所以工作stream将是: 1) string received by lambda 2) lambda transforms string 3) lambda saves string to dynamo 4) lambda returns via context.succeed the transformed string 现在的位保存function是这样的: function _saveItem (item) { dynamo.putItem(item, function (err, data) { //error handling here […]