Airflow 스케줄링

 

 

• Airflow 스케줄러
  • 모든 작업, 모든 DAG모니티링하여 작업 인스턴스를 트리거
  • DAG 개체 폴더를 모니터링하고 동기화하여 유지하여 정기적(1분)으로 트리거
  • DAG 파일들 확인하여 작업, 스케줄링 간격들을 확인하여 처리
• Airflow 스케줄러 로그
  • 날짜 기준으로 자동으로 수집처리됨

 

 

• 스케줄러 자동
  • 기본적으로 UTC 기준으로 동작하므로 KST로 변경하여 사용해야함.

 

 

 

• 스케줄러 설정
  • 시간(UTC -> KST)
  • 간격 설정(Schedule_interval)
  • DAGs 코드상에서 변경

 

• 스케줄링 Schedule_interval
  • Start_date : 시작할 시점
  • end_date : 시작할 시점
  • Schedule_interval : 스케줄 시간 시점