A media company is building a telemetry platform to ingest and transform clickstream data from its mobile application. The data stream averages and spikes up to during peak hours. The company requires that the data be converted from JSON to Apache Parquet format, partitioned by date, and stored in Amazon S3. The latency from ingestion to S3 must not exceed 5 minutes (). The architecture must be high-performing and require minimal operational overhead. Which two actions should a solutions architect recommend to meet these requirements?
- Create an Amazon Kinesis Data Firehose delivery stream to ingest the data, and enable data format conversion to Apache Parquet using the AWS Glue Data Catalog.Cevap
- Configure the Kinesis Data Firehose delivery stream with a buffer interval of 300 seconds and direct the output to the destination Amazon S3 bucket.Cevap
- CDeploy an Amazon Kinesis Data Stream with a single provisioned shard to ingest the stream sequentially before routing it to the S3 bucket.
- DIngest the clickstream data into an Amazon SQS Standard queue to decouple the ingestion tier and guarantee the chronological order of user events.
- EStore the incoming unconverted clickstream data in an Amazon S3 bucket using the S3 Standard-Infrequent Access (S3 Standard-IA) storage class to optimize storage costs before a weekly batch conversion job.
Cevap
Create an Amazon Kinesis Data Firehose delivery stream to ingest the data and configure it to perform format conversion to Apache Parquet using AWS Glue, then set the buffer interval to 300 seconds to write the files to the target Amazon S3 bucket.
The correct solution involves creating an Amazon Kinesis Data Firehose delivery stream configured to perform inline conversion of incoming JSON data to Apache Parquet format using the AWS Glue Data Catalog. By setting the buffer interval to 300 seconds, the delivery stream ensures the transformed data is written to the destination S3 bucket within the required 5-minute latency window without manual operational management.
Adım Adım Çözüm
Anahtar Kavram
Serverless data ingestion and real-time transformation using Kinesis Data Firehose and AWS Glue.
Tahmini Süre:2m 0s