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

Cvičení

Více @tasks

Aby ses mohl/a posunout dál v implementaci svého workflow, potřebuješ přidat další krok pro zpracování a uložení změn staženého souboru. DAG process_sales je definovaný a má již přidaný task pull_file. Pythonová funkce parse_file(inputfile, outputfile) je pro tebe připravena předem.

Měj na paměti, že při implementaci Airflow tasků nemusíš vždy rozumět každému jednotlivému kroku. Stačí vědět, jak jednotlivé kroky zabalit do struktury Airflow — a zvládneš sestavit jakékoli požadované workflow.

Pokyny

100 XP
  • Vytvoř Airflow task pomocí metody parse_file.
  • Zavolej task s potřebnými argumenty.