[Airflow] Airflow CLI 명령어

[Airflow] Airflow CLI 명령어

Airflow CLI를 사용해 작업 실행, 스케줄 조작, 작업 상태 확인 등 다양한 작업 수행이 가능함

airflow cheat-sheet 명령어를 통해 자주쓰이는 명령어를 확인 할 수 있으며 

airflow --help 명령어를 사용해서 자세한 도움말을 확인 할 수 있음 

 

아래는 일부 명령어이며,

airflow CLI에는 더 많은 명령어와 옵션이 있음 

 

arguments 

• dag _id  : 실행 할 DAG의 ID
• task_id : 실행할 task의 ID
• execution_date : 실행할 날짜와 시간 (YYYY-MM-DD 또는 ISO 8601 형식)

DAG ON

airflow dags pause [dag_id]

DAG OFF

airflow dags unpause [dag_id]

task 상태 확인

airflow tasks state [dag_id] [task_id] [execution_date_or_run_id]

task 클리어

airflow tasks clear [dag_id] --start-date [start_date] --end-date [end_date]

DAG 트리거

필요에 따라 --conf 플래그를 사용하여 매개변수 전달 가능

airflow dags trigger <dag_id> --conf '{"key": "value"}'

DAG 목록 확인

ariflow dag list

#dag의 실행정보 확인 가능 start/end date는 생략 가능
airflow dag run_list -d [dag_id] --start-date [start_date] --end-date [end_date]

task 목록 확인

airflow tasks list [dag_id]