Uso de AWS Lambda con Amazon Kinesis Data Firehose - AWS Lambda

Uso de AWS Lambda con Amazon Kinesis Data Firehose

Amazon Kinesis Data Firehose captura, transforma y carga datos de streaming en servicios posteriores como Kinesis Data Analytics o Amazon S3. Es posible escribir funciones de Lambda para realizar un procesamiento adicional personalizado de los datos antes de enviarlos a los servicios posteriores.

ejemplo Evento de mensaje de 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": "" } } ] }

Para obtener más información, consulte Transformación de datos de Amazon Kinesis Data Firehose en la Guía para desarrolladores de Kinesis Data Firehose.