Free AWS Certified Data Engineer (DEA-C01) Practice Test 9

Free AWS Certified Data Engineer Associate Exam (DEA-C01) Practice Test 9 is for candidates chasing remote or hybrid data roles. Distributed teams still standardize on AWS, the most widely adopted cloud platform among companies worldwide, because one account can serve many offices. A DEA-C01 gives a remote hiring manager something objective to score. Certification benefits include easier cross-state screening, a credential that does not depend on one campus, and a cleaner path to job offers in AWS and data engineering outside your current city.

Location changes the offer, but the bands are a useful anchor. Junior data engineers often average about $72,000, with stronger entry pay toward $105,000. Mid-level data engineers often see $119,000 to $156,000. Senior data engineers often see about $147,000 to $181,000 or above. Employers that hire AWS data talent include Salesforce, Adobe, and Oracle.

SynergisticIT JOPP helps jobseekers get certified, prepared, and hired at top tech companies through our Job Placement programs — Java DevOps Full Stack JOPP and Data Science JOPP.

If you want to learn how to get hired as a Data Engineer, Data Scientist, Data Analyst, AI or ML engineer, or a software engineer, contact SynergisticIT for expert upskilling and marketing connections to companies. Use Contact Us and SynergisticIT JOPP.

Welcome to your AWS Data Engineer Associate – Test-09

Name

Phone

Q1. A data engineering team wants to implement fine-grained permissions for a data lake using Attribute-based Access Control (ABAC) and Lake Formation tag-based access control (LF-TBAC) in AWS. Which statement accurately describes the relationship between IAM ABAC and LF-TBAC in granting permissions?

Select 1 option(s):

IAM ABAC grants broad permissions to top-level resources, while LF-TBAC allows fine-grained access to specific data values within the resources. LF-TBAC relies on IAM policies for initial access.

IAM ABAC focuses on assigning LF-Tags to IAM principals, allowing access to specific resources based on tag matching. LF-TBAC grants access to IAM principals regardless of IAM policies.

IAM ABAC sets coarse-grained permissions, while LF-TBAC provides secondary, finer-grained access control to resources already accessible through IAM policies.

IAM ABAC and LF-TBAC work independently, requiring separate policies for access to data lake resources.

Q2. A data engineer working for an analytics company is working on a consumer to a Kinesis Data Streams application. They have written the consumer using Kinesis Client Library (KCL), however, currently they are receiving an ExpiredIteratorException when reading records from Kinesis Data Streams.

What would you recommend to the engineer to solve their issue?

Select 1 option(s):

Change the capacity mode of the Kinesis Data Stream to on-demand.

Increase WCU in DynamoDB checkpointing table.

Increase the amount of shards in Kinesis Data Streams.

Increase RCU in DynamoDB checkpointing table.

Q3. AWS CloudFormation is a tool for provisioning resources using either .yaml or .json templates.

Which of the following services utilize CloudFormation to provision its infrastructure/resources (SELECT TWO)?

Select 2 option(s):

AWS Cloud Development Kit (CDK)

AWS Lambda

AWS Serverless Application Model (SAM)

Amazon Elastic Container Service (ECS)

AWS Glue DataBrew

Q4. You are building a pipeline to process, analyze and classify images. Your image datasets contain images that you need to preprocess as a first step by resizing and enhancing image contrast. Which AWS service should you consider to use to preprocess the datasets?

Select 1 option(s):

AWS Step Functions

AWS Data Pipeline

AWS SageMaker Data Wrangler

AWS Glue DataBrew

Q5. A social media company currently stores 1TB of data within S3 and wants to be able to analyze this data using SQL queries. Which method allows the company to do this with the LEAST effort?

Select 1 option(s):

Use AWS Kinesis Data Analytics to query the data from S3

Use Athena to query the data from S3

Create an AWS Glue job to transfer the data to Redshift. Query the data from Redshift

Use Kinesis Data Firehose to transfer the data to RDS. Query the data from RDS

Q6. A solutions architect at a retail company is working on an application that utilizes SQS for decoupling its components. However, when inspecting application logs, they see that SQS messages are often being processed multiple times. What would you advise the architect to fix the issue?

Select 1 option(s):

Decrease the visibility timeout for the messages

Change the application to use long polling with SQS

Increase the visibility timeout for the messages

Change the application to use short polling with SQS

Q7. Which of the following services are capable of reading from AWS Kinesis Data Streams (SELECT THREE)?

Select 3 option(s):

Amazon Managed Service for Apache Flink

EFS

EC2

EMR

Q8. You are tasked with implementing a search solution for your organization‘s vast collection of technical documents. The solution should allow users to search for documents, retrieve related documents based on context, and apply custom search analyzers for domain-specific terms. Which AWS service is the most suitable choice for this use case, given the need for advanced text analysis and customizable search capabilities?

Select 1 option(s):

Amazon Comprehend

Amazon SageMaker

Amazon OpenSearch Service

Amazon Kendra

Q9. A financial company is giving its clients investment ideas. The data of which customer was given what idea on a particular date is stored on Amazon S3. Due to regulatory requirements, the company must implement an archival solution based on Amazon S3 Glacier with strict compliance control on data access.

As a data engineer, which of the following approaches would you suggest?

Select 1 option(s):

Use S3 Glacier to archive the investment data. Modify the S3 Access Control List (ACL) to satisfy compliance requirements.

Use S3 Glacier vault to archive the investment data. Modify the S3 Access Control List (ACL) to satisfy compliance requirements.

Use S3 Glacier Deep Archive storage to archive the investment data.

Use S3 Glacier vault to archive the investment data. Apply a vault lock policy to satisfy compliance requirements.

Q10. A company has a daily running ETL process, which processes transactions from a production database. The process is not time sensitive and can be run at any point of the day. Currently, the company is in the process of migrating the ETL job to an AWS Glue Spark job.

As a Certified Data Engineer, what would be the most cost-efficient way to structure the Glue ETL job?

Select 1 option(s):

Set the Glue to version 2.0

Set the execution class of the Glue job to FLEX

Set the execution class of the Glue job to STANDARD

Set the Glue job to use Spot instances

Q11. A data engineer at a social media company wants to enable their analysts to view visualizations of their clickstream data in near real-time. They also do not want to manage any of the underlying infrastructure. What would you recommend to the engineer to solve this problem?

Select 1 option(s):

Ingest clickstream data into Kinesis Data Streams, after which the data is written into Amazon Managed Service for Apache Flink (previously Kinesis Data Analytics). Flink is used to query the data into Quicksight for visualizations

Ingest clickstream data with AWS Lambda, which writes the data into S3, used as a source for Quicksight

Ingest clickstream data into Kinesis Data Streams, which is used to output the data into Quicksight for visualizations

Ingest clickstream data with Kinesis Data Streams, write data into EC2, and output data into Quicksight

Q12. A data engineer is tasked with importing data from an AWS RDS PostgreSQL to the company‘s AWS Lake Formation data lake. The task is to import data from all tables in the RDS database. The tables receive new data each night, and new data can also modify earlier rows as upsert statements. How should the data engineer set up a workflow from Lake Formation to achieve this goal?

Select 1 option(s):

Create the workflow from a Database snapshot blueprint

Create the workflow from a Log file blueprint

Create the workflow from an Incremental database blueprint

AWS Lake Formation only supports S3 as a source, so a workflow from RDS is not possible

Q13. A data engineer working for a retail company has been tasked to get some data for reporting needs from a PostgreSQL RDS database. The engineer has been asked to get all orders where the category of the product ends with either ‘ball‘ or ‘toy‘.

What SQL query would meet the requirements of the engineer?

Select 1 option(s):

Q14. An AWS Redshift table called purchases is storing customer purchases at an online retailer. A data engineer is tasked with moving less frequently accessed data from purchases to Amazon S3. Which of the following are necessary parts of a suitable SQL command meeting the requirements (SELECT THREE)?

Select 3 option(s):

MANIFEST VERBOSE

UNLOAD (‘select * from purchases‘)

TO ‘s3://mybucket/purchases_‘

UNLOAD (‘select * from purchases into s3://mybucket/purchases_‘)

IAM_ROLE ‘arn:aws:iam::0123456789012:role/MyRedshiftRole‘

COPY (‘select * from purchases‘)

Q15. A data engineer at an analytics company is attempting to fetch all items in a DynamoDB table with a size of 10 MB. However, when using the Scan DynamoDB API call, the result only gives a subset of all items each time.

What should the engineer do to fetch all items from the DynamoDB table?

Select 1 option(s):

Use a parallel Scan to get all results.

Use the Query DynamoDB API call, as Scan cannot return larger queries than 1 MB.

Use pagination with the Scan API call.

Increase the Limit parameter of the Scan API call.

Q16. Which of the following statements are CORRECT regarding AWS SQS (SELECT TWO)?

Select 2 option(s):

Message size is limited to 256KB

Messages cannot be duplicated

Messages will be delivered in order

Messages can be duplicated

Message size is limited to 128KB

Q17. A data engineer at a financial company is looking at an Amazon Redshift table called transactions comprising five columns: customer_id, orderdate, stock_id, amount, and buy_or_sell. Each row specifies a single stock transaction, either buy or sell, made by a specific customer on a certain date for a specific amount. A data analyst requires visualizing the trading days with the highest number of transactions for a dashboard. The amount of rows is large, and the query should be as fast as possible for the dashboard to be interactive.

Which combination of steps should the data engineer perform to satisfy the requirements from the data analyst (SELECT TWO)?

Select 2 option(s):

Q18. A video game company is using AWS Redshift for ingesting data about in-game events, actions, player sessions and purchases. In addition to continuous updates, the data engineering team at the company is pushing large batches of social media data obtained from a 3rd party vendor into tables in the Redshift database.

How can the team ensure that their batch updates do not cause inconsistencies or unexpected changes for the data analysts downstream using the data for reporting?

Select 1 option(s):

Use the SQL command LOCK with the batch updates.

Use the SQL command VACUUM before the batch update.

Use the SQL command EXECUTE with the batch updates.

Use the SQL command CREATE RLS POLICY with the batch updates.

Q19. A retail company has setup a DynamoDB table for their ecommerce platform, which contains all of their products. Their table is setup with ItemID as the partition key and the traffic to the website is relatively consistent. However, they have noticed, that for their most popular items, they are getting ProvisionedThroughputExceeded error message.

As a Certified Data Engineer, what would you recommend to the company to fix their issue?

Select 1 option(s):

Change the mode of the DynamoDB table to on-demand capacity mode.

Increase the WCU in the DynamoDB table.

Increase the RCU in the DynamoDB table.

Add a DAX cluster to the DynamoDB table.

Q20. A company has developed a complex machine learning model to predict the vulnerability of a customer. The model is running on a fleet of EC2 instances, and the payloads sent for the model can be up to 2MB. The company wants a method to stream payloads for the EC2 instances with the lowest possible latency.

As a Certified Data Engineer, what would you suggest to the company to meet their requirements?

Select 1 option(s):

Use Amazon Managed Streaming for Apache Kafka (MSK) to stream payloads. Consume messages from the EC2 instances.

Use Kinesis Data Streams to stream payloads. Consume messages using Kinesis API from the EC2 instances.

Use Kinesis Data Streams to stream payloads. Consume messages using the Kinesis Client Library (KCL) from the EC2 instances.

Use Kinesis Data Firehose to stream payloads to S3. Consume messages using S3 API from the EC2 instances.

Q21. The data science team at a retail company wants to transform their data before using it to train a classification model. The team needs to join datasets, encode categorical features, and balance datasets using oversampling. How can the team achieve this without writing any custom code?

Select 1 option(s):

Use AWS SageMaker JumpStart to process the data

Spin up an EMR cluster to process the data

Create an AWS Batch job to process the data

Use AWS SageMaker Data Wrangler to process the data

Q22. You are tasked with ensuring compliance for a set of critical AWS S3 buckets. Specifically, it must hold that all buckets tagged with the key “Critical“ have encryption enabled.

Which of the following options is the most appropriate in achieving this goal?

Select 1 option(s):

Create an AWS Config rule to check that each bucket tagged as “Critical“ has encryption. Set the rule evaluation trigger type to configuration changes.

Use AWS CloudTrail to detect changes to the encryption of buckets tagged as “Critical“.

Create an AWS Config rule to check that each bucket tagged as “Critical“ has encryption. Set the rule evaluation trigger type to hybrid.

Create an AWS Config rule to check that each bucket tagged as “Critical“ has encryption. Set the rule evaluation trigger type to periodic.

Q23. A company has set up a CloudTrail Lake for analyzing API calls across multiple AWS regions and AWS accounts. A data engineer want to use the CloudTrail Lake to analyze the number of API calls since January 1, 2023 until today by event name and event source. The CloudTrail Lake is missing a suitable event data store that needs to be created.

Which of the following statements are most appropriate to achieve these goals (SELECT TWO)?

Select 2 option(s):

Q24. A team of data analysts at a financial services company is tasked to set up a database for analytics applications. The underlying architecture of the database should be performant and be able to scale up-to petabytes of data. Which database software would you recommend to the team?

Select 1 option(s):

RDS

Redshift

DynamoDB

Q25. A data engineer is considering the use of blueprints for allowing the company data analysts to efficiently solve common extract, transform and load (ETL) problems.

Which of the following statements are true regarding AWS Glue blueprints (SELECT THREE)?

Select 3 option(s):

The blueprint comprises a layout generator script, a configuration file, and optional ETL scripts or other supporting files.

Workflows refer to a blueprint, so updating a blueprint updates all workflows created from it.

The blueprint layout, meaning its jobs, crawlers and their dependencies, must be defined through a Python script.

The maximum uncompressed size of the blueprint ZIP archive is 5 MB. The maximum compressed size is 1 MB.

The blueprint layout, meaning its jobs, crawlers and their dependencies, can be defined either visually or through a Python script.

Q26. A new member of a development team is ready to start contributing to a shared project of the team. The team has set up an AWS CodeCommit repository for the project.

Which combination of commands should the new member perform to obtain a local copy of the repository and to modify an existing file in the project (SELECT THREE)?

Select 3 option(s):

git checkout

git push

git branch

git pull

git clone

git commit

Q27. An edutech company runs an online learning platform with courses and exams. Student interactions update an Amazon DynamoDB table as they progress through grades. After completing a course, access to past educational materials decreases, but compliance mandates retaining data for 5 years. The large DynamoDB table, mostly holding rarely accessed data, hurting performance.

How should the company modify their current solution to increase cost-effectiveness and performance with the LEAST development time?

Select 1 option(s):

Assign a Time to Live (TTL) to each completed course in the DynamoDB table. Create a Lambda function with event filtering to be invoked on TTL deletions. Move the expired items to a new Amazon DynamoDB Standard-Infrequent Access table.

Create a Lambda function executed on a cron schedule to scan the DynamoDB table for completed courses. Move completed items to S3 as CSV files with the Standard-Infrequent storage class. Apply object lock in governance mode with a retention period of 5 years for the S3 bucket.

Create a Lambda function executed on a cron schedule to scan the DynamoDB table for completed courses. Move completed items to S3 as CSV files with the Standard-Infrequent storage class.

Q28. An e-commerce company is architecting a serverless AWS Lambda based solution for processing and analyzing user-generated data during flash sales events. The primary concern is efficient and scalable access to shared files containing flash sale product details. Considering this scenario, what is a key difference between using Lambda‘s ephemeral storage and mounting an Amazon EFS filesystem?

Select 1 option(s):

Lambda ephemeral storage is suitable for large datasets with high I/O requirements, while Amazon EFS is designed for temporary storage during Lambda execution.

Both Lambda ephemeral storage and Amazon EFS provide persistent, shared storage with similar performance characteristics.

Lambda ephemeral storage is temporary and shared among concurrent executions, while Amazon EFS offers persistent, shared storage accessible across multiple Lambda executions.

Lambda ephemeral storage is durable, while Amazon EFS provides better performance for concurrent read and write operations.

Q29. A gaming company is planning to release a new feature into their mobile gaming application. Based on user behaviour data and experience from their previous games, the company wants to automatically scale the storage of their backend Amazon RDS instance. Specifically, the company wants the RDS backend storage to scale such that when 15 % of space is free, the database storage scales up 25 % when its size is less than 1000 GB. If its size is between 1000 and 5000 GBs, it scales up by 15 %. Finally, if its size is over 5000 GB, it scales up by 5 %.

How can the company achieve this goal with the LEAST amount of operational overhead?

Select 1 option(s):

Create an AWS Lambda function that runs periodically to check the RDS storage space. If the free space is below the specified thresholds, trigger an AWS Step Functions workflow that scales the storage up accordingly.

Use CloudWatch to monitor the RDS database‘s free storage space. Send a notification to Amazon Simple Notification Service (Amazon SNS) when the free storage space is below the defined amount. Configure SNS to invoke an AWS Lambda function which modifies the RDS with the new storage size.

Configure Amazon RDS storage autoscaling with the specified thresholds and actions.

Implement an Amazon CloudWatch Events rule that triggers an AWS Lambda function based on a schedule. The Lambda function checks the RDS storage space and modifies the storage size if it falls below the specified thresholds.

Q30. A static code analysis tool has flagged the line of a source code file to contain hardcoded, plaintext username and password. To follow best practices, the data engineering team responsible for the source code wants to remove the hardcoded secrets and instead use an AWS solution to manage them. The team requires the secrets to be encrypted at rest and needs to be able to track and audit when the secrets are accessed. The team is also conscious about controlling costs.

Select 2 option(s):

Which combination of actions would be most appropriate for the team to achieve their goals (SELECT TWO)?

Audit and track when secrets are accessed using AWS CloudTrail.

Audit and track when secrets are accessed using AWS CloudWatch.

Create the username and password in AWS Secrets Manager.

Store the username and password in AWS Systems Manager Parameter Store as standard parameters.

Store the username and password in AWS Systems Manager Parameter Store as advanced parameters.

Q31. A gaming company has an AWS S3 bucket partitioned by year, month and day collecting data regarding microtransactions in Parquet format from their flagship mobile application. To control costs, the company recently implemented an S3 Lifecycle rule to move data older than 1 month to S3 Glacier storage class. However, after this change was implemented, some AWS Glue extract, transform and load (ETL) jobs became unstable and crashed with the following error statement:

java.io.IOException: com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.services.s3.model.AmazonS3Exception:
The operation is not valid for the object‘s storage class (Service: Amazon S3; Status Code: 403;
Error Code: InvalidObjectState; Request ID: ), S3 Extended Request ID: (1)
Which of the following actions should a data engineer take to fix this issue with the LEAST operational overhead?

Select 1 option(s):

The IAM role used for Glue must be modified to allow s3:ListBucket and s3:GetObject on the source S3 bucket.

The fetch size parameter should be set to a non-zero value to avoid caching the records in the Spark executor‘s memory.

The ETL script must be modified to exclude the Glacier storage class.

The S3 bucket should be split into two buckets such that one contains all the Glacier stored files. The ETL script does not need any modifications.

Q32. A data engineer working for a stock photo company wants to create a way to watermark all images when serving them to their trial customers. The solution should be able to add a watermark to images within an S3 bucket. What should the engineer implement to serve this need with the LEAST amount of operational overhead?

Select 1 option(s):

Create a Lambda RestAPI endpoint, which fetches an image from S3 and processes the image by adding a watermark. Point trial customers to the RestAPI endpoint.

Create an AWS Batch job to process all images within the S3 bucket by adding watermarks to images. Send processed images into a separate S3 bucket, and point trial customers to the bucket with the processed images.

Setup an S3 Object Lambda Access Point with a Lambda function to add watermarks to images. Point trial customers to the S3 Object Lambda Access Point.

Setup an S3 Event to process images with a Lambda function to add watermarks to images. Send processed images to a separate zone within the S3 bucket, and point trial customers to the processed zone within the bucket.

Q33. You are tasked to setup server-side encryption for an S3 bucket with customer-provided keys for encryption to enhance the security of an application. Which are the necessary steps that need to be taken to satisfy the requirements (SELECT TWO)?

Select 2 option(s):

Add S3 resource policy to allow S3 to use keys from AWS KMS

Encrypt the data before sending the data to the bucket

Use HTTPS when making requests to the bucket

Include the encryption headers when making requests to the bucket

Define keys to be used for the S3 bucket in AWS KMS

Q34. A media company is receiving hourly batches of social media posts into an Amazon S3 bucket. The bucket is configured to notify an AWS Lambda function of the creation of new data. The Lambda function uses AWS Comprehend for further analysis of the post and stores the output to Amazon DynamoDB. As it stands, the Lambda execution role has the following S3 permission:

{
“Version“: “2012-10-17“,
“Statement“: [
{
“Sid“: “ExampleStatementID“,
“Action“: [“s3:*],
“Effect“: “Allow“,
“Resource“: [“*“]
}
]
}
To follow security best practices, which combination of steps should the company take (SELECT TWO)?

Select 2 option(s):

Modify the Action to be “s3:GetObjectAttributes.“

Modify the Resource to be only the bucket ARN.

Append “s3:GetObject“ to the Action.

Modify the Action to be “s3:GetObject.“

Append the bucket name to the Resource.

Q35. A data engineering team wants to move their existing Python-based ETL script based the pandas library to the AWS cloud. The team wants a solution that is serverless and the workflow must be triggered by the arrival of new data into S3.

Which service(s) should the team use to achieve these goals with the LEAST operational overhead?

Select 1 option(s):

AWS Batch

AWS Step Functions with AWS Lambda

Amazon Managed Workflows for Apache Airflow (MWAA)

AWS Glue

Q36. A social media company has a database running in RDS within their private VPC in availability zone us-east-1a. The RDS database is running in the default port. They want to connect an EC2 instance within the same availability zone to the RDS database.

How should they configure their RDS security group for minimal necessary access to RDS from the EC2 instance?

Select 1 option(s):

Configure RDS security group to have ingress and egress all traffic from the security group of the EC2 instance on port 5432.

Configure RDS security group to have ingress and egress TCP from the security group of the EC2 instance on port 5432.

Configure RDS security group to have ingress all traffic from the security group of the EC2 instance on port 5432.

Configure RDS security group to have ingress TCP from the security group of the EC2 instance on port 5432.

Q37. A data engineer at a company is tasked with designing a data integration and transformation solution for the organization‘s data lake in AWS. The goal is to ensure efficient, automated, and scalable data ingestion and transformation workflows. Which AWS service is best suited for achieving this, offering capabilities for data cataloging, ETL job orchestration, and serverless execution?

Select 1 option(s):

AWS Glue

AWS Lambda

AWS Data Pipeline

AWS Step Functions

Q38. A retail company wants to use AWS Glue for Spark for its ETL jobs. What output data formats does AWS Glue NOT support?

Select 1 option(s):

Avro

RecordIO-Protobuf

XML

CSV

Parquet

Q39. A data engineer working in an analytics company has been tasked to migrate their Apache Cassandra database to AWS. What AWS service should the engineer use to migrate the database to AWS, with the LEAST amount of operational overhead?

Select 1 option(s):

Amazon DocumentDB

Amazon Neptune

Amazon Keyspaces

Amazon RDS

Q40. A data analyst at a social media company wants to create a new Redshift table from a query. What would you recommend to the analyst?

Select 1 option(s):

Use the SELECT INTO command on Redshift to query data and create a table from the results of the query

Use the CREATE TABLE command on Redshift to create a table from a given query

Use the COPY command on Redshift to create a table from a given query

Use the SELECT command on Redshift and save the intermediary results to S3. Use the COPY command to create a new table on Redshift from the S3 data

Q41. Which of the following statements are true regarding AWS Database Migration Service (DMS) (SELECT TWO)?

Select 2 option(s):

DMS supports BLOB transformations

You must create an EC2 instance to perform replication tasks

You do not have to manage the underlying servers to perform a replication task

The source database is not available during migration

DMS is capable of continuous data replication

Q42. A data engineer has set up an extract, transform, and load (ETL) AWS Glue job whose data source is an AWS S3 bucket. Which of the following are common reasons why the AWS Glue job might reprocess data even though job bookmarks are enabled (SELECT TWO)?

Select 2 option(s):

The job execution role lacks the necessary permissions to read from the source and write to the target.

The S3 bucket used as a data source has versioning enabled.

You have multiple concurrent jobs with job bookmarks, and the max concurrency is not set to 1.

The job.commit() object is missing.

The Glue job script is written in a language other than Python.

Q43. An analytics company currently stores their data within S3 and wants to deduplicate their data before sending it to be processed further. Which method allows them to remove duplicates with the least amount of development time?

Select 1 option(s):

AWS Glue job using PySpark

AWS Glue ML transforms job

Use native S3 deduplication feature

AWS Kinesis Data Firehose with a Lambda transformation to determine whether a file is a duplicate

Q44. A technology company is working on storing customer data in DynamoDB. To comply with data protection regulations, they are mandated to delete unused records after 3 years.

As a Certified Data Engineer, instruct the company on what is true regarding DynamoDB Time to Live (TTL) (SELECT TWO).

Select 2 option(s):

TTL attribute must be of type Number

TTL attribute must be of type Datetime

TTL consumes WCU

TTL attribute must be of type String

TTL does not consume WCU

Q45. A data engineer working for an analytics company has been tasked to create an EMR cluster for their company. They would like their cluster to be long-running and provisioned.

Which option would improve the cost-efficiency of the cluster without sacrificing performance?

Select 1 option(s):

Use Spot instances for Core nodes

Use EMR Serverless

Run EMR within a private VPC

Use Graviton instances for EMR

Q46. An analytics company wants to separate their raw data and processed data into separate S3 buckets, with automated triggers for processing of their raw data. Each time a set of data arrives into their raw data bucket, an ETL job should be triggered to transform the data, convert it into parquet format and save it to the processed bucket. As a Certified Data Engineer, what solution would you suggest the company?

Select 1 option(s):

Use AWS Kinesis Data Streams to stream the data from the raw data zone to the processed zone, with an intermediary Lambda function to transform the data.

Use S3 Events to create a trigger for processing jobs, create a processing script using AWS Lambda to process the incoming data and save it into the processed zone.

Use AWS Glue to create a trigger for processing jobs, and create a processing script using Glue that transforms the data and saves it into the processed zone.

Use AWS Kinesis Data Firehose to create a trigger for processing jobs, add a Lambda function to Kinesis Data Firehose to transform the data before saving it into the processed zone.

Q47. A company wants to accelerate their Athena queries that select only a few columns of their large datasets.

Which of the following data formats would be suitable for their use case?

Select 2 option(s):

ORC

JSON

CSV

Avro

Parquet

Q48. A Kinesis Data Streams application has records that are 250KB in size, and they are coming at a rate of 10 per second. How many shards would Kinesis Data Streams need to handle this velocity of data for 5 consumers?

Select 1 option(s):

Q49. What is the advantage of using long polling in Amazon SQS?

Select 1 option(s):

It reduces the number of empty responses.

It queries only a subset of servers for messages.

It guarantees immediate message delivery.

It provides a shorter maximum wait time compared to short polling.

Q50. A financial services company has expanded rapidly over the past few years, and have come to a place with high fragmentation within their ETL process orchestration. They now want to unify their orchestration by using Amazon Managed Workflows for Apache Airflow (MWAA). However, their security department has determined that they should use the private access mode for MWAA.

Can you instruct the company on the necessary requirements for the private access mode for MWAA (SELECT THREE)?

Select 3 option(s):

Configured Transit Gateway within the target VPC

Configured VPC service endpoints for services accessed by MWAA within the target VPC

Configured more than one private subnet within the target VPC

A fleet of EC2 instances for MWAA to utilize as workers

Configured AWS PrivateLink to connect from company network to the target VPC

Q51. A data science team at a sports betting company is maintaining a growing number of machine learning models. Many of the models depend on the same training data. The team would like to share and manage the features efficiently, and to make sure the processing logic is authored only once. The team is considering the use of Amazon SageMaker Feature Store. Which statements regarding it are true (SELECT TWO)?

Select 2 option(s):

Offline feature data is only accessible during model training.

The online feature store automatically handles feature versioning.

The offline store is primarily used for real-time feature access.

The feature store only supports a single availability zone.

The offline store provides a centralized repository for storing historical feature data.

Q52. An analytics company wants to query their data from S3 using their Redshift cluster. What would you recommend to the company to achieve this with the least amount of developmental overhead?

Select 1 option(s):

Use the COPY command to load data from S3 to Redshift, after which Redshift can be used to query the data

Use Redshift Spectrum to directly query the data from S3

Use Athena to directly query the data from S3

Use AWS DMS to move data from S3 to Redshift, after which Redshift can be used to query the data

Q53. A data engineer has been tasked with working on a Kinesis Data Streams application, which required low latency (~100ms) delivery of records to a single EC2 client. Currently, the application has a throughput of 4MB/s with 6 shards.

How should the engineer implement the consumption of records to meet the criteria with the LEAST amount of operational cost?

Select 1 option(s):

Use Kinesis Enhanced Fan-Out with the Kinesis Consume SDK to consume the records.

Use Kinesis Enhanced Fan-Out with the Kinesis Client Library to consume the records.

Use Kinesis Consumer SDK to consume the records.

Use Kinesis Client Library to consume the records.

Q54. A financial service company is evaluating storage on Amazon S3 in a way that meets their data protection guidelines. Their compliance department has mandated that data within their S3 bucket CANNOT be deleted within three years of it being saved into S3.

Which of the following would you recommend, to meet their requirements?

Select 1 option(s):

Enable S3 versioning on the bucket

Use S3 Lifecycle Rules to disable file deletion for three years

Enable AWS Multi-Factor Authentication delete on the bucket

Use S3 Object Lock

Q55. A healthcare company wants to tighten the security of their AWS infrastructure, by making sure their EMR cluster does not access S3 via public internet.

As a Certified Data Engineer, what would you recommend to the company?

Select 1 option(s):

Create a VPC interface endpoint for S3. Add the interface endpoint as target to the route table for traffic destined from the VPC to S3.

Create a VPC gateway endpoint for S3.

Create a VPC gateway endpoint for S3. Add the gateway endpoint as target to the route table for traffic destined from the VPC to S3.

Create a VPC interface endpoint for S3.

Q56. A social investing start-up is looking to build a highly scalable and reliable graph database for their social networking platform. The company requires a database service that supports both strong consistency and high availability. Which AWS service would be the most suitable choice for meeting these requirements?

Select 1 option(s):

AWS Neptune

Amazon Redshift

Amazon RDS

AWS Keyspaces

Q57. A data engineer working for a retail company wants to setup continuous replication for an existing and non-empty S3 bucket into an S3 bucket in a different region. What is the correct combination of steps that the engineer must implement?

Select 1 option(s):

Create an S3 Batch Replication task to move existing objects to new bucket. Enable Cross-Region Replication (CRR) to automatically replicate new objects within the new bucket.

Setup versioning for the existing bucket. Enable Cross-Region Replication (CRR) to automatically replicate new and existing objects within the new bucket.

Setup versioning for the existing bucket. Create an S3 Batch Replication task to move existing objects to new bucket. Enable Cross-Region Replication (CRR) to automatically replicate new objects within the new bucket.

Setup versioning for the existing bucket. Create an S3 Batch Replication task to move existing objects to new bucket. Enable Same-Region Replication (SRR) to automatically replicate new objects within the new bucket.

Q58. A technology company wants to convert 100GB of data, stored within S3, from flat files to RecordIO-Protobuf format. Which methods would satisfy the requirements of the job (SELECT TWO)?

Select 2 option(s):

Use Kinesis Data Firehose to transform the files

Use AWS Glue to create an ETL job to transform the files

Create an AWS Batch job to transform the files

Use S3 Events to trigger Lambda functions to transform the files

Spin up an EMR cluster and create an Apache Spark job to transform the files

Q59. A data engineering team at a software company is designing the ingestion of logs from their flagship application to AWS. They want to enable their data science team to perform real-time analysis of streaming logs to generate a list of the top 10 error types every few minutes by region and various software details, including its version. Which AWS service provides the capability to directly read and query data from Kinesis streams, allowing for real-time log analysis using tools like Hive, Pig, MapReduce, Hadoop Streaming, and Cascading?

Select 1 option(s):

AWS Glue

AWS Data Pipeline

EMR Connector to Kinesis

Amazon Kinesis Firehose

Q60. A technology company has recently started using Redshift to store their data. They are planning on storing IoT device data on a Redshift table, which will be used for downstream analytics tasks. In most cases, the table will be queried using the device ID.

As a Certified Data Engineer, what Redshift table distribution style would you suggest to the company?

Select 1 option(s):

EVEN distribution

KEY distribution

INDEX distribution

ALL distribution