AWS 람다에서 Kinesis Firehose로 데이터 푸시

Question

apiGateway 엔드 포인트가 있으며 엔드 포인트에 대한 게시물 요청을 보내고 있습니다. apigateway에 대한 통합 유형은 람다 함수입니다. 나는 람다 함수가 apilotway에서 오는 포스트 데이터를 듣고 kinesis firehose로 그 데이터를 밀어 넣기를 원합니다.

누구든지 들어오는 데이터를 kinesis firehose로 밀어 넣을 샘플 노드 js lambda 코드를 얻을 수 있도록 도와 줄 수 있습니까? 나는 이것을 찾으려고했지만 아무 것도 얻을 수 없었다.

감사합니다.

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