Tasks का क्रम निर्धारित करें
अब जब आपने bitshift सिंटैक्स के बारे में सीख लिया है, तो tasks के ऑर्डर को परिभाषित करने का समय है। आपके पास तीन पहले से परिभाषित tasks हैं: cleanup, consolidate, और push_data.
airflow.sdk से dag और task डेकोरेटर्स पहले से इम्पोर्ट किए गए हैं.
यह अभ्यास पाठ्यक्रम का हिस्सा है
Python में Apache Airflow परिचय
अभ्यास निर्देश
- bitshift सिंटैक्स का उपयोग करके
cleanuptask कोconsolidatetask से पहले चलने के लिए कॉन्फ़िगर करें. consolidateको अगला चलने औरpush_datatask को सबसे अंत में चलने के लिए कॉन्फ़िगर करें.
इंटरैक्टिव व्यावहारिक अभ्यास
इस अभ्यास को इस नमूना कोड को पूरा करके आज़माएँ।
@dag(
dag_id="analytics_dag",
start_date=datetime(2026, 3, 1),
)
def analytics_dag():
# Run cleanup before consolidate
cleanup() ____ consolidate()
# Run consolidate before push_data
____
analytics_dag()