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

exercițiu

Decorarea unui task

Ai decis să implementezi un task specific în Airflow folosind Python. Acest task trebuie să descarce și să salveze un fișier în sistem, în cadrul Airflow, utilizând funcția pull_file. Funcția este deja definită pentru tine.

Biblioteca requests este deja importată, la fel și obiectul dag din Airflow.

Instrucțiuni

100 XP
  • Importă obiectul necesar din biblioteca Airflow.
  • Configurează funcția pull_file să fie un task Airflow.
  • Apelează obiectul task.