Створення FileSensor

Після ознайомлення з FileSensor ви вирішили спробувати реалізувати базовий приклад, щоб відчути, які параметри з ним зазвичай використовують. Цей FileSensor має перевіряти наявність певного файлу даних, перш ніж рухатися далі.

FileSensor опитує наявність файлу з регулярним інтервалом і припиняє очікування після спливу timeout секунд. З параметром mode='reschedule' слот виконавця звільняється між опитуваннями.

Ця вправа є частиною курсу

Вступ до Apache Airflow на Python

Переглянути курс

Інструкції до вправи

Імпортуйте потрібну бібліотеку для використання FileSensor.
Присвойте посиланню precheck об'єкт FileSensor.
Налаштуйте FileSensor на пошук файлу "salesdata_ready.csv".
Встановіть тайм-аут на 5 хвилин.

Інтерактивна практична вправа

Спробуйте виконати цю вправу, доповнивши цей зразок коду.

# 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"
)

Редагувати та запускати код