Branching

Pengantar Apache Airflow dengan Python

Mike Metzger

Data Engineer

Branching

Branching di Airflow:

Menyediakan logika kondisional
Menggunakan BranchPythonOperator
from airflow.operators.python import BranchPythonOperator
Menerima python_callable yang mengembalikan id tugas berikutnya (atau daftar id) untuk diikuti

Contoh branching

def branch_test(**kwargs):
  if int(kwargs['ds_nodash']) % 2 == 0:
    return 'even_day_task'
  else:
    return 'odd_day_task'

Contoh branching

def branch_test(**kwargs):
  if int(kwargs['ds_nodash']) % 2 == 0:
    return 'even_day_task'
  else:
    return 'odd_day_task'


branch_task = BranchPythonOperator(task_id='branch_task',dag=dag,
       provide_context=True,
       python_callable=branch_test)


start_task >> branch_task >> even_day_task >> even_day_task2

branch_task >> odd_day_task >> odd_day_task2

Tampilan grafik branching

Tampilan grafik DAG branching

Branching hari genap

Tampilan grafik branching - hari genap

Branching hari ganjil

Tampilan grafik branching - hari ganjil

Ayo berlatih!

Pengantar Apache Airflow dengan Python