AWS Lambda를 Amazon Kinesis Data Firehose와 함께 사용 - AWS Lambda

AWS Lambda를 Amazon Kinesis Data Firehose와 함께 사용

Amazon Kinesis Data Firehose는 스트리밍 데이터를 캡처하고 변환하여 Kinesis Data Analytics 또는 Amazon S3 등과 같은 다운스트림 서비스에 로드합니다. 다운스트림으로 보내기 전에 함수를 작성하여 추가로 사용자 지정된 데이터 처리를 요청할 수 있습니다.

예 Amazon Kinesis Data Firehose 메시지 이벤트

{ "invocationId": "invoked123", "deliveryStreamArn": "aws:lambda:events", "region": "us-west-2", "records": [ { "data": "SGVsbG8gV29ybGQ=", "recordId": "record1", "approximateArrivalTimestamp": 1510772160000, "kinesisRecordMetadata": { "shardId": "shardId-000000000000", "partitionKey": "4d1ad2b9-24f8-4b9d-a088-76e9947c317a", "approximateArrivalTimestamp": "2012-04-23T18:25:43.511Z", "sequenceNumber": "49546986683135544286507457936321625675700192471156785154", "subsequenceNumber": "" } }, { "data": "SGVsbG8gV29ybGQ=", "recordId": "record2", "approximateArrivalTimestamp": 151077216000, "kinesisRecordMetadata": { "shardId": "shardId-000000000001", "partitionKey": "4d1ad2b9-24f8-4b9d-a088-76e9947c318a", "approximateArrivalTimestamp": "2012-04-23T19:25:43.511Z", "sequenceNumber": "49546986683135544286507457936321625675700192471156785155", "subsequenceNumber": "" } } ] }

자세한 내용은 Kinesis Data Firehose 개발자 안내서의 Amazon Kinesis Data Firehose 데이터 변환을 참조하십시오.