पार्टिशन्ड एसेट्स को डाउनस्ट्रीम Dag ट्रिगर करते हुए देखना
पिछले अभ्यास के अपस्ट्रीम sales_pipeline_v3 और डाउनस्ट्रीम sales_report Dags डिप्लॉय हो चुके हैं और चलने के लिए तैयार हैं। सेल्स पाइपलाइन हर मिनट चलती है और हर रन पर पार्टिशन्ड daily_sales इवेंट इमिट करती है, जबकि रिपोर्ट को सिर्फ़ तारीख की परवाह है; यही काम StartOfDayMapper करता है। अब इन्हें साथ काम करते हुए देखें।
इन चरणों का क्रम से पालन करें:
- Dags व्यू में, सबसे पहले
sales_reportको सक्रिय करें ताकि एसेट इवेंट आते ही यह रिएक्ट करने के लिए तैयार रहे। - फिर
sales_pipeline_v3को सक्रिय करें; यह हर मिनट चलती है और हर रन पर एक पार्टिशन्डdaily_salesइवेंट इमिट करती है। sales_pipeline_v3के पूरा होने के लिए लगभग एक मिनट प्रतीक्षा करें — उसके बाद एसेट इवेंट सेsales_reportअपने-आप ट्रिगर हो जाएगा।sales_reportखोलें, Runs टैब पर जाएँ, नवीनतम रन खोलें, और रन विवरण के शीर्ष पर Mapped Partition key ढूँढ़ें।
Mapped Partition key का डेट फ़ॉर्मेट क्या है?
यह अभ्यास पाठ्यक्रम का हिस्सा है
Airflow के साथ Data Pipelines बनाना
इंटरैक्टिव व्यावहारिक अभ्यास
हमारे इंटरैक्टिव अभ्यासों में से किसी एक के साथ सिद्धांत को व्यवहार में बदलें
अभ्यास शुरू करें