Bir Asset üzerinde tüketici Dag zamanlama

Artık satış üreticisi veriler hazır olduğunda sinyal verdiğine göre, asset güncellendiğinde otomatik olarak çalışan bir tüketici Dag'ine ihtiyacın var. Aynı asset'i (s3://data-lake/sales/daily.csv) tanımla ve tüketicinin zamanlamasını buna ayarla ki Airflow her güncellemeden sonra Dag'i tetiklesin.