Airflow-деги DAG эмне?

Apache Airflow'daki DAG (Yönlendirilmiş Siklsiz Grafik) — bu, vazifalar (tasks) sırasını ve bağımlılıklarını yo'naltirilgan siklsiz grafiga ta'riflovchi tuzilma.

Grafning har bir tuguni vazifani ifodalaydi, va qirralar bajarilish tartibini ko'rsatadi: B vazifasi, agar A dan B ga qirra bo'lsa, A muvaffaqiyatli yakunlangandan so'ng boshlanishi mumkin.

Airflow'dagi DAG ning asosiy xususiyatlari:

• Yo'naltirilgan — vazifalar ma'lum bir yo'nalishda ketadi, ma'lumotlar yoki jarayonlar oqimini yansıtadi.
• Siklsiz — tsikllar yo'q, cheksiz takrorlanishlarni oldini olish uchun.

Python'da Airflow bilan oddiy DAG misoli:

from airflow import DAG
from airflow.operators.bash import BashOperator
from datetime import datetime

default_args = {'start_date': datetime(2024, 1, 1)}

dag = DAG('misol_dag', default_args=default_args, schedule_interval='@daily')

# Vazifalarni aniqlash
start = BashOperator(task_id='start', bash_command='echo Start', dag=dag)
process = BashOperator(task_id='process', bash_command='echo Processing', dag=dag)
end = BashOperator(task_id='end', bash_command='echo End', dag=dag)

# Байланыштарды аныктоо
start >> process >> end

Шулай, Airflow'daki DAG — бул татаал иш процесстерин сүрөттөө жана автоматташтыруу үчүн колдонулган, ачык белгиленген аткаруу тартиби менен.