1. Învăţa
    2. /
  2. Courses
    3. /
  3. Introducere în Apache Airflow în Python
Connected

exercise

Scriere cu Jinja

Pe măsură ce ai început să lucrezi mai mult cu Airflow, ai adăugat diverse callback-uri de notificare, dar realizezi că primești același mesaj în inbox de fiecare dată. E greu să găsești un mesaj când subiectul este mereu identic. După ce ai citit despre suportul Jinja în Airflow, îți dai seama că poți adăuga informații de identificare pentru ca DAG-urile tale să trimită un raport pentru fiecare rulare zilnică. Ai decis să începi prin actualizarea DAG-ului sales_update, astfel încât acesta să îți trimită un e-mail cu un subiect bazat pe template atunci când se finalizează cu succes.

Toate importurile Airflow necesare sunt deja disponibile, iar task-urile pull_sales_data și generate_sales_report sunt deja definite.

Instrucțiuni

100 XP

  • Configurează DAG-ul să îți trimită un e-mail când se finalizează fără erori.

  • Setează atributul subject pentru e-mailul de notificare.

  • Folosește un template Jinja pentru a include data rulării în subiectul e-mailului:

    Sales update successfully processed for YYYY-MM-DD