在 AWS Lambda 中侦听 Firebase 数据库超时

Question

我正在构建 Alexa 技能，这需要我收听 Firebase 实时数据库。在该技能的一个特定部分中，我需要向 Firebase 写入一个 JSON 对象，该对象由两个字段组成，“intent”，具有一个无关紧要的值，“done”，其值为false。

然后，我等待另一个侦听此数据库的设备注册此更改，此时它会创建另一个名为“result”的字段，其中包含一些数值，并将“done”的值更改为 true。

那么原函数（test1）应该识别“done”的值为真，然后检索“result”的值。

我遇到的问题是想出一个函数，该函数在我的主（异步）函数完成之前执行所有这些读/写操作。正如标题所示，AWS Lambda 出于某种原因超时，我无法读取“结果”的值。

这是我正在使用的功能：

function test1(intentName, targetRef, context) {
    console.log("writing");
    targetRef.set({
        intent: intentName,
        done: false
    }).then(function() {
        return targetRef.orderByChild("done").equalTo(true).on("value");
    }).then(function(snapshot) {
        var res = snapshot.val().result;
        console.log("Res: " + res);
        context.succeed( //context.succeed should be called after "result" has a value.
            generateResponse(
                buildSpeechletReponse("The result is" + processNumbersForSpeech(res), true),
                {}
            )
        );
    });
}

这是控制台的输出（在 AWS Lambda 中）：

    
20:05:31
START RequestId: a25d2354-d9cb-11e6-b80a-f35142a5f45f Version: $LATEST
20:05:31
2017-01-13T20:05:31.464Z    a25d2354-d9cb-11e6-b80a-f35142a5f45f    writing

20:05:35
END RequestId: a25d2354-d9cb-11e6-b80a-f35142a5f45f

20:05:35
REPORT RequestId: a25d2354-d9cb-11e6-b80a-f35142a5f45f  Duration: 4001.15 ms    Billed Duration: 4000 ms Memory Size: 128 MB    Max Memory Used: 39 MB

20:05:35
2017-01-13T20:05:35.335Z a25d2354-d9cb-11e6-b80a-f35142a5f45f Task timed out after 4.00 seconds

以下是 Firebase 数据的结构：

“完成”最初是错误的。当其他设备添加“result”时，它也会将“done”的值更新为true。 “148434459...”是 targetRef。

非常感谢您的帮助。如果需要，我会提供更多信息。

Answer 1

问题是on 没有返回承诺。相反，它返回作为参数传递的回调函数。 on 将为初始数据调用回调，然后为对数据所做的任何更改再次调用。

你很可能想使用once，它确实会返回一个承诺：

...
}).then(function () {
    return targetRef.orderByChild("done").equalTo(true).once("value");
}).then(function (snapshot) {
    snapshot.forEach(function (childSnapshot) {
        console.log(childSnapshot.val());
    });
})
...

请注意，promise 的已解析快照将包含零个或多个与查询匹配的子项。要枚举孩子，可以使用快照的forEach 方法。

Answer 2

我发现在 lambda 函数（例如通过 firebase-admin）中初始化 firebase 会阻止函数终止（直到默认的 6 秒超时），除非您在 firebase 应用实例上调用 app.delete()。此外，您应确保每次运行 lambda 函数时都使用新的 firebase 应用程序实例，否则您会遇到问题。

const app = admin.initializeApp({});
app.database().ref('child').set('hello').then(() => {
  return app.delete();
}).then(() => {
  let response = {}; // whatever
  callback(null, response);
});

Answer 3

您的 Lambda 函数可能会在 4 秒后超时，因为您在配置 Lambda 函数时设置了此值。为了让您的函数等待外部事情发生，您可以安排一个函数定期使用 setTimeout() 查询该值，直到该值存在。如果这需要超过 4 秒，您还需要增加函数超时时间。

Answer 4

来自 AWS Lambda 文档：

问：AWS Lambda 函数可以执行多长时间？

对 AWS Lambda 的所有调用必须在 300 秒内完成执行。默认超时为 3 秒，但您可以将超时设置为 1 到 300 秒之间的任何值。

我建议您在尝试从 Lambda 函数内部等待 Firebase 事件时会遇到问题。 Lambda 被设计为使用数据调用并处理数据并退出，而不是等待其他事件发生。你最好使用某种 VPS 并运行一个通用的 Node 进程来完成数据库工作。 Lambda 将数据推送到 Firebase 很好，但您尝试使用 Firebase 实现的目标可能是错误的方法。

Answer 5

您在调用另一个函数之前调用该函数。试试 npm sleep() 或 setTimeout() 让你的函数暂停一下。