पिछले अभ्यास के अपस्ट्रीम 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 का डेट फ़ॉर्मेट क्या है?

बधाई हो!

Create Your Free Account