节点能够发出http请求节点js aws lambda

Question

我正在尝试编写一个 lambda 函数，该函数将对在我的 pod 的 ec2 实例中运行的服务的端点进行 3 次 http 调用， aws lambda 将由我配置的 cron 触发， 在配置 aws lambda 时，我还在网络设置中添加了 VPC。

我正在使用 node.js 8.10 来编写我的 lambda 处理函数，这是我的 lambda 处理函数的代码

'use strict';

var http = require('http');

exports.handler = async (event) => {
  http.get('url1', function(res) {
    console.log("Got response: " + res.statusCode);

  }).on('error', function(e) {
    console.log("Got error: " + e.message);

  });
  http.get('url2', function(res) {
    console.log("Got response: " + res.statusCode);

  }).on('error', function(e) {
    console.log("Got error: " + e.message);

  });
  http.get('url3', function(res) {
    console.log("Got response: " + res.statusCode);

  }).on('error', function(e) {
    console.log("Got error: " + e.message);

  });

  console.log('end request to');
}

我也试过了

'use strict';

var http = require('http');

exports.handler = async (event,context) => {
  http.get('url1', function(res) {
    console.log("Got response: " + res.statusCode);
    context.succeed();
  }).on('error', function(e) {
    console.log("Got error: " + e.message);
   context.done(null, 'FAILURE');
  });
  http.get('url2', function(res) {
    console.log("Got response: " + res.statusCode);
    context.succeed();
  }).on('error', function(e) {
    console.log("Got error: " + e.message);
   context.done(null, 'FAILURE');
  });
  http.get('url3', function(res) {
    console.log("Got response: " + res.statusCode);
    context.succeed();
  }).on('error', function(e) {
    console.log("Got error: " + e.message);
   context.done(null, 'FAILURE');
  });

  console.log('end request to');
}

但在这两种情况下我都得到了这个：

START RequestId: 0fa5225f-a54f-11e8-85a9-83174efb4714 Version: $LATEST
2018-08-21T14:32:41.855Z    0fa5225f-a54f-11e8-85a9-83174efb4714    end request to
END RequestId: 0fa5225f-a54f-11e8-85a9-83174efb4714
REPORT RequestId: 0fa5225f-a54f-11e8-85a9-83174efb4714

我参考this回答

有什么原因导致它不工作吗？

Answer 1

利用（更新的）async/await 功能，并减少样板文件，您可以这样提出您的要求：

const get = async (requestUrl) => {
    return new Promise((resolve, reject) => {
        http.get(requestUrl, function(res) {
            console.log("Got response: " + res.statusCode);
            resolve(res);
        }).on('error', function(e) {
            console.log("Got error: " + e.message);
            reject(e);
        });
    });
}

在您的 lambda 文件中定义该函数，然后您可以在处理函数中调用它，如下所示：

const response1 = await get('url1');

那么你的 lambda 应该可以正常运行了。

有关在 AWS Lambda 中使用 async 函数的更多信息，请参阅 this blog post 从他们将 Node.js 8.10 运行时引入 AWS Lambda（因此允许 async/await 功能）。