AWS Lambda を Amazon Kinesis Data Firehose に使用する - AWS Lambda

AWS Lambda を Amazon Kinesis Data Firehose に使用する

Amazon Kinesis Data Firehose は、ストリーミングデータをダウンストリーミングサービス (例: Kinesis Data Analytics または Amazon S3) にキャプチャ、変換、またはロードします。Lambda 関数を作成して、データがダウンストリームに送信される前に、カスタマイズされた処理を追加でリクエストできます。

例 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 のデータ変換」を参照してください。