Airflow-də DAG nədir?

Apache Airflow'daki DAG (Yönlendirilmiş Siklsiz Grafik), görevlerin (tasks) sırasını ve bağımlılıklarını tanımlayan yönlendirilmiş siklsiz bir grafiktir.

Grafikteki her tepe noktası bir görevi temsil eder ve kenarlar, yürütme sırasını gösterir: B görevi, A görevi başarıyla tamamlandıktan sonra başlayabilir, eğer A'dan B'ye bir kenar varsa.

Airflow'daki DAG'nin temel özellikleri:

• Yönlendirilmiş — görevler belirli bir yönde ilerler, ma'lumotlar veya süreç akışını yansıtır.
• Siklsiz — döngüler yok, sonsuz tekrarları önlemek için.

Python'da Airflow ile basit bir DAG örneği:

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')

# Vazifeleri tanımla
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)

# Bağlılıqları tanımla
start >> process >> end

Shu tarzda, Airflow'daki DAG murakkab ish jarayonlarini ta'riflash va avtomatlashtirish uchun ishlatiladigan, aniq belgilangan bajarilish tartibiga ega usuldir.