Tag: amazon dynamodb

如何从nodejs客户端重新格式化DynamoDB响应: 当我使用aws nodejs客户端从dynamoDB获取请求时，结果包含一个types为key的响应 { Item: { newrelic_id: { S: 'nr-1234' } , jumpcloud_id: { S: 'j-234' } , microtime: { N: '1475690490854' } , instance_id: { S: 'i-abc1234' } } } 请注意，值的键是这些types的前缀， String S和数字N是否有删除这个“types键”的方法？

使用node.js更新expression式上的发电机数据库错误: 我需要更新我的aws-dynamo数据库上的列表。我用分区键创build了一个表：email。然后iam成功地将一些电子邮件ID插入到表中。现在我的桌子是这样的电子邮件 manaf1@gmail.com manaf2@gmail.com manaf3@gmail.com 然后，我试图用新的关键“细节”更新表，它的值是一个列表。这是我的代码 var AWS = require("aws-sdk"); var params = { TableName: "manaftable1", Key: { email: "manaf1@gmail.com" }, UpdateExpression: "set #details = list_append (#details, :detailsinput)", ExpressionAttributeNames: { "#details": "details" }, ExpressionAttributeValues: { ":detailsinput":{ "id": "1","mob": "978956" } } }; var docClient = new AWS.DynamoDB.DocumentClient(); docClient.update(params, function (err, data) […]

AWS DynamoDB查询不对BOOL值进行筛选: 我有一个用GUI创build的用户表，给出了电子邮件的分区键，它是一个string。然后我用aws lambda来做一个putItem，它有： email (string) test@testing.com deleted (BOOL) false 这工作得很好。然后我试图用lambda查询它使用以下参数和查询： var params = { TableName : 'Users', KeyConditionExpression : 'email = :email', FilterExpression : 'deleted = :deleted', ExpressionAttributeValues : { ':email' : email, ':deleted': { BOOL: false } } }; docClient.query(params, function(err, data) { if (err) return fn(err); else { console.log("GetItem succeeded:", JSON.stringify(data, null, […]

在nodejs中的dynamodb中进行扫描的recursion函数: 所以我需要一个nodejs中的recursion函数来replace这个函数调用： docClient.scan(params, callback) http://docs.aws.amazon.com/amazondynamodb/latest/gettingstartedguide/GettingStarted.NodeJs.04.html

使用nodejs Dynamodb创build表？: 我想创build一个表，并希望使用Dynamodb（NodeJs）创build6-7列/属性。我创build了一个表，但我不能添加超过2个属性。我是这个平台的新手，任何人都可以帮助我在一个表中创build多个属性。

使用Node.js将数据从MSSQL传输到DynamoDB: 我正在尝试使用Node.js将数据从SQL服务器传输到DynamoDb sql.connect(config, function (err) { if (err) console.log(err); // create Request object var request = new sql.Request(); // query to the database and get the records request.query('SELECT Client, Brand FROM Client WHERE Brand = 6', function (err, recordset) { if (err) console.log(err); console.log('request exectued'); var itemProcessed = 0; // send records as a response recordset.forEach(function […]

AWS Lambda函数如何更新DynamoDB表中的所有logging？: 我正在使用需要运行DynamoDB表中的所有项目并更新某些属性的AWS Lambda函数（节点4.3）。我遇到的问题是如何让Lambda等待所有DynamoDB操作完成。 var async = require('async'); var aws = require('aws-sdk'); var doc = new aws.DynamoDB.DocumentClient(); exports.handler = (event, context, callback) => { doc.scan({ TableName: 'Occupations_dev' }, function (err, data) { console.log(data.Items.length); var funcs = []; data.Items.forEach(function (item) { funcs.push(function (cb) { item.Popularity = 0; doc.put({ TableName: 'Occupations_dev', Item: item }, function (err, data) { […]

Dynogels：使用OR比较的查询: 我正尝试将以下scans优化为单个scan （或query ）。我看到的唯一方法是使用DynamoDB使用OR比较器。我在我的应用程序中使用dynogels （fork of vogels ），但遗憾的是我没有意识到任何OR查询function。 let arrivals = yield Reservation.scan() .where('room').equals(room) .where('arrival').between(from, to) .execAsync().then((reply) => reply.Items.map((item) => item.get())); let departures = yield Reservation.scan() .where('room').equals(room) .where('departure').between(from, to) .execAsync().then((reply) => reply.Items.map((item) => item.get())); let combined = arrivals.concat(departures); return Promise.resolve(combined); build议的优化： return Reservation.scan() .where('room').equals(room) .where('arrival').between(from, to) .or.where('departure').between(from, to) .execAsync().then((reply) => reply.Items.map((item) => item.get())); […]

NodeJS API通过ID获取。如何检测项目未find？: 我正在开发一个GET端点来从数据库（dynamoDB）中获取元素。我使用Swagger在我的api中定义数据模型。这是我的控制器中的operationId方法： getInvoiceConfigById: function(req, res) { var myId = req.swagger.params.id.value; // InvoiceConfig is a dynamoDb model // providerId attribute is the unique key of the db table InvoiceConfig.scan('providerId') .eq(myId) .exec(function (err, config) { if (err) { console.log("Scan InvoiceConfig error"); throw err; } res.status(200).send(config); }); } 如果找不到id，我想发送404消息。我在swagger-ui中注意到响应的主体是空的 Response Body [] 当在数据库中找不到id时。如何在我的代码中检测到ID未find时？我试图检查响应的主体是否为空：如果（！（config.body）） […]

Nodejs错误：读取ECONNRESET: 我在我的一个应用程序中使用Nodejs进行web套接字通信。这个应用程序定期发送用户数据到AWS dynamodb。我得到了很多新的文物更改与下面stacktace： Error: read ECONNRESET at exports._errnoException (util.js:856:11) at TLSWrap.onread (net.js:545:26) / 我只是想了解为什么发生这个TLSWrap错误。提前致谢