Şablonlarla çalışmak

Python ile Apache Airflow'a Giriş

Mike Metzger

Data Engineer

Şablonlar nedir?

Şablonlar:

Bir DAG çalışırken bilgi yerleştirmeye olanak tanır
Görev tanımlarken ek esneklik sağlar
Jinja şablonlama diliyle oluşturulur

Şablonsuz BashOperator örneği

Dosya listesini echo eden bir görev oluşturun:

t1 = BashOperator(
       task_id='first_task',
       bash_command='echo "Reading file1.txt"',
       dag=dag)

t2 = BashOperator(
       task_id='second_task',
       bash_command='echo "Reading file2.txt"',
       dag=dag)

Şablonlu BashOperator örneği

templated_command="""
  echo "Reading {{ params.filename }}"
"""

t1 = BashOperator(task_id='template_task',
       bash_command=templated_command,
       params={'filename': 'file1.txt'},
       dag=example_dag)

Çıktı:

Reading file1.txt

Şablonlu BashOperator örneği (devam)

templated_command="""
  echo "Reading {{ params.filename }}"
"""

t1 = BashOperator(task_id='template_task',
       bash_command=templated_command,
       params={'filename': 'file1.txt'},
       dag=example_dag)

t2 = BashOperator(task_id='template_task',
       bash_command=templated_command,
       params={'filename': 'file2.txt'},
       dag=example_dag)

Haydi pratik yapalım!

Python ile Apache Airflow'a Giriş