
Apache Airflow: The Operators Guide
Apache Airflow is an open-source platform to programmatically author, schedule and monitor workflows. If you have many ETL(s) to manage, Airflow is a must-have.
In the Apache Airflow: The Operators Guide, you are going to learn how to create reliable, efficient and powerful tasks in your Airflow data pipelines. Learn how to create incredible data pipelines and discover the most untold secrets of Airflow Operators!
Materials (required for the course)
You will find the materials directly in a video of the course
Curriculum
Section 1: Introduction
- Important Prerequisites
- Course Objectives
- Who am I?
- Development Environment
Section 2: The BaseOperator Exposed
- Introduction
- What you need to know
- Important details
- The task id exposed
- DAG versioning
- Who owns the task?
- The start_date is more than you think
- Be PROPERLY notified by emails
- Make your tasks dependent across DAG Runs
- Wait for downstream tasks
- Pool Party
- Task priority
- Define the priority
- A callback to react
- Catch a timeout with the failure callback
- Share data with the famous XCOMs
- Limit the concurrency
- Chain and Cross dependency helpers
- Let’s play with chain and cross helpers
- Customize your task according to the executor
Section 3: The Most Common Operators
- Introduction to Providers
- The PythonOperator
- The PythonOperator with the Taskflow API
- The BashOperator
- Quick note about templated fields
- The PostgresOperator
- Passing Dynamic Parameters to the PostgresOperator
Section 4: Choose your path
- Introduction
- The BranchPythonOperator
- DAG scheduling based on a Calendar!
- The BranchSQLOperator
- The BranchDatetimeOperator
- The BranchDayOfWeekOperator
Section 5: DAG dependencies
- Introduction
- The SubDAGOperator
- Deep dive into the SubDAGOperator
- Discover the TaskGroups
- TriggerDagRunOperator
- The famous ExternalTaskSensor
- DAG dependencies view
Section 6: The Exotic ones
- One DAG different schedules with the ShortCircuitOperator
- Prevent from running past tasks with the LatestOnlyOperator
- Side Note with the LatestOnlyOperator
- You think you know the DummyOperator?
Section 7: Last words
- Choose the next operator