Einen Consumer-Dag auf einem Asset planen

Jetzt, da der Sales-Producer signalisiert, wann Daten bereitstehen, brauchst du einen Consumer-Dag, der automatisch läuft, sobald das Asset aktualisiert wird. Definiere dasselbe Asset (s3://data-lake/sales/daily.csv) und setze den Zeitplan des Consumers darauf, damit Airflow den Dag nach jedem Update auslöst.