ETL Pipeline

Extract, Transform, Load.

Pipelines

Prompt

Write a Python Airflow DAG that extracts daily sales data from a MySQL replica, aggregates it by region using Pandas, and loads it into Snowflake.