Python으로 DAG 스케줄 설정하기
DAG을 만드는 방법을 충분히 익혔으니, 이제 특정 DAG을 원하는 요일과 시간에 실행되도록 스케줄을 설정해 보겠습니다. 동료가 다른 서버에 DAG을 재설치해야 할 경우를 대비해, 스케줄 정보를 코드에 직접 포함시켜 두면 좋습니다.
Airflow의 dag 객체와 필요한 datetime 메서드는 이미 임포트되어 있습니다.
이 연습은 강의의 일부입니다
Python으로 배우는 Apache Airflow 입문
연습 안내
- DAG의 시작 날짜를 2025년 11월 1일로 설정하세요.
- cron 구문을 사용하여 매주 수요일 오후 12시 30분에 실행되는 스케줄을 구성하세요.
실습형 인터랙티브 연습
이 예제를 이 샘플 코드를 완성하여 풀어보세요.
@dag(
dag_id='update_dataflows',
# Set to November 1, 2025
start_date=datetime(____),
# Every Wednesday at 12:30pm
schedule='____'
)
def update_dataflows():
@task
def pull_source_data():
pass
update_dataflows()