Asset outlet से डेटा उपलब्धता का सिग्नल देना

आपकी टीम के पास एक पाइपलाइन है जो दैनिक बिक्री डेटा s3://data-lake/sales/daily.csv पर लिखती है, और कई डाउनस्ट्रीम पाइपलाइनें उस पर निर्भर हैं। उन्हें टाइमर से पोल कराने या यह अनुमान लगाने के बजाय कि फ़ाइल कब तैयार होगी, आप एक Asset outlet जोड़ेंगे ताकि यह टास्क जैसे ही पूरा हो, यह सिग्नल दे कि डेटा अपडेट हो गया है। यही सिग्नल अन्य Dags को सीधे उसी डेटा के आधार पर खुद को शेड्यूल करने देता है.

कोड पूरा करने के बाद, फ़ाइल चलाइए, फिर Airflow CLI का उपयोग करके जाँच कीजिए कि asset रजिस्टर हुआ और अपडेट भी हुआ।