Planifier un Dag consommateur sur un Asset

Maintenant que le producteur des ventes signale quand les données sont prêtes, vous avez besoin d'un Dag consommateur qui s'exécute automatiquement à chaque mise à jour de l'asset. Définissez le même asset (s3://data-lake/sales/daily.csv) et affectez-le au planning du consommateur afin qu'Airflow déclenche le Dag après chaque mise à jour.