Ek operatörler

Python ile Apache Airflow'a Giriş

Mike Metzger

Data Engineer

PythonOperator

Bir Python fonksiyonunu/callable'ı çalıştırır
BashOperator'a benzer çalışır, daha fazla seçeneği vardır
Python koduna argüman geçebilir

from airflow.operators.python import PythonOperator

def printme():
    print("This goes in the logs!")

python_task = PythonOperator(
    task_id='simple_print',
    python_callable=printme
)

Argümanlar

Görev argümanlarını destekler
- Konumsal
- Anahtar kelime
op_kwargs sözlüğünü kullanın

op_kwargs örneği

def sleep(length_of_time):
  time.sleep(length_of_time)


sleep_task = PythonOperator(
    task_id='sleep',
    python_callable=sleep,
    op_kwargs={'length_of_time': 5}
)

EmailOperator

airflow.operators kitaplığında bulunur
E-posta gönderir
Tipik bileşenler içerebilir
- HTML içeriği
- Ekler
Airflow'un e-posta sunucusu ayrıntılarıyla yapılandırılmasını gerektirir

EmailOperator örneği

from airflow.operators.email import EmailOperator


email_task = EmailOperator(
    task_id='email_sales_report',
    to='[email protected]',
    subject='Automated Sales Report',
    html_content='Attached is the latest sales report',
    files='latest_sales.xlsx'
)

Hadi pratik yapalım!

Python ile Apache Airflow'a Giriş