CloudWatch事件触发Amazon Transbe事件

Question

我正在使用Amazon Transcripbe服务，并试图让CloudWatch事件激发一个Lambda函数，该函数执行对我的API的POST请求。

下面是Lambda函数

var querystring = require('querystring');
var http = require('http');

exports.handler = function(event, context) {


    var post_data = querystring.stringify(
        event
    );

    // An object of options to indicate where to post to
    var post_options = {
        host: '193e561e.ngrok.io',
        port: '80',
        path: '/api/lambda',
        method: 'POST',
        headers: {
            'Content-Type': 'application/x-www-form-urlencoded',
            'Content-Length': Buffer.byteLength(post_data)
        }
    };

    // Set up the request
    var post_req = http.request(post_options, function(res) {
        res.setEncoding('utf8');
        res.on('data', function(chunk) {
            console.log('Response: ' + chunk);
            context.succeed();
        });
        res.on('error', function(e) {
            console.log("Got error: " + e.message);
            context.done(null, 'FAILURE');
        });

    });

    // post the data
    post_req.write(post_data);
    post_req.end();

}

我已经将CloudWatch事件配置为监听Amazon Transcripbe服务，特别是监听作业状态更改为completed或failed。

'version' => '0',
  'id' => '1fa5cca6-413f-4a0f-0ba2-66efa49c247e',
  'detail-type' => 'Transcribe Job State Change',
  'source' => 'aws.transcribe',
  'account' => '405723091079',
  'time' => '2019-11-19T19:04:25Z',
  'region' => 'eu-west-1',
  'detail' => NULL,

这是我认为我的应用程序工作的唯一方式，转录作业是通过亚马逊转录服务调用的，然后当它完成时，点击我的API来更新我的应用程序中必要的模型，但如果没有获得转录作业名称，它就不会工作。

任何建议都很感激。

Answer 1

根据你最新的问题，我怀疑你的问题实际上是在这里：

var post_data = querystring.stringify(
    event
);

Querystring不支持嵌套对象，例如cloudwatch事件的detail块。更多信息：

• https://github.com/sindresorhus/query-string#user-content-nesting

var post_data = JSON.stringify(event);