1. Učit se
    2. /
  2. Kurzy
    3. /
  3. Úvod do Apache Airflow v Pythonu
Connected

Cvičení

Psaní se šablonami Jinja

Jak stále více pracuješ s Airflow, přidal/a jsi různé notifikační callbacky — jenže v inboxu ti přistávají pořád stejné zprávy. Když má každá předmět identický, těžko se v tom orientuje. Po přečtení dokumentace o podpoře Jinja v Airflow sis uvědomil/a, že můžeš do zpráv přidat rozlišující informace a zajistit, aby DAG posílal report pro každý den zvlášť. Rozhodl/a ses začít úpravou DAGu sales_update tak, aby ti po úspěšném dokončení odeslal e-mail s dynamickým předmětem.

Všechny potřebné importy z Airflow jsou již dostupné a tasky pull_sales_data a generate_sales_report jsou již definovány.

Pokyny

100 XP

  • Nastav DAG tak, aby ti odeslal e-mail při úspěšném dokončení bez chyb.

  • Nastav atribut subject pro notifikační e-mail.

  • Pomocí šablony Jinja zahrň datum spuštění do předmětu e-mailu:

    Sales update successfully processed for YYYY-MM-DD