19

我有以下 Lambda 函数代码：

console.log('Loading function');
var aws = require('aws-sdk');
var ddb = new aws.DynamoDB();

function getUser(userid) {
    var q = ddb.getItem({
        TableName: "Users",
        Key: {
            userID: { S: userid } }
        }, function(err, data) {
            if (err) {
                console.log(err);
                return err;
            }
            else {
                console.log(data);
            }
    });
    console.log(q);
}


exports.handler = function(event, context) {
    console.log('Received event');
    getUser('user1');
    console.log("called DynamoDB");
    context.succeed();
};

我有一个 [Users] 表，其定义如下：

{
    "cognitoID": { "S": "token" },
    "email": { "S": "user1@domain.com" },
    "password": { "S": "somepassword" },
    "tos_aggreement": { "BOOL": true },
    "userID": { "S": "user1" }
}

当我调用该函数（从 AWS 控制台或 CLI）时，我可以在日志中看到消息，但从未调用 getItem() 的回调。

我尝试在没有回调的情况下执行 getItem(params)，然后定义了完成、成功和失败的回调，但是当我执行 send() 时，甚至也不调用完成回调。

我知道调用是异步的，我想也许 lambda 函数在查询完成之前就完成了，因此不会调用回调，但是，我在函数末尾添加了一个简单的愚蠢循环，并且调用定时3 秒后退出，根本没有调用回调。

我尝试了不同的函数 batchGetItem、getItem、listTables 和扫描。结果是一样的，没有错误，但回调函数永远不会被调用。

我敢打赌，如果我在不使用 Lambda 的情况下查询 dynamoDB，它会得到结果，所以我真的很想知道为什么这里什么都没有发生。

我为该函数创建了一个角色，并创建了一个策略，允许访问我需要但无济于事的 dynamoDB 中的功能。

该政策如下所示：

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "lambda:InvokeFunction"
            ],
            "Resource": "arn:aws:lambda:*:*:*"
        },
        {
            "Effect": "Allow",
            "Action": [
                "dynamodb:GetItem",
                "dynamodb:BatchGetItem",
                "dynamodb:Scan",
                "dynamodb:PutItem",
                "dynamodb:Query",
                "dynamodb:GetRecords",
                "dynamodb:ListTables"
            ],
            "Resource": "arn:aws:dynamodb:*:*:*"
        },
        {
            "Action": [
                "logs:*"
            ],
            "Effect": "Allow",
            "Resource": "*"
        }
    ]
}

我在模拟器中运行了策略，它按我想的那样工作。建议？

4

6 回答 6

19

所以，事实证明代码是正确的。问题是 dynamodb API 使用所有这些回调，并且基本上该函数在数据被检索之前结束。

最快的解决方法是删除context.succeed()呼叫并检索数据。当然使用 async 模块会有所帮助，如果您不想使用它，只需在回调中添加一个计数器或布尔值，然后等到值发生更改，表明回调已被调用（哪种很烂如果你想到它）

于 2015-06-09T23:13:19.733 回答
6

我有一些类似的问题，并没有找到很多有用的资源。这就是我最终做的事情。也许更聪明的人可以告诉我们这是否是最好的。

function getHighScores(callback) {
    var params = {
        TableName : 'sessions',
        ScanFilter: {"score":{"AttributeValueList":[{"N":"0"}], "ComparisonOperator":"GT"}},
    };
    var dynamo = new AWS.DynamoDB();
    dynamo.scan(params, function(err, data) {
        if (err) {
            console.log (err)
            callback(err);
        } else {
            callback(data.Items);
            console.log(data.Items);
        }
    });
} 



getHighScores(function (data) {
    console.log(data);
    context.succeed(data);
});

总之，通过主函数将回调回传给较小的函数，可以让应用程序继续运行，直到完成 Dynamo。将 context.succeed 保留在辅助功能中或在那里继续其他功能。

于 2015-10-29T00:01:28.967 回答
2

我的问题是我的 lambda 在 VPC 中运行以便连接到 ElastiCache。这会导致对公共 Internet 资源（例如 DynamoDB 和 API Gateway）的任何查询无限期挂起。我必须在我的 VPC 中设置一个 NAT 网关才能访问 DynamoDB。

于 2017-02-04T00:30:38.120 回答
2

我的问题是我试图调用的函数接受了回调。

因此，Node.js 只是继续执行 Lambda 函数，一旦到达终点，它就会告诉 Lambda 关闭，因为它已经完成了。

这是一个如何使用Promises解决它的示例：

'use strict';

exports.handler = async (event, context) => {

  // WRAP THE FUNCTION WHICH USES A CALLBACK IN A PROMISE AND RESOLVE IT, WHEN
  // THE CALLBACK FINISHES

  return await new Promise( (resolve, reject) => {

    // FUNCTION THAT USES A CALLBACK
    functionThatUsesACallback(params, (error, data) => {
      if(error) reject(error)
      if(data) resolve(data)
    });

  });

};
于 2020-02-20T09:28:27.390 回答
1

现在，由于 node.js 引入了 async/await，这可以让它等到查询调用返回，然后主函数终止：

let result = await ddb.getItem(params).promise();
return result;
于 2019-08-11T21:27:17.083 回答
0

为了避免回调地狱，请使用 Promises。youtube 上有一些非常不错的教程，作者叫做 funfunfunction。

于 2016-07-21T05:29:07.963 回答