Operators और Providers

Tasks के template

Operator एक तरह के काम का दोबारा उपयोग होने वाला template है: BashOperator shell command चलाता है, PythonOperator function बुलाता है, EmptyOperator प्लेसहोल्डर है, और provider packages बाहरी systems के लिए operators जोड़ते हैं (apache-airflow-providers-amazon, -google, -postgres, -snowflake, -cncf-kubernetes और कई अन्य)। सिर्फ़ ज़रूरी providers install करें। Airflow 3 में core "standard" operators airflow.providers.standard में हैं, इसलिए imports Airflow 2 से अलग हैं; हमेशा अपने version का दस्तावेज़ देखें।

Tasks और उनके बीच तीर

DAG फ़ाइल tasks और निर्भरताएँ घोषित करती है; graph का आकार ही run की योजना है।

Imports: Airflow 3 बनाम 2

एक ही DAG को major version के अनुसार अलग imports चाहिए। अपने install किए version से मेल खाता block चुनें।

# Airflow 3.x
from airflow.sdk import DAG, dag, task
from airflow.providers.standard.operators.bash import BashOperator
from airflow.providers.standard.operators.python import PythonOperator

# Airflow 2.x
# from airflow import DAG
# from airflow.decorators import dag, task
# from airflow.operators.bash import BashOperator
# from airflow.operators.python import PythonOperator

विशिष्ट operator चुनें

आपके warehouse या cloud service का provider operator, CLI को shell से बुलाने वाले हाथ के लिखे BashOperator से connections, retries और idempotent व्यवहार बेहतर सँभालता है।

त्वरित जाँच: Provider packages Airflow में क्या जोड़ते हैं?

• नया database
• बाहरी systems के लिए operators, hooks और sensors
• तेज़ CPUs
• Browser themes