在异步AWS Lambda函数中使用带有node-fetch模块的node.js时出现问题

ben*_*ich 7 javascript asynchronous node.js aws-lambda node-fetch

这就是我想要做的:我有一个由 webhook 触发的 lambda 函数,该函数将处理该数据并使用它向 api 发出 POST 请求。

我正在使用 Node.js 12 和 node-fetch 模块。

现在该函数已正确触发,但第一次调用时不会发送 POST。但如果我在短时间内重复触发 lambda 函数,第一个之后的请求就会通过。

以下是 lambda 函数的 index.js 文件中的代码:

const fetch = require('node-fetch');

exports.handler = async (event) => {

    sendPost();

    const response = {
        statusCode: 200,
        body: "Ok",
    };

    return response;
};


function sendPost() {

    const url = "http://requestbin.net/r/vjv4mvvj";

    const body = {
        foo: "foo",
        bar: "bar",
        baz: "baz"      
    };

    const params = {
        method: "POST",
        mode: "cors",
        headers: {"Content-Type":"application/json"},
        body: JSON.stringify(body)
    };

    fetch(url, params);

}
Run Code Online (Sandbox Code Playgroud)

当我删除(event)前面的async时,请求第一次通过,但首先发送 webhook 的服务器没有得到响应。

所以基本上我需要在每次调用函数时发送 POST,并且还能够返回 200 状态代码。

我没有太多使用异步的经验,所以我知道它与此相关,但我正在摸不着头脑。

Aru*_*han 12

获取返回一个承诺,您需要一个await. 您还需要将该sendPost函数标记为async. 您还需要处理函数来等待sendPost函数完成。

const fetch = require('node-fetch');

exports.handler = async (event) => {

    await sendPost();

    const response = {
        statusCode: 200,
        body: "Ok",
    };

    return response;
};


async function sendPost() {

    const url = "http://requestbin.net/r/vjv4mvvj";

    const body = {
        foo: "foo",
        bar: "bar",
        baz: "baz"      
   };

    const params = {
        method: "POST",
        mode: "cors",
        headers: {"Content-Type":"application/json"},
        body: JSON.stringify(body)
    };

    await fetch(url, params);
}
Run Code Online (Sandbox Code Playgroud)