将数据从 AWS lambda 推送到 Kinesis Firehose

Question

我有一个 apiGateway 端点，我正在向端点发送一些 post 请求。 apigateway 的集成类型是 lambda 函数。我希望 lambda 函数监听来自 apigateway 的 post 数据并将这些数据推送到 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();
    });
};

将数据从 AWS lambda 推送到 Kinesis Firehose

Push data from AWS lambda to Kinesis Firehose

aws-lambda

amazon-kinesis-firehose