AWSラムダのデータをKinesis Firehoseにプッシュ

Question

私はapiGatewayエンドポイントを持っており、エンドポイントに何らかの投稿要求を送信しています。 apigatewayの統合型はラムダ関数です。私は、ラムダ関数がapilotwayに来るポストデータを聞き、そのデータをkinesis firehoseにプッシュすることを望みます。

誰も私がkinesis firehoseに着信データをプッシュするサンプルノードのjsラムダコードを手に入れることができますか？私はこれを検索しようとしましたが、何も得られませんでした。

ありがとうございました

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