Einen FileSensor erstellen

Nachdem du über FileSensoren gelesen hast, willst du einen einfachen umsetzen, um ein Gefühl für die verwendeten Parameter zu bekommen. Dieser FileSensor soll sicherstellen, dass eine bestimmte Datendatei vorhanden ist, bevor es weitergeht.

Ein FileSensor fragt die Datei in regelmäßigen Abständen ab und beendet das Warten, sobald timeout Sekunden verstrichen sind. Mit mode='reschedule' wird der Worker-Slot zwischen den Abfragen freigegeben.

Diese Übung ist Teil des Kurses

<Kurs>Einführung in Apache Airflow mit Python</Kurs>

Kurs ansehen

Übungsanweisungen

Importiere die passende Bibliothek, um einen FileSensor zu verwenden.
Weise precheck das FileSensor-Objekt zu.
Lass den FileSensor nach der Datei "salesdata_ready.csv" suchen.
Setze das Timeout auf 5 Minuten.

Interaktive praktische Übung

Versuche dich an dieser Übung, indem du diesen Beispielcode vervollständigst.

# Import the FileSensor class
from airflow.providers.standard.sensors.filesystem import ____

# Set the file sensor to an alias
precheck = ____(
  task_id='check_for_datafile',
  # Wait for this file to exist before continuing
  filepath='____',
  timeout=____,
  mode="reschedule"
)

Code bearbeiten und ausführen