DEA-C01 Exam Simulation 1 — 100 Questions

Question 1

A company uses Amazon Kinesis Data Firehose to ingest application logs into an Amazon S3 bucket. The logs are in JSON format. The data engineering team wants to convert the logs from JSON to Parquet format before landing in S3. What is the most cost-effective way to achieve this?

Choose an answer to begin — your selection is scored in the full session.

Accepted Answer

Configure the Firehose delivery stream to convert the data to Parquet using a schema from AWS Glue.. Kinesis Data Firehose can convert the input data format to Parquet using a schema from AWS Glue. Option A is incorrect because Athena queries raw data and would not help with ingestion. Option C is incorrect because Lambda can do this but would incur additional compute cost. Option D is incorrect because Glue ETL would add cost and latency.

Answer

Use Amazon Athena to query the JSON data and write results in Parquet format.

Answer

Use an AWS Lambda function to transform each record to Parquet and send to Firehose.

Answer

Use an AWS Glue ETL job to run on a schedule and convert JSON to Parquet in S3.

Question 2

A data engineering team uses Amazon Kinesis Data Analytics for Apache Flink to process streaming data. They notice that the application's checkpointing is failing intermittently, causing data reprocessing. The application uses a large state. Which configuration change should the team make to improve checkpoint reliability?

Accepted Answer

Increase the checkpointing interval.. Increasing the checkpointing interval reduces the frequency of checkpoint operations, giving the system more time to complete each checkpoint before the next one starts. This alleviates backpressure and resource contention, which is critical when dealing with large state, as checkpointing large state is I/O and CPU intensive and can fail if intervals are too tight.

Answer

Disable checkpointing to avoid failures.

Answer

Switch the state backend from in-memory to RocksDB.

Answer

Increase the parallelism of the application.

Question 3

A data engineer is troubleshooting a Kinesis Data Analytics application that processes streaming data. The application is falling behind and has a high 'MillisBehindLatest' metric. The application uses a parallelism of 2. The source stream has 4 shards. What is the MOST likely cause and solution?

Accepted Answer

The application parallelism is too low; increase it to 4.. The 'MillisBehindLatest' metric indicates the application is not keeping up with the incoming data. With a source stream of 4 shards and a parallelism of only 2, the application cannot process data from all shards concurrently, leading to backpressure. Increasing parallelism to match the shard count (4) allows each shard to be processed by a separate task, reducing lag.

Answer

The application is using a JSON format; switch to Avro.

Answer

The source stream has too many shards; decrease to 2.

Answer

The output destination is slow; change to a faster sink.

Question 4

A company is using Amazon DynamoDB with on-demand capacity for a gaming application that experiences unpredictable traffic spikes. The application consistently sees 'ProvisionedThroughputExceededException' errors during spikes. The data engineer needs to resolve this issue without changing the application code. What should the engineer do?

Accepted Answer

Switch the table to on-demand capacity mode. The application is already using on-demand capacity, but the error 'ProvisionedThroughputExceededException' indicates the table is actually in provisioned mode, not on-demand. Switching to on-demand capacity mode eliminates throttling by automatically scaling throughput to match traffic spikes, with no code changes required.

Answer

Enable DynamoDB Accelerator (DAX) to cache read requests

Answer

Increase the read capacity units

Answer

Enable auto scaling for the table with a higher maximum capacity

Question 5

A company is using Amazon S3 to store sensitive data. They need to automatically transition objects to S3 Glacier Deep Archive after 90 days and delete them after 7 years. Which S3 lifecycle configuration action should be used?

Accepted Answer

Transition. The S3 lifecycle 'Transition' action is specifically designed to move objects between storage classes. To automatically move objects to S3 Glacier Deep Archive after 90 days, you define a transition rule with a 'Days' value of 90 and a 'StorageClass' of 'DEEP_ARCHIVE'. This action directly meets the requirement for transitioning data to a colder storage tier.

Answer

AbortIncompleteMultipartUpload

Answer

Expiration

Answer

NoncurrentVersionExpiration

Question 6

A company is using Amazon RDS for SQL Server with Multi-AZ. The database has a 500 GB data file and 100 GB log file. The application experiences high latency during peak hours. Monitoring shows high WriteIOPS on the primary. Which change will reduce latency without losing the ability to failover?

Accepted Answer

Increase the provisioned IOPS on the RDS instance. The high WriteIOPS on the primary indicates that the storage layer is saturated, causing latency. Increasing provisioned IOPS on the RDS instance directly addresses the bottleneck by providing more I/O capacity, and since Multi-AZ is already enabled, the standby remains synchronized and failover capability is preserved.

Answer

Reduce the log file size by changing recovery model

Answer

Create a Read Replica in a different Availability Zone

Answer

Switch to Multi-AZ with two readable standbys

Question 7

A company is using Amazon RDS for MySQL with Multi-AZ deployment. The database experiences intermittent slowdowns during peak hours. The company's DevOps team suspects that the primary instance is overwhelmed. Which action should the team take to distribute the read load without changing the application code?

Accepted Answer

Create a read replica and modify the connection string to point to the replica for read queries.. Creating a read replica and modifying the connection string to point to the replica for read queries (Option B) offloads read traffic from the primary RDS instance without requiring application code changes. This directly addresses the intermittent slowdowns during peak hours by distributing the read load, leveraging MySQL’s native replication to keep the replica synchronized. The key constraint is 'without changing the application code,' which is satisfied by simply updating the connection string in the application configuration.

Answer

Increase the instance size of the RDS instance.

Answer

Enable Multi-AZ on the existing instance.

Answer

Configure DynamoDB Accelerator (DAX) in front of the RDS instance.

Question 8

Refer to the exhibit. A data engineer notices that the Redshift cluster 'mycluster' does not have automated backups beyond 7 days. However, the compliance team requires a minimum of 35 days of backup retention. What should the engineer do?

Accepted Answer

Modify the cluster's automated snapshot retention period to 35 days.. Amazon Redshift allows you to modify the automated snapshot retention period for a cluster up to 35 days. The engineer can use the AWS Management Console, CLI, or API to change the `automated_snapshot_retention_period` parameter from the current 7 days to 35 days, meeting the compliance requirement without additional manual intervention.

Answer

Change the node type to ra3.xlplus to enable automatic backups for 35 days.

Answer

Enable audit logging to capture changes for recovery.

Answer

Take manual snapshots every day and retain them for 35 days.

Question 9

A company is evaluating Amazon DynamoDB for a new application. The application requires single-digit millisecond latency for read and write operations. Which TWO DynamoDB features should the company enable to achieve this? (Choose TWO.)

Accepted Answer

Use DAX with Write-Through caching.. DAX with Write-Through caching ensures that every write to DynamoDB is also written to the DAX cache, so subsequent reads of the same item are served from the in-memory cache with single-digit millisecond latency. Option D is correct because DynamoDB Accelerator (DAX) is a fully managed, highly available, in-memory cache that reduces read response times from single-digit milliseconds to microseconds, directly meeting the latency requirement for read operations.

Answer

Enable DynamoDB Global Tables.

Answer

Enable DynamoDB Streams.

Answer

Enable auto-scaling for read and write capacity.

Question 10

A data engineer is designing a streaming pipeline that ingests data from an Amazon Kinesis Data Stream (with 5 shards) into Amazon S3. The data must be transformed using a complex stateful operation that cannot be done in a Lambda function (limited to 15 minutes). The engineer needs a solution that can maintain state across multiple records. Which service should be used?

Accepted Answer

Amazon Kinesis Data Analytics for Apache Flink. Amazon Kinesis Data Analytics for Apache Flink is the correct choice because it supports stateful stream processing with exactly-once semantics, can maintain state across multiple records, and has no 15-minute execution limit like AWS Lambda. It natively integrates with Kinesis Data Streams and can sink transformed data to S3, meeting all requirements for complex stateful operations.

Answer

Amazon EMR running Spark Structured Streaming

Answer

Amazon Kinesis Data Firehose with Lambda transformation

Answer

AWS Glue streaming ETL job

Question 11

A company is using AWS Glue to run ETL jobs that write data to an Amazon S3 data lake. The jobs are failing with '503 Slow Down' errors. The data engineering team has already implemented retries. What is the BEST long-term solution?

Accepted Answer

Implement a backoff strategy to reduce the request rate.. The '503 Slow Down' error from Amazon S3 indicates that the request rate is too high and S3 is throttling the requests. The best long-term solution is to implement a backoff strategy (exponential backoff) to reduce the request rate, which allows the Glue job to automatically slow down and retry with increasing delays, aligning with S3's request rate limits and avoiding sustained throttling.

Answer

Enable S3 Transfer Acceleration.

Answer

Use S3 multipart upload for all objects.

Answer

Increase the number of retries in the Glue job.

Question 12

A data engineer is evaluating storage options for a new application that requires low-latency access to unstructured blobs (up to 5 TB each) with high throughput. The data will be accessed frequently for the first 30 days and then rarely. Which TWO storage solutions meet these requirements? (Choose TWO)

Accepted Answer

Amazon S3 with lifecycle policies. Amazon S3 with lifecycle policies is correct because S3 provides low-latency access to unstructured blobs (up to 5 TB each) with high throughput, and lifecycle policies can automatically transition objects to colder storage tiers (e.g., S3 Glacier Deep Archive) after 30 days, matching the access pattern of frequent then rare access.

Answer

Amazon EBS with io2 Block Express volumes

Answer

Amazon EFS

Answer

Amazon RDS for PostgreSQL

Question 13

A company uses Amazon S3 as a data lake. A data engineer needs to ensure that all objects uploaded to the 'incoming' prefix are automatically encrypted at rest using AWS KMS with a specific customer managed key. What is the simplest way to enforce this?

Accepted Answer

Use a bucket policy that denies PutObject requests without the required encryption header.. A bucket policy with a condition that denies PutObject requests unless the request includes the required encryption headers (x-amz-server-side-encryption: aws:kms and x-amz-server-side-encryption-aws-kms-key-id with the specific customer managed key ARN) enforces encryption at rest using that key. Option A (S3 Transfer Acceleration) only optimizes transfer speed, not encryption at rest. Option C (S3 Inventory) reports on encryption status but does not enforce it. Option D (default encryption with SSE-S3) uses S3-managed keys, not a customer managed KMS key, so it does not meet the requirement.

Answer

Enable S3 Transfer Acceleration to force encryption in transit.

Answer

Configure S3 Inventory to report on encryption status and alert on non-compliance.

Answer

Enable default encryption on the bucket with SSE-S3.

Question 14

A company uses AWS Lambda to process records from an Amazon Kinesis Data Stream. Each record is about 50 KB. The Lambda function transforms the data and writes to Amazon DynamoDB. Recently, the Lambda function has been experiencing throttling and high error rates. The Kinesis stream has 10 shards. What is the most cost-effective solution to improve processing throughput?

Accepted Answer

Increase the Batch Window (MaximumBatchingWindowInSeconds) for the event source mapping.. Increasing the Batch Window (MaximumBatchingWindowInSeconds) allows the Lambda function to accumulate more records from the Kinesis stream before invoking the function, reducing the number of invocations and thus lowering the chance of throttling. This is the most cost-effective solution as it does not require additional shards, memory, or parallelization, and directly addresses the high error rates caused by excessive concurrent executions.

Answer

Increase the number of shards in the Kinesis stream.

Answer

Increase the Parallelization Factor for the Lambda event source mapping.

Answer

Increase the memory allocated to the Lambda function.

Question 15

Which THREE factors should a data engineer consider when choosing between Amazon RDS and Amazon DynamoDB for a new application? (Choose THREE.)

Accepted Answer

Requirement for ACID transactions across multiple tables.. Amazon RDS (with engines like PostgreSQL or MySQL) supports ACID transactions across multiple tables, ensuring atomicity, consistency, isolation, and durability for complex operations. DynamoDB, while supporting transactions, is limited to a single AWS account and region, and its transactional API has constraints on item sizes and throughput, making RDS the better choice for multi-table ACID compliance.

Answer

Ability to encrypt data at rest.

Answer

Support for multi-region disaster recovery.

Question 16

A company needs to transform JSON data from Amazon Kinesis Data Streams into Parquet format and store it in Amazon S3. The transformation includes simple field mappings and type conversions. Which approach is most cost-effective and serverless?

Accepted Answer

Use Amazon Kinesis Data Firehose with an AWS Lambda function for transformation and output to Parquet. Amazon Kinesis Data Firehose can directly deliver streaming data to Amazon S3 in Parquet format. By attaching an AWS Lambda function for simple field mappings and type conversions, you achieve a fully serverless, cost-effective solution without managing any infrastructure. This approach minimizes costs because you pay only for the data volume processed by Firehose and the Lambda invocations, avoiding the overhead of always-on compute resources.

Answer

Use Amazon EC2 instances running Apache Spark Streaming

Answer

Use Amazon SageMaker for transformation

Answer

Use an AWS Glue ETL job triggered by a Kinesis stream

Question 17

A data engineer is designing a data ingestion pipeline for a social media analytics platform. The pipeline must ingest tweets in real-time, perform sentiment analysis, and store results in Amazon S3. The sentiment analysis is compute-intensive and must be done as the data arrives. The estimated throughput is 10,000 tweets per second. Which architecture is most suitable?

Accepted Answer

Amazon Kinesis Data Streams with Amazon Kinesis Data Analytics for sentiment analysis, then Kinesis Data Firehose to S3.. The most suitable because Amazon Kinesis Data Streams can ingest up to 10,000 records per second per shard (with shard-level scaling), and Kinesis Data Analytics provides built-in, low-latency stream processing for compute-intensive sentiment analysis using SQL or Apache Flink. Kinesis Data Firehose then reliably buffers and writes the processed results to Amazon S3 without custom code, ensuring near-real-time delivery.

Answer

Amazon SQS with AWS Lambda pollers to process tweets and store in S3.

Answer

Amazon EMR with Spark Streaming to process tweets and write to S3.

Answer

Amazon API Gateway with AWS Lambda to process each tweet and store in S3.

Question 18

A data engineer needs to ingest data from an Amazon S3 bucket into Amazon Redshift for analytics. The data is in CSV format and the Redshift table already exists. Which service can be used to perform this ingestion with minimal configuration?

Accepted Answer

Amazon Redshift COPY command. The Amazon Redshift COPY command is the most direct and minimal-configuration method to load data from an S3 bucket into an existing Redshift table. It is purpose-built for bulk data ingestion from S3, supports CSV format natively, and requires only the table name, S3 path, IAM role, and format options — no additional services or pipelines needed.

Answer

AWS Glue

Answer

Amazon Kinesis Data Firehose

Answer

AWS Database Migration Service (DMS)

Question 19

A data pipeline using AWS Glue ETL jobs is failing intermittently with the error 'Rate exceeded' when writing to an Amazon Redshift cluster. Which action is MOST effective to resolve this issue?

Accepted Answer

Enable auto-tuning on the Redshift cluster and use concurrency scaling.. Enabling auto-tuning on the Redshift cluster and using concurrency scaling dynamically adds cluster capacity to absorb spikes in write requests, directly addressing the 'Rate exceeded' error. This error typically occurs when the Glue ETL job's write throughput exceeds the cluster's current capacity, and concurrency scaling provides additional query queues to handle the load without manual intervention.

Answer

Increase the timeout of the Glue ETL job to allow more time for retries.

Answer

Disable workload management (WLM) concurrency scaling in Redshift.

Answer

Change the output file format from Parquet to CSV to reduce write size.

Question 20

A healthcare company processes patient records in near-real-time using Amazon Kinesis Data Streams. Each record contains sensitive personal health information (PHI). The data must be encrypted at rest and in transit. The company also needs to audit access to the data. The data engineer is designing the ingestion pipeline. Which combination of services and configurations meets these requirements?

Accepted Answer

Use Kinesis Data Streams with SSE-KMS and TLS, and enable CloudTrail for data events.. Kinesis Data Streams supports server-side encryption (SSE) using AWS KMS for at-rest encryption, and TLS for in-transit. CloudTrail can log Kinesis API calls for auditing. Option A lacks encryption at rest. Option B lacks auditing. Option D is wrong because S3 does not replace Kinesis for streaming.

Answer

Use Kinesis Data Firehose to deliver data to S3 with SSE-S3, and enable CloudTrail for S3.

Answer

Use Kinesis Data Streams with TLS and enable CloudTrail for auditing. Do not enable SSE.

Answer

Use Kinesis Data Streams with SSE-KMS and TLS. Do not enable any auditing.