Search

Airflow 자주 쓰는 명령어 정리

airflow cli

airflow dags show schedule_test airflow tasks list <DAG_ID> airflow dags unpause <DAG_ID> airflow dags pause <DAG_ID> airflow dags trigger <DAG_ID> airflow dags list-runs -d <DAG_ID> airflow dags list airflow dags test dag_id execution_date # airflow parsing이 안되는 이유 확인 airflow dags list-import-errors airflow tasks states-for-dag-run <DAG_ID> <execution_date_or_run_id> airflow tasks clear \ -d <DAG_ID> \ -s 2023-01-06T03:05:00+00:00 -e 2023-01-06T03:05:00+00:00 view /<base_log_folder>/<DAG_ID>/<TASK_ID>/<EXECUTION_DATE>/<TRY_NUMBER>.log airflow cheat-sheet
Shell
복사

메타 데이터 베이스

airflow db init: 메타 데이터베이스를 초기화합니다. 이 명령어는 Airflow가 처음 설치될 때 사용되며, 필요한 테이블과 구조를 생성합니다. airflow db reset: 기존의 메타 데이터베이스를 삭제하고 새로 초기화합니다. 이 명령어는 기존 데이터를 모두 삭제하므로 주의해서 사용해야 합니다. airflow db upgrade: 메타 데이터베이스의 스키마를 최신 버전으로 업그레이드합니다. Airflow의 버전을 업그레이드 할 때 사용됩니다. airflow db downgrade: 메타 데이터베이스의 스키마를 이전 버전으로 다운그레이드합니다. 특정 버전으로 롤백이 필요할 때 사용됩니다. airflow db check: 메타 데이터베이스의 연결과 상태를 확인합니다. 데이터베이스 설정이 올바르게 구성되었는지 검증할 때 사용됩니다. airflow db shell: 메타 데이터베이스의 SQL 쉘에 직접 접근합니다. 데이터베이스 쿼리를 수행하거나 직접적인 데이터베이스 관리 작업을 할 때 유용합니다.
Shell
복사