1. Learn
    2. /
  2. Cursuri
    3. /
  3. Introducere în Apache Airflow în Python
Connected

exercițiu

Mai multe @tasks

Pentru a continua implementarea workflow-ului tău, trebuie să adaugi un pas suplimentar care să parseze și să salveze modificările din fișierul descărcat. DAG-ul process_sales este deja definit și include task-ul pull_file. În acest caz, funcția Python este deja scrisă pentru tine: parse_file(inputfile, outputfile).

Rețineți că, atunci când implementezi task-uri în Airflow, nu trebuie neapărat să înțelegi fiecare pas în detaliu. Atâta timp cât știi cum să înglobezi pașii în structura Airflow, vei putea implementa orice workflow dorești.

Instrucțiuni

100 XP
  • Creează un task Airflow folosind metoda parse_file.
  • Apelează task-ul cu argumentele necesare.