Signaler la disponibilité des données avec une sortie d'Asset

Votre équipe a un pipeline qui écrit les données de ventes quotidiennes dans s3://data-lake/sales/daily.csv, et plusieurs pipelines en aval en dépendent. Plutôt que de les faire sonder avec une minuterie ou deviner quand le fichier est prêt, vous allez ajouter une sortie Asset pour que cette tâche signale que les données ont été mises à jour dès qu'elle se termine. Ce signal permet aux autres Dags de se planifier en fonction des données elles-mêmes.

Après avoir complété le code, exécutez le fichier, puis vérifiez que l'asset a été enregistré et mis à jour à l'aide de l'outil en ligne de commande d'Airflow (Airflow CLI).