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

Connected

ćwiczenie

Dekorowanie zadania

Postanawiasz zaimplementować konkretne zadanie Airflow w Pythonie. Zadanie ma pobierać plik i zapisywać go w systemie w ramach Airflow – do tego celu służy funkcja pull_file, która jest już zdefiniowana.

Biblioteka requests oraz obiekt dag Airflow są już zaimportowane.

Instrukcje

100 XP
  • Zaimportuj niezbędny obiekt z biblioteki Airflow.
  • Skonfiguruj funkcję pull_file jako zadanie Airflow.
  • Wywołaj obiekt zadania.