Accedi all'interfaccia a riga di comando di Airflow

Cloud Composer 3 | Cloud Composer 2 | Cloud Composer 1

Apache Airflow ha un'interfaccia a riga di comando (CLI) che puoi utilizzare per eseguire attività come l'attivazione e la gestione di DAG, l'ottenimento di informazioni sulle esecuzioni di DAG e sulle attività, l'aggiunta e l'eliminazione di connessioni e utenti.

Comandi dell'interfaccia a riga di comando Airflow supportati

Airflow in Cloud Composer 1 fornisce due sintassi diverse per i comandi CLI:

Per un elenco completo dei comandi dell'interfaccia a riga di comando di Airflow supportati, consulta la documentazione di riferimento del comando gcloud composer environments run.

Prima di iniziare

  • Devi disporre delle autorizzazioni per utilizzare Google Cloud CLI con Cloud Composer ed eseguire i comandi dell'interfaccia a riga di comando Airflow.

  • I comandi dell'interfaccia a riga di comando di Airflow consumano la environments.executeAirflowCommand quota.

Esegui i comandi dell'interfaccia a riga di comando di Airflow

Per eseguire i comandi dell'interfaccia a riga di comando di Airflow nei tuoi ambienti, utilizza gcloud CLI:

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

Sostituisci quanto segue :

Separatore degli argomenti dei sottocomandi

Separa gli argomenti per il comando Airflow CLI specificato con --:

Airflow 2

  • Specifica i comandi CLI composti come sottocomando.
  • Specifica gli argomenti per i comandi composti come argomenti dei sottocomandi, dopo un separatore --.

Esempio:

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

Airflow 1

  • Specifica i comandi CLI come sottocomando.
  • Specifica gli argomenti dopo un separatore --.

Esempio:

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

Località predefinita

La maggior parte dei comandi gcloud composer richiede una posizione. Puoi specificare la posizione con il flag --location o impostando la posizione predefinita.

Ad esempio, per attivare un DAG denominato sample_quickstart con l'ID 5077 nel tuo ambiente Cloud Composer:

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

Passaggi successivi