Push-Daten von AWS Lambda zu Kinesis Firehose

Question

Ich habe einen API-Gateway-Endpunkt und ich sende einige Post-Anfrage an den Endpunkt. Der Integrationstyp für den Apigateway ist Lambda-Funktion. Ich möchte, dass die Lambda-Funktion die Postdaten, die auf dem Apigateway ankommen, abgehört und diese Daten zu Kinesis Firehose überträgt.

Kann jemand mir helfen, einen Beispielknoten js Lambda-Code zu bekommen, der die ankommenden Daten zu kinesis firehose drückt. Ich habe versucht, danach zu suchen, konnte aber nichts bekommen.

Danke

Answer 1

Ich habe es.

Dies ist ein Beispielcode:

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(); 
    }); 
};