AWS Certified Data Engineer Associate (DEA-C01)

1. A data engineer needs to ingest clickstream events from a website into AWS for real-time processing. The application generates approximately 5,000 records per second, and each record is 2 KB in size. The engineer needs to determine the minimum number of shards required for an Amazon Kinesis Data Stream. How many shards are needed?

2. A company is using Amazon Kinesis Data Streams to ingest sensor data. The default data retention period is not long enough for their recovery requirements. A data engineer needs to retain records in the stream for 10 days to allow replay in case of downstream failures. What is the correct action?

3. A data engineer is setting up an Amazon AppFlow flow to transfer sensitive customer PII data from Salesforce to Amazon Redshift. The security team requires that all data in transit and at rest must be encrypted with customer-managed keys. The flow must also mask specific fields (such as credit card numbers) before loading into Redshift. Which combination of AppFlow features satisfies both requirements?

4. A data engineer is building an AWS Glue job that reads from Amazon DynamoDB and writes to Amazon S3. The DynamoDB table has 50 million items and is heavily used by production applications during business hours. The engineer wants the Glue job to read all 50 million items without impacting production performance. What is the most appropriate approach?

5. A data engineering team is designing a new Amazon Redshift cluster to store sales transaction data. The fact table has 500 million rows and is frequently joined to a dimension table that has only 200 rows. Which distribution style should the team use for the dimension table to minimize data movement during joins?