शुरू करेंमुफ़्त में शुरू करें

पार्टिशन्ड एसेट्स को डाउनस्ट्रीम Dag ट्रिगर करते हुए देखना

पिछले अभ्यास के अपस्ट्रीम sales_pipeline_v3 और डाउनस्ट्रीम sales_report Dags डिप्लॉय हो चुके हैं और चलने के लिए तैयार हैं। सेल्स पाइपलाइन हर मिनट चलती है और हर रन पर पार्टिशन्ड daily_sales इवेंट इमिट करती है, जबकि रिपोर्ट को सिर्फ़ तारीख की परवाह है; यही काम StartOfDayMapper करता है। अब इन्हें साथ काम करते हुए देखें।

इन चरणों का क्रम से पालन करें:

  1. Dags व्यू में, सबसे पहले sales_report को सक्रिय करें ताकि एसेट इवेंट आते ही यह रिएक्ट करने के लिए तैयार रहे।
  2. फिर sales_pipeline_v3 को सक्रिय करें; यह हर मिनट चलती है और हर रन पर एक पार्टिशन्ड daily_sales इवेंट इमिट करती है।
  3. sales_pipeline_v3 के पूरा होने के लिए लगभग एक मिनट प्रतीक्षा करें — उसके बाद एसेट इवेंट से sales_report अपने-आप ट्रिगर हो जाएगा।
  4. sales_report खोलें, Runs टैब पर जाएँ, नवीनतम रन खोलें, और रन विवरण के शीर्ष पर Mapped Partition key ढूँढ़ें।

Mapped Partition key का डेट फ़ॉर्मेट क्या है?

यह अभ्यास पाठ्यक्रम का हिस्सा है

Airflow के साथ Data Pipelines बनाना

पाठ्यक्रम देखें

इंटरैक्टिव व्यावहारिक अभ्यास

हमारे इंटरैक्टिव अभ्यासों में से किसी एक के साथ सिद्धांत को व्यवहार में बदलें

अभ्यास शुरू करें