1. Učit se
    2. /
  2. Kurzy
    3. /
  3. Úvod do Apache Airflow v Pythonu
Connected

Cvičení

Vytvoření FileSensoru

Po přečtení o FileSensorech se rozhodneš vyzkoušet si implementaci základního senzoru, abys lépe pochopil/a, jak fungují jeho parametry. Tento FileSensor bude hlídat, jestli je před dalším zpracováním přítomný konkrétní datový soubor.

FileSensor pravidelně kontroluje existenci souboru a přestane čekat buď po jeho nalezení, nebo po uplynutí timeout sekund. S nastavením mode='reschedule' se mezi jednotlivými kontrolami uvolní slot workeru.

Pokyny

100 XP
  • Naimportuj příslušnou knihovnu pro použití FileSensoru.
  • Přiřaď do proměnné precheck objekt FileSensoru.
  • Nastav FileSensor tak, aby hledal soubor „salesdata_ready.csv".
  • Nastav timeout na 5 minut.