如何从AWS DynamoDB中的函数返回查询结果-JS lambda

Question

我有一个愚蠢的问题，让我发疯。我有一个AWS lambda函数，可以调用Dynamo db。

我想有ddb.Scan操作成一个函数得到的结果，然后将它传递给事件，但我不能返回结果的函数内部...

var aws = require('aws-sdk'); 
var ddb = new aws.DynamoDB(); 

function getName(userid) { 

ddb.scan({ 
     TableName: "Users", 
     ScanFilter: { 
      "userid": 
        { 
         "AttributeValueList": [ 
          {"S": userid} 
         ], 
         "ComparisonOperator": "EQ" 
        } 
     } 
    }, function (err, data) { 
     return data.Items[0].username; 
    }); 

}; 

exports.handler = function (event, context) { 

     var userid= '4vwe6jd56es59q'; 

     var username = getName(userid); 

     context.succeed({success: true, username: username}); 


}; 

有人可以帮助我了解我迷路的地方？

Answer 1

注意如何声明此功能：

function getName(userid) { 

这里的另一个功能：

function (err, data) { 

这是第二个功能，即你正在试图返回的东西，但没有什么期待该功能返回任何东西，所以返回值被丢弃。

请注意，对ddb.scan()的调用立即返回，并且在检索到DynamoDB响应后稍后调用传递给ddb.scan()的匿名回调函数。这是一个基本的异步编程概念，在成功编写NodeJS代码之前，您必须先了解它。您需要将回调函数传递给您的函数，该函数只要具有名称值即可调用该函数，或者您可能需要重新考虑完全设计Lambda函数的方式。

我还建议使用AWS Lambda上提供的最新版本的NodeJS，以便您可以使用promise而不是回调函数，这使得使用异步函数更容易一些。

Answer 2

我注意到你的代码的第一件事是你的getName函数实际上并不返回任何东西，所以即使扫描函数按预期工作，它也会返回null。

更重要的是，ddb.scan(...)是一个异步函数，因此，您必须在回调中嵌入想要完成的所有内容（在本例中为扫描结果）。

这意味着你的代码应该看起来更像是这样的：

var aws = require('aws-sdk'); 
var ddb = new aws.DynamoDB(); 

exports.handler = function (event, context) { 
     var userid= '4vwe6jd56es59q'; 
     var username = getName(userid); 

    ddb.scan({ 
     TableName: "Users", 
     ScanFilter: { 
      "userid": 
        { 
         "AttributeValueList": [ 
          {"S": userid} 
         ], 
         "ComparisonOperator": "EQ" 
        } 
     } 
    }, function (err, data) { 
     var username = data.Items[0].username 
     context.succeed({success: true, username: username}); 
    }); 
}; 

注意context.succeed现在已嵌入异步回调中，这样，只有当数据已经返回的数据传递。