Airflow Tutorial for Beginners - Full Course in 2 Hours 2022

क्या आप सीखेंगे

• एयरफ्लो का परिचय और इसके मुख्य घटकों को समझना
• एयरफ्लो को स्थापित करना और इसका उपयोग करना सीखना
• एयरफ्लो में डीएजी बनाना और इसके विभिन्न ऑपरेटरों का उपयोग करना

मुख्य अवधारणाएं

एयरफ्लो एक açık-स्रोत टूल है जिसका उपयोग विभिन्न प्रकार के कार्यों को निर्धारित और निगरानी करने के लिए किया जा सकता है। यह एक पायथन-आधारित टूल है जो कार्यों को निर्धारित करने और उनके बीच संबंधों को परिभाषित करने के लिए उपयोग किया जाता है। एयरफ्लो में डीएजी (डायरेक्टेड एसाइक्लिक ग्राफ) का उपयोग कार्यों को व्यवस्थित करने और उनके बीच संबंधों को परिभाषित करने के लिए किया जाता है।

कोड उदाहरण

from datetime import datetime, timedelta
default_args = {
    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': datetime(2021, 10, 6),
    'retries': 1,
    'retry_delay': timedelta(minutes=5),
}

यह कोड एयरफ्लो में एक डीएजी के लिए डिफ़ॉल्ट तर्कों को परिभाषित करता है।

def greet(name, age):
    print(f"हैलो विश्व! मेरा नाम {name} है और मैं {age} साल का हूँ")

यह कोड एक पायथन फ़ंक्शन को परिभाषित करता है जो एक नाम और आयु को प्रिंट करता है।

task = PythonOperator(
    task_id='greet',
    python_callable=greet,
    op_kwargs={'name': 'टॉम', 'age': 20}
)

यह कोड एक पायथन ऑपरेटर को परिभाषित करता है जो पूर्वकाल फ़ंक्शन को चलाता है।

पाठ सारांश

इस पाठ में, हमने एयरफ्लो का परिचय दिया और इसके मुख्य घटकों को समझा। हमने एयरफ्लो को स्थापित करना और इसका उपयोग करना सीखा। हमने एयरफ्लो में डीएजी बनाना और इसके विभिन्न ऑपरेटरों का उपयोग करना भी सीखा। हमने पायथन ऑपरेटर का उपयोग करके एक पायथन फ़ंक्शन को चलाना सीखा और इसके तर्कों को परिभाषित करना सीखा।

अभ्यास व्यायाम

एक पायथन फ़ंक्शन बनाएं जो एक नाम और आयु को प्रिंट करता है। फिर, एयरफ्लो में एक डीएजी बनाएं जो इस फ़ंक्शन को चलाता है।

आगे क्या है

अब आप एयरफ्लो का उपयोग करके अपने स्वयं के डीएजी बनाने के लिए तैयार हैं। अगले पाठ में, हम एयरफ्लो में अधिक जटिल डीएजी बनाने और इसके विभिन्न सुविधाओं का उपयोग करने के बारे में सीखेंगे।