FileSensor 만들기
FileSensor에 대해 학습한 후, 주요 매개변수를 익히기 위해 기본적인 FileSensor를 직접 구현해 보기로 했습니다. 이 FileSensor는 작업을 계속하기 전에 특정 데이터 파일이 존재하는지 확인하는 역할을 합니다.
FileSensor는 일정한 간격으로 파일을 폴링하며, timeout초가 경과하면 대기를 중단합니다. mode='reschedule'을 설정하면 폴링 사이에 워커 슬롯이 해제됩니다.
이 연습은 강의의 일부입니다
Python으로 배우는 Apache Airflow 입문
연습 안내
- 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"
)