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

exercițiu

Crearea unui FileSensor

După ce ai citit despre FileSensors, decizi să implementezi unul de bază pentru a te familiariza cu parametrii folosiți. Acest FileSensor va fi configurat să verifice prezența unui fișier de date specific înainte de a continua.

Un FileSensor verifică existența fișierului la intervale regulate și oprește așteptarea odată ce au trecut timeout secunde. Cu mode='reschedule', slotul de worker este eliberat între verificări.

Instrucțiuni

100 XP
  • Importă biblioteca corespunzătoare pentru a folosi un FileSensor.
  • Atribuie referința precheck obiectului FileSensor.
  • Configurează FileSensor-ul să caute fișierul "salesdata_ready.csv".
  • Setează timeout-ul la 5 minute.