Airflow 指令列介面

Apache Airflow 包含一個指令列介面 (CLI),可用於管理 Airflow 環境。CLI 很適合用來管理工作流程、變更 Airflow 環境及取得記錄資訊等工作。

Cloud Composer 透過 Google Cloud SDK 簡化了 Airflow CLI 指令。安裝完成後,您可以使用 gcloud 指令列工具執行 gcloud composer environments run 指令,藉此執行 Airflow CLI 子指令

事前準備

如要在 Cloud Composer 環境中存取 gcloud 指令列工具 (Airflow CLI),您必須具備下列權限:

  • composer.environments.get
  • container.clusters.get
  • container.clusters.list
  • container.clusters.getCredentials

詳情請參閱 Cloud Composer 存取權控管一文。

限制

請勿使用 Airflow resetdb 指令。這個指令會清除資料庫,包括 Cloud Composer 設定的連線。

執行 Airflow CLI 指令

您可以使用以下指令,在 Cloud Composer 環境中執行 Airflow CLI 指令:

gcloud composer environments run ENVIRONMENT_NAME \
    --location LOCATION SUBCOMMAND

大部分的 gcloud composer 指令都需要位置。如要指定位置,您可以使用 --location 標記或設定預設位置

舉例來說,如要在 Cloud Composer 環境中觸發名稱為 sample_quickstart 且 ID 為 5077 的 DAG,請使用以下指令:

gcloud composer environments run test-environment \
    --location us-central1 trigger_dag -- sample_quickstart \
    --run_id=1234

舉例來說,如要檢查 test/ 目錄中的 DAG 是否有語法錯誤,請使用以下指令:

gcloud composer environments run test-environment \
     --location us-central1 \
     list_dags -- -sd /home/airflow/gcs/data/test
本頁內容對您是否有任何幫助?請提供意見:

傳送您對下列選項的寶貴意見...

這個網頁
Cloud Composer