Planifier un Dag consommateur à partir d'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 fois que l'asset est mis à jour. Définissez le même asset (s3://data-lake/sales/daily.csv) et réglez l'horaire du consommateur sur celui-ci pour qu'Airflow déclenche le Dag après chaque mise à jour.