将数据从AWS lambda推送到Kinesis Firehose

Question

我有一个apiGateway端点,我正在向端点发送一些发布请求.apigateway的集成类型是lambda函数.我希望lambda函数能够监听apigateway上发布的数据并将这些数据推送到kinesis firehose.

任何人都可以帮我获取一个示例节点js lambda代码,将传入的数据推送到kinesis firehose.我试图搜索这个,但无法得到任何东西.

谢谢

Answer 1

我知道了.

这是一个示例代码:

var AWS = require('aws-sdk');
var firehose = new AWS.Firehose();

exports.handler = function(event, context) {
    var params = {
        DeliveryStreamName: <STRING>,
        Record: { 
            Data: decodeURIComponent(event)
        }
    };
    firehose.putRecord(params, function(err, data) {
        if (err) console.log(err, err.stack); // an error occurred
        else     console.log(data);           // successful response

        context.done();
    });
};