Convertire un Dag classico in TaskFlow
Il tuo team ha deciso di adottare la TaskFlow API per tutte le nuove pipeline. Il tuo manager ti chiede di riscrivere una pipeline ETL esistente che usava PythonOperator con collegamenti manuali >>.
La versione classica originale è disponibile come riferimento in dags/classic_etl.py. Una versione TaskFlow predisposta è pronta per essere completata da te.
Questo esercizio fa parte del corso
Creare data pipeline con Airflow
esercizio interattivo pratico
Trasforma la teoria in pratica con uno dei nostri esercizi interattivi
Inizia esercizio