Orchestrer un pipeline avec Airflow

Intermédiaire LinuxApache Airflow25 min50 XP

Écrivez le DAG /opt/airflow/dags/ventes_quotidiennes.py :

dag_id="ventes_quotidiennes", planification tous les jours à 02:00 (schedule="0 2 * * *"), start_date=datetime(2026, 9, 1), catchup=False
default_args avec "retries": 2 et "retry_delay": timedelta(minutes=10)
trois tâches BashOperator : extraire, transformer, charger, enchaînées extraire >> transformer >> charger

Vérifiez qu'Airflow le charge sans erreur (airflow dags list-import-errors), puis testez-le pour le 28/09/2026 (airflow dags test ventes_quotidiennes 2026-09-28).

Bientôt disponible

Les exercices pratiques ouvrent prochainement. Le titre, le résumé et le plan restent visibles pour découvrir le contenu.

Créer mon compte Se connecter

Tâches

Paramètres du DAG
Reprises automatiques
DAG chargé et testé