Bir Asset çıkışıyla veri kullanılabilirliğini işaretleme

Ekibinin, günlük satış verilerini s3://data-lake/sales/daily.csv dosyasına yazan bir hattı var ve buna bağlı birkaç aşağı akış hattı bulunuyor. Bu hatların bir zamanlayıcıyla yoklama yapması veya dosyanın ne zaman hazır olduğunu tahmin etmesi yerine, bu göreve bir Asset çıkışı ekleyeceksin; böylece görev biter bitmez verinin güncellendiğini işaret edecek. Bu sinyal, diğer Dag'lerin kendilerini doğrudan veriye göre zamanlamasını sağlar.

Kodu tamamladıktan sonra dosyayı çalıştır, ardından Airflow CLI kullanarak varlığın (asset) kaydedildiğini ve güncellendiğini doğrula.