Hands-On Quiz — Operators & Hooks

Practice Exercises

Exercise 1: Build an ETL DAG

Create a DAG using operators that:

Uses HttpSensor to wait for an API to be available
Uses PythonOperator to extract data from the API
Uses PythonOperator to transform the data
Uses BashOperator to trigger a dbt run
Has proper error handling with retries and email alerts

Exercise 2: Custom Hook Usage

Write a @task function that uses PostgresHook to:

Connect to a PostgreSQL database
Run a data quality check (count rows, check for nulls)
Push the results to XCom
Raise an exception if quality checks fail

Exercise 3: Sensor Mode Comparison

Create a DAG with three branches, each using the same FileSensor but with different modes:

mode="poke" with poke_interval=10
mode="reschedule" with poke_interval=60
deferrable=True

Run the DAG and observe the differences in the Gantt chart view.

lock

This content is reserved for Premium Members.

Upgrade to Premium