AWS DEA-C01 cheat sheet for ingestion, transformation, lakehouse storage, catalogs, operations, security, governance, cost, and final review traps.
Keep this cheat sheet open while drilling questions. DEA‑C01 rewards “production data platform realism”: correct service selection, replayability/backfills, partitioning/file formats, monitoring and data quality, and governance-by-default.
CDC: Change data capture, where source-system changes are emitted as events for downstream ingestion.
ETL: Extract, transform, and load workflow for moving and reshaping data into a target system.
Lake Formation: AWS governance layer for permissions and controls on S3-based data lakes.
MWAA: Managed Workflows for Apache Airflow, the AWS managed orchestration service for Airflow DAGs.
Use this when the question is really about where the pipeline should land, transform, govern, and publish.
flowchart LR
SRC["Sources"] --> ING["Ingest: batch, stream, or CDC"]
ING --> RAW["Raw S3 landing"]
RAW --> ETL["Transform: Glue, EMR, Lambda"]
ETL --> CUR["Curated S3 / warehouse"]
CUR --> GOV["Governance: Lake Formation + catalog + permissions"]
CUR --> OBS["Observe: CloudWatch, CloudTrail, Macie"]
Use this when the stem mixes sources, ingestion, storage, governance, and consumption.
flowchart TD
S["Scenario"] --> I["Identify the source shape"]
I --> P["Pick batch, streaming, or CDC"]
P --> L["Land in durable storage first"]
L --> T["Transform with the right engine"]
T --> G["Apply catalog + permissions + governance"]
G --> C["Choose the serving layer"]
C --> M["Monitor quality, cost, and replayability"]
I verified these current AWS exam facts on May 24, 2026.
| Item | Value |
|---|---|
| Exam | AWS Certified Data Engineer - Associate |
| Exam code | DEA-C01 |
| Questions | 65 total |
| Scoring | 50 scored + 15 unscored (unscored items are not identified) |
| Question types | Multiple choice and multiple response |
| Time | 130 minutes |
| Passing score | 720, scaled 100-1000 |
| Cost | 150 USD |
| Intended candidate | 2-3 years of data engineering experience, including 1-2 years of hands-on AWS experience |
| Domain | Weight | What to compress for final review |
|---|---|---|
| Data Ingestion and Transformation | 34% | batch, streaming, CDC, Glue, EMR, Lambda, orchestration, idempotency, replay |
| Data Store Management | 26% | S3 lake layout, file formats, partitioning, cataloging, Redshift, Athena, lifecycle |
| Data Operations and Support | 22% | monitoring, troubleshooting, data quality, cost/performance, lineage, alerts |
| Data Security and Governance | 18% | Lake Formation, IAM, KMS, privacy, logging, compliance, access boundaries |
DEA-C01 is an implementation exam. Prefer answers that make pipelines repeatable, observable, governed, and recoverable; reject answers that only move data once without replay, quality checks, ownership, or cost controls.
DEA-C01 questions usually test whether a pipeline can survive real data-platform pressure, not whether you can name a single analytics service. Before choosing the answer, walk the scenario through this stack:
If an answer moves data successfully but cannot replay, explain freshness, isolate bad records, or prove governed access, it is usually too thin for Data Engineer - Associate.
Data Ingestion and Transformation covers batch, streaming, CDC, APIs, scheduling, fan-in/fan-out, replayability, transformation, orchestration, code, and IaC. Preserve raw data, handle duplicates, support replay, and choose the transform engine from volume, velocity, variety, latency, and operational cost.
Data Store Management covers store choice, cataloging, lifecycle, schema evolution, Redshift/S3 movement, open table formats, and vector concepts. Storage decisions are access-pattern decisions: query engine, file format, partitioning, catalog, lifecycle, schema evolution, and governance all interact.
Data Operations and Support covers automation, analysis, monitoring, logs, troubleshooting, data quality, skew, sampling, cost/performance, and operational evidence. A pipeline is not production-ready until freshness, quality, cost, failures, lineage, and alerts are observable.
Data Security and Governance covers IAM, Lake Formation, KMS, masking, audit logs, privacy, data sharing, sovereignty, and controlled access. Prefer least privilege, fine-grained lake permissions, encryption, auditability, PII detection, and Region controls over informal bucket sprawl.
AWS frames DEA-C01 as a data engineering implementation exam. Use that boundary to reject overbuilt or off-scope answers:
| Question type | Exam-day habit |
|---|---|
| Multiple choice | Identify the pipeline failure point first: source capture, durable landing, transform engine, catalog, serving store, quality gate, or access control. |
| Multiple response | Include every required data-platform control. A strong answer may need ingestion plus checkpointing, cataloging, monitoring, and security. |
Unanswered questions are incorrect and there is no penalty for guessing. With 65 questions in 130 minutes, your average budget is exactly 2 minutes per question; do not spend 6 minutes on one dense pipeline scenario before banking easier service-selection points.
| Stem clue | Eliminate first | Keep in play |
|---|---|---|
| need replayable ingest and backfills | transform directly into final table only | raw S3 landing, idempotent jobs, checkpoints, partitioned curated outputs |
| source database changes must flow downstream | scheduled full extracts forever | AWS DMS CDC, durable landing, duplicate handling, restart strategy |
| ad-hoc SQL on S3 with lowest operational overhead | Redshift cluster by default | Athena with columnar format, partition pruning, and catalog metadata |
| warehouse analytics with managed performance | Athena for every workload | Redshift, data loading design, sort/distribution choices where relevant |
| data lake access must be governed across engines | IAM-only bucket sprawl | Lake Formation plus Glue Data Catalog, tag-based or fine-grained permissions |
| tiny files causing slow queries | add more crawlers | compaction, partition strategy, columnar format, file-size hygiene |
| schema changed upstream | ignore crawler/catalog impact | schema evolution handling, validation, quarantine, compatibility rules |
| pipeline failed overnight | rerun everything manually | workflow retries, dead-letter/quarantine path, CloudWatch logs/metrics, alert ownership |
| PII appears in data lake | rely on naming conventions | Macie discovery, classification, encryption, access policy, retention controls |
| cost spike in analytics | more compute first | reduce scanned data, partition pruning, compression, right-sized service choice |
Use this chain when the stem asks for a durable data platform rather than a one-time transfer.
flowchart LR
S["Source contract"] --> L["Raw durable landing"]
L --> C["Checkpoint and dedupe key"]
C --> V["Validation and quarantine"]
V --> T["Transform to curated format"]
T --> M["Catalog, partition, and lineage"]
M --> G["Govern access and keys"]
G --> O["Freshness, cost, and failure alarms"]
The strongest DEA-C01 answer usually shows where records came from, how the job can replay safely, how bad records are isolated, how consumers discover the table, and how operators prove freshness and access control.
| Design question | Strong exam answer | Weak answer pattern |
|---|---|---|
| Can the pipeline replay or backfill? | raw immutable landing, checkpoints, idempotent transforms, dedupe keys | overwrite final tables directly and hope reruns work |
| Can consumers trust the schema? | explicit contracts, catalog updates, schema evolution handling, validation | crawler-only discovery with no compatibility plan |
| Can queries stay cost-efficient? | Parquet/ORC, partition pruning, compaction, compression, projection | scan raw CSV/JSON forever or partition on unusable columns |
| Can bad records be handled safely? | quarantine path, failed-rule evidence, alert owner, replay after correction | drop records silently or rerun the whole pipeline manually |
| Can governance cross engines? | Lake Formation, Glue Data Catalog, IAM, KMS, audit trail | bucket policies copied per consumer without catalog discipline |
| Can operations explain failure? | CloudWatch logs/metrics, CloudTrail, job run history, freshness checks | generic “enable logging” without searchable evidence |
| Requirement | Prefer | Watch for |
|---|---|---|
| ad hoc SQL over S3 with low operations | Athena plus Glue Data Catalog | scanned bytes, partitions, columnar files, workgroup controls |
| governed lake tables shared across engines | S3 data lake, Glue Catalog, Lake Formation | row/column/tag permissions, partitions, KMS, cross-account sharing |
| warehouse BI with predictable performance | Redshift | load design, distribution/sort strategy, concurrency, materialized views |
| key-value lookup with predictable access pattern | DynamoDB | partition key design, hot keys, TTL, streams, point-in-time recovery |
| source database change capture | AWS DMS CDC into durable landing | duplicates, ordering, restart position, schema conversion, backfill |
| lakehouse updates or deletes | Apache Iceberg or supported open table format | compaction, snapshot retention, engine compatibility, catalog integration |
| vector search or semantic retrieval | vector-capable store or knowledge-base pattern | embeddings, metadata filters, HNSW/IVF tradeoffs, authorization |
| Symptom in the stem | First evidence to inspect | Better fix |
|---|---|---|
| today’s dashboard is empty | S3 prefix, partition registration, freshness metric, upstream job status | sync partitions or repair upstream run before blaming BI |
| duplicate rows after CDC replay | checkpoint, DMS task logs, primary key or event ID, merge logic | make writes idempotent and dedupe on stable business keys |
| Athena bill spiked | bytes scanned, file format, partition filters, workgroup settings | convert/compress/partition data before adding more compute |
| Glue job runtime doubled | input file count, skew, shuffle, worker metrics, recent schema change | compact files, fix skew, tune worker type/count from evidence |
| downstream schema broke | catalog version, source schema diff, validation failure, consumer contract | quarantine incompatible records and publish a compatible schema path |
| compliance asks who accessed data | CloudTrail, Lake Formation audit path, access logs, KMS usage, Config history | produce centralized audit evidence, not screenshots or manual notes |
| If the question says… | Usually best answer |
|---|---|
| Replayable ingest and backfills | S3 raw zone + idempotent processing + checkpoints |
| Database replication / CDC | AWS DMS |
| Low-latency event stream analytics | Kinesis Data Streams or MSK (+ Flink when stateful processing is needed) |
| Cheapest ad-hoc SQL on S3 | Athena + Parquet + partition pruning |
| Warehouse-style analytics and mixed workload SQL | Redshift (plus Spectrum for external S3 data) |
| Cross-engine data permissions on lake data | Lake Formation + Glue Data Catalog |
| Production orchestration with dependencies/retries | MWAA or Step Functions |
| PII discovery in S3 | Amazon Macie |
| Schema discovery and metadata | Glue crawlers + explicit table design where needed |
| Data quality guardrails | In-pipeline checks + quarantine + alerting |
| Topic | Fast recall |
|---|---|
| File format for analytics | Parquet/ORC beats CSV/JSON for scan cost and speed |
| S3 table performance | Partition on query predicates; avoid tiny files |
| Delivery semantics | Most streaming/integration paths are at-least-once |
| Governance baseline | CloudTrail, encryption (KMS), least-privilege access |
| Query cost lever | Reduce data scanned first (partition + columnar + projection) |
| Trap | Better exam instinct |
|---|---|
| Redshift for every SQL question | Athena is often better for low-ops ad hoc S3 queries; Redshift fits warehouse performance, concurrency, and modeled analytics. |
| Athena scans raw JSON forever | Convert to Parquet/ORC, partition by common predicates, and avoid tiny files. |
| DynamoDB used like a warehouse | DynamoDB is for key-value/document access patterns, not arbitrary analytical scans. |
| RDS selected for unbounded event analytics | Use lake, stream, or warehouse patterns when volume and analytical access dominate. |
| Lifecycle only after storage cost spikes | Apply lifecycle, retention, and deletion rules when designing the data product. |
| Cross-Region replication without sovereignty check | Data residency, privacy, backup, and replication controls are part of the answer. |
flowchart LR
SRC["Sources<br/>(SaaS, DBs, apps, streams)"] --> ING["Ingest<br/>(DMS, AppFlow, Kinesis, MSK)"]
ING --> RAW["S3 data lake<br/>(raw/bronze)"]
RAW --> ETL["Transform<br/>(Glue, EMR, Lambda)"]
ETL --> CUR["S3 curated<br/>(silver/gold)"]
CUR --> CAT["Glue Data Catalog"]
CAT --> ATH["Athena<br/>(serverless SQL)"]
CUR --> RS["Redshift<br/>(warehouse)"]
ATH --> BI["QuickSight / BI"]
RS --> BI
CUR --> GOV["Lake Formation<br/>(permissions)"]
ING --> ORCH["Orchestrate<br/>(MWAA, Step Functions, EventBridge)"]
ORCH --> ETL
MON["Monitor + audit<br/>(CloudWatch, CloudTrail, Macie)"] --> ORCH
MON --> RS
MON --> ATH
High-yield framing: DEA‑C01 is about the pipeline + platform, not just one service.
| Pattern | Best for | Typical AWS answers | Common gotcha |
|---|---|---|---|
| Batch | Daily/hourly loads, predictable schedules | S3 landing + Glue/EMR; EventBridge schedule; AppFlow | Backfills + late data handling |
| Streaming | Near-real-time events | Kinesis Data Streams; MSK; (optional) Flink | Ordering, retries, consumer lag |
| CDC (change data capture) | Database replication | AWS DMS | Exactly-once isn’t guaranteed; handle duplicates |
| Trap | Better exam instinct |
|---|---|
| Treating stream retention as permanent storage | Land durable raw events in S3 or another appropriate store when replay/backfill matters. |
| Assuming one consumer can satisfy every downstream need | Design fan-out, consumer isolation, delivery guarantees, and checkpointing explicitly. |
| Ignoring source rate limits | Use throttling, batching, retries, backoff, and API quota-aware ingestion. |
| CDC without duplicate handling | DMS/streaming paths can replay records; design idempotent writes and deduplication keys. |
| Stateful transform treated like simple Lambda glue | Stateful windows, joins, and aggregations usually require a streaming engine or workflow with durable state. |
| LLM data processing used without validation | LLM-assisted extraction or cleanup still needs schema checks, confidence handling, auditability, and human review when impact is high. |
| Need | Typical best-fit |
|---|---|
| Run every N minutes | EventBridge schedule |
| Run when file arrives in S3 | S3 event notifications or EventBridge |
| Complex dependencies + retries | MWAA or Step Functions |
| You need… | Best-fit (typical) | Why |
|---|---|---|
| Managed Spark ETL with less ops | AWS Glue | Serverless-ish ETL + integrations |
| Full control over Spark (big jobs) | Amazon EMR | More knobs/control; long-running clusters optional |
| Lightweight transforms or glue code | AWS Lambda | Event-driven, simple steps |
| SQL transforms close to the warehouse | Amazon Redshift | Push compute to the warehouse when appropriate |
| Approach | When it’s best | Risk |
|---|---|---|
| Glue crawler | Fast discovery, unknown schemas | Schema drift surprises |
| Explicit DDL | Strong contracts | More manual maintenance |
High-yield rule: keep partitions in sync (MSCK REPAIR / partition projection / crawler updates), or queries “miss” new data.
| Requirement | Strong first fit | Watch for |
|---|---|---|
| lakehouse table updates, deletes, or schema evolution | Apache Iceberg or another supported open table format | catalog integration, snapshot lifecycle, compaction, and engine compatibility |
| semantic search or RAG-style retrieval over enterprise data | vector index or knowledge-base pattern | embeddings, metadata filters, vector index type, refresh, and authorization |
| approximate nearest-neighbor vector search | HNSW or IVF-style index concepts | recall/latency tradeoffs and index maintenance, not normal B-tree thinking |
| technical metadata for query engines | Glue Data Catalog or Hive metastore | partition sync, schema drift, crawler behavior, and table definitions |
| business data catalog and projects | SageMaker Catalog or SageMaker Unified Studio concepts | domain, domain unit, project, ownership, and access governance |
| lineage and schema evolution | catalog metadata, DMS/SCT where migration is involved, and lineage-aware tools | compatibility, downstream contracts, and audit evidence |
| You need… | Best-fit | Why |
|---|---|---|
| Ad hoc SQL on S3 | Athena | Serverless, pay per scan |
| High concurrency BI dashboards | Redshift | Warehouse optimization + caching |
| Query S3 from Redshift | Redshift Spectrum | External tables on S3 |
COPY from S3 for fast loads (parallel, columnar-friendly).UNLOAD to export query results back to S3.If your table is partitioned by dt, always filter by it:
1SELECT *
2FROM curated.events
3WHERE dt = '2025-12-12'
4 AND event_type = 'purchase';
1CREATE TABLE curated.daily_sales
2WITH (format='PARQUET', partitioned_by=ARRAY['dt'])
3AS
4SELECT dt, customer_id, SUM(amount) AS total
5FROM raw.sales
6GROUP BY dt, customer_id;
| You need… | Best-fit | Why |
|---|---|---|
| DAGs, complex dependencies, retries | MWAA (Airflow) | Mature DAG patterns |
| Serverless state machine orchestration | Step Functions | Visual state, retries, integration patterns |
flowchart LR
E["EventBridge schedule"] --> W["Workflow start"]
W --> I["Ingest"]
I --> V{"Valid?"}
V -->|yes| T["Transform"]
V -->|no| Q["Quarantine + alert"]
T --> C["Catalog/partitions update"]
C --> P["Publish dataset"]
P --> N["Notify (SNS)"]
High-yield reliability rules:
Common AWS tooling:
| Symptom | First evidence | Strong first fix |
|---|---|---|
| newest data missing in Athena | partition catalog, crawler run, partition projection, S3 prefix | sync partitions or repair table design before rerunning all ETL |
| Glue job slow or failing | job logs, worker sizing, input file count, skew, shuffle behavior | fix partitioning/file sizes/skew or right-size workers based on evidence |
| stream lag grows | shard/partition throughput, consumer errors, checkpoint age, downstream writes | scale consumers or shards, batch correctly, and remove downstream bottleneck |
| Redshift load slow | COPY pattern, file sizes, compression, distribution/sort design, WLM pressure | stage files correctly and tune load/query design instead of row-by-row inserts |
| data quality alert fires | failed rule, source change, schema version, quarantine location | quarantine bad records, alert owner, and preserve replay path |
| audit question asks “who changed it” | CloudTrail or CloudTrail Lake, Config timeline, service logs | use API/config evidence, not only application logs |
| Dimension | Example check |
|---|---|
| Completeness | Required fields not null |
| Consistency | Same customer_id format across sources |
| Accuracy | Values within expected ranges |
| Integrity | Valid foreign keys / referential relationships |
High-yield pattern: run checks in-pipeline, quarantine bad records, and alert.
Lake Formation helps you manage fine-grained permissions for data in S3 across engines like Athena/EMR/Redshift Spectrum, using a consistent governance model.
| Requirement | Strong first fit | Watch for |
|---|---|---|
| fine-grained access across Athena, EMR, Redshift Spectrum, and S3 lake data | Lake Formation with Glue Data Catalog | tag-based permissions, row/column controls, cross-account sharing, and IAM interaction |
| PII discovery in S3 | Macie with classification workflow | discovery must lead to masking, access control, encryption, retention, or remediation |
| data masking or anonymization | transformation-time masking, view-level controls, or service-specific masking | do not leave raw sensitive data broadly queryable |
| cross-account encrypted data access | KMS key policy, grants, IAM, Lake Formation/resource policy | both data permission and key permission must allow the path |
| centralized audit queries | CloudTrail Lake, Athena over logs, CloudWatch Logs Insights, or OpenSearch based on volume/use case | retention, encryption, query access, and separation of duties |
| data sovereignty | Region restrictions, replication controls, backup policy, and governance rules | backup and replication can violate residency requirements if ignored |
| governed data projects | SageMaker Catalog projects, domains, domain units, or appropriate catalog governance | ownership and access model must be explicit, not just a bucket folder |