Airflow 명령줄 인터페이스 액세스

Managed Airflow (3세대) | Managed Airflow (2세대) | Managed Airflow (기존 1세대)

Apache Airflow에는 DAG 트리거 및 관리, DAG 실행 및 태스크 정보 가져오기, 연결 및 사용자 추가와 삭제 등의 작업을 수행하는 데 사용할 수 있는 명령줄 인터페이스 (CLI)가 있습니다.

지원되는 Airflow CLI 명령어

관리형 Airflow (기존 1세대)의 Airflow에서는 CLI 명령어용 구문을 2가지 제공합니다.

  • Airflow 1.10 CLI 구문: Airflow 1.10을 사용한 관리형 Airflow 환경에서 사용할 수 있습니다.

  • Airflow 2 CLI 구문: Airflow 2를 사용한 관리형 Airflow 환경에서 사용할 수 있습니다.

지원되는 Airflow CLI 명령어의 전체 목록은 gcloud composer environments run 명령어의 참조를 확인하세요.

시작하기 전에

Google Cloud CLI를 통해 Airflow CLI 명령어를 실행하려면 다음 안내를 따르세요.

  • Google 계정에 Managed Airflow에서 Google Cloud CLI를 사용하고 Airflow CLI권한 명령어를 실행할 수 있는 권한이 있어야 합니다.

  • Google Cloud CLI를 통해 실행되는 Airflow CLI 명령어는 environments.executeAirflowCommand 할당량을 사용합니다.

gcloud CLI로 Airflow CLI 명령어 실행

환경에서 Airflow CLI 명령어를 실행하려면 gcloud CLI를 사용합니다.

gcloud composer environments run ENVIRONMENT_NAME \
    --location LOCATION \
    SUBCOMMAND \
    -- SUBCOMMAND_ARGUMENTS

다음을 바꿉니다.

  • ENVIRONMENT_NAME: 환경의 이름입니다.
  • LOCATION: 환경이 위치한 리전
  • SUBCOMMAND: 지원되는 Airflow CLI 명령어 중 하나입니다.
  • SUBCOMMAND_ARGUMENTS를 Airflow CLI 명령어의 인수로 바꿉니다.

하위 명령어 인수 구분 기호

지정된 Airflow CLI 명령어의 인수를 --로 구분합니다.

Airflow 2

  • 복합 CLI 명령어를 하위 명령어로 지정합니다.
  • -- 구분 기호 뒤에 복합 명령어의 인수를 하위 명령어 인수로 지정합니다.

예:

gcloud composer environments run example-environment \
    dags list -- --output=json

Airflow 1

  • CLI 명령어를 하위 명령어로 지정합니다.
  • -- 구분 기호 뒤에 모든 인수를 지정합니다.

예:

gcloud composer environments run example-environment \
    list_dags -- --report

기본 위치

대부분 gcloud composer 명령어에는 위치가 필요합니다. 위치를 --location 플래그로 지정하거나 기본 위치를 설정할 수 있습니다.

예를 들어 Managed Airflow 환경에서 ID가 5077인 sample_quickstart라는 DAG를 트리거하려면 다음을 실행합니다.

Airflow 2 

gcloud composer environments run example-environment \
    --location us-central1 dags trigger -- sample_quickstart \
    --run-id=5077

Airflow 1 

gcloud composer environments run example-environment \
    --location us-central1 trigger_dag -- sample_quickstart \
    --run_id=5077

다음 단계