Airflow Schedule 정의

Schdule 하지 않은 DAG 사용자 이벤트 데이터는 BashOperator를 이용해 가져오고, 통계 및 계산은 PythonOperator를 사용해 Pandas DataFrame에 데이터 로드한 후 groupby 및 aggregation을 사용해 이벤트 개수를 확인합니다. import datetime as dt from pathlib import Path import pandas as pd from airflow import DAG from airflow.operator.bash import BashOperator from airflow.operator.python import PythonOperator dag=DAG( dag_id="schdule_id", start_date=dt.datetime(2022, 1, 1), # DAG의 시작 날짜를 정의 schedule_interval=None # 스케쥴되지 않는 DAG로 지정 ) fetch_events=BashOperator( tas...

원문링크 : Airflow Schedule 정의