Domain 3 of 4 · Chapter 1 of 4

Data Processing Automation

Unlock the complete study guide + 1,040 practice questions across 16 full exams.

Bundled into the existing AWS Certified Data Engineer - Associate premium course — no separate purchase.

Included in this chapter:

  • Triggers: what starts the work
  • Lambda and the SDK: automating the steps
  • No-code prep: Glue DataBrew and SageMaker Unified Studio
  • Athena: SQL automation over S3
  • Operating and troubleshooting MWAA and Step Functions
  • Exam-pattern recognition for automation questions

How processing automation gets triggered

Trigger mechanismCauseSchedule supportBuilt-in retry / DLQTypical target
S3 Event NotificationObject created or deletedNone (event only)No (target handles failures)Lambda, SQS, SNS
EventBridge event-pattern ruleAn event occurred (e.g. Glue Job State Change)None (event only)Per-target retry + DLQLambda, Step Functions, Glue
EventBridge SchedulerThe clock (one-time, rate, cron)One-time, rate, cron + time zonesPer-schedule retry + DLQ270+ services via universal target
Lambda (invoked by any of the above)Whatever invoked itInherited from the triggerAsync retries + on-failure DLQGlue, Athena, Step Functions

Decision tree

What starts the work?the clock vs an eventFixed timeEventBridge Schedulerone-time / rate / cron + DLQObject landsNeed richer filtering?native vs via EventBridgeOther eventEventBridge rulematch event, route to targetNoS3 Event Notificationpush direct to Lambda / GlueYesS3 event via EventBridgericher event patternsFits the Lambda limits?15 min / 10 GB / 10 GB tmpYesDo the work in Lambdashort glue logic, small filesNoLambda starts a job, returnsGlue / EMR / Step Functions

Cheat sheet

  • Automate by trigger: an event or the clock starts the work, not a person
  • Use an S3 Event Notification to run code the instant an object lands
  • S3 must have permission to invoke your Lambda, or the event silently never arrives
  • Never write a function's output back to the prefix that triggered it
  • EventBridge Scheduler gives a schedule its own retry policy and dead-letter queue
  • Use an EventBridge event-pattern rule to react to something that happened
  • Prefer EventBridge Scheduler over the older scheduled EventBridge rule
  • Lambda is the event-driven runner a trigger invokes for short processing
  • A Lambda invocation caps at 15 minutes, 10 GB memory, and 10 GB of /tmp
  • When work exceeds the Lambda limits, start a job from Lambda instead of stretching it
  • Drive any AWS service from code with the SDK, boto3 in Python
  • SDK start calls are asynchronous; poll for completion
  • A boto3 AccessDenied in Lambda is an execution-role fix, not a code fix
  • Use Glue DataBrew for visual, no-code data preparation
  • A DataBrew recipe is the reusable, versioned list of transformation steps
  • SageMaker Unified Studio is the single workspace that unifies data, analytics, and AI
  • Use Athena for serverless SQL directly over S3
  • Automate Athena with start_query_execution, then poll for the result
  • Size an MWAA environment by its class, scale it with workers
  • MWAA tasks queuing for a long time means add capacity, not retries
  • An MWAA DAG that never appears is usually an import error or wrong S3 path
  • Diagnose a Step Functions failure from its execution history
  • States.Permissions is a missing IAM permission on the execution role
  • A Distributed Map's MaxConcurrency caps fan-out to a downstream service's own limit
  • Pick Standard for long or exactly-once workflows and Express for short high-volume ones
  • The .sync pattern for Glue needs StartJobRun, GetJobRun, GetJobRuns, and BatchStopJobRun
  • Use a Parallel state to run independent branches and wait for all of them
  • Use a Choice state to branch a workflow on the data's value
  • Use Retry for transient errors and Catch for ones you want to route
  • A Glue conditional trigger's Logical AND or ANY decides whether all or one watched job must finish
  • A Glue EventBridge event trigger batches arrivals with BatchSize and BatchWindow
  • Airflow datasets trigger a consumer DAG by data availability, not the clock

Unlock with Premium — includes all practice exams and the complete study guide.

References

  1. Amazon S3 Event Notifications
  2. Use Lambda recursive loop detection to prevent infinite loops
  3. What Is Amazon EventBridge?
  4. What is Amazon EventBridge Scheduler?
  5. Lambda quotas
  6. AWS Glue Jobs API (StartJobRun)
  7. AWS SDK for Python (Boto3) Documentation
  8. What is AWS Glue DataBrew?
  9. What is Amazon SageMaker Unified Studio?
  10. What is Amazon Athena?
  11. Using Athena with the AWS Glue Data Catalog
  12. Amazon Athena pricing
  13. Amazon Managed Workflows for Apache Airflow environments
  14. Configuring the Amazon MWAA environment class
  15. Amazon MWAA automatic scaling
  16. What is Step Functions?