एक सरल Dag बनाना
आपने Airflow के कॉम्पोनेंट्स की समीक्षा में समय लगाया है और अब अपने खुद के वर्कफ़्लो आज़माने में रुचि रखते हैं. शुरुआत के लिए, आप डिफ़ॉल्ट पैरामीटर्स परिभाषित करने और अपने वर्कफ़्लो के लिए एक Dag ऑब्जेक्ट बनाने का निर्णय लेते हैं.
datetime ऑब्जेक्ट आपके लिए इम्पोर्ट किया जा चुका है.
यह अभ्यास पाठ्यक्रम का हिस्सा है
Python में Apache Airflow परिचय
अभ्यास निर्देश
- Airflow का Dag ऑब्जेक्ट इम्पोर्ट करें; ध्यान दें कि यह केस-सेंसिटिव है.
- Dag डेकोरेटर परिभाषित करें और Dag का नाम
example_etlरखें. - कोड फ़ाइल के अंत में Dag फ़ंक्शन चलाएँ.
इंटरैक्टिव व्यावहारिक अभ्यास
इस अभ्यास को इस नमूना कोड को पूरा करके आज़माएँ।
# Import the dag object
from ____ import dag
# Define the Dag attributes
____(
____='example_etl',
start_date=datetime(2026, 3, 1),
)
def example_etl():
pass
# Run the Dag
____()