1. Nauka
    2. /
  2. Kursy
    3. /
  3. Wprowadzenie do Apache Airflow w Pythonie
Connected

ćwiczenie

Więcej dekoratorów @task

Aby kontynuować budowanie swojego przepływu pracy, musisz dodać kolejny krok – parsowanie i zapisywanie zmian z pobranego pliku. DAG process_sales jest już zdefiniowany i zawiera zadanie pull_file. W tym przypadku funkcja Pythona jest już dla ciebie gotowa: parse_file(inputfile, outputfile).

Pamiętaj, że podczas implementowania zadań w Airflow nie zawsze musisz rozumieć każdy szczegół poszczególnych kroków. Wystarczy, że wiesz, jak opakować je w strukturę Airflow – i już możesz z powodzeniem zbudować dowolny przepływ pracy.

Instrukcje

100 XP
  • Utwórz zadanie Airflow, używając metody parse_file.
  • Wywołaj zadanie z wymaganymi argumentami.