Accedi all'interfaccia a riga di comando di Airflow

Airflow gestito (terza generazione) | Airflow gestito (seconda generazione) | Airflow gestito (prima generazione legacy)

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

Comandi CLI di Airflow supportati

Airflow in Airflow gestito (prima generazione legacy) fornisce due sintassi diverse per i comandi CLI:

Per un elenco completo dei comandi CLI di Airflow supportati, consulta la documentazione di riferimento del gcloud composer environments run comando.

Prima di iniziare

Per eseguire i comandi CLI di Airflow tramite Google Cloud CLI:

  • Il tuo Account Google deve disporre delle autorizzazioni per utilizzare Google Cloud CLI con Managed Airflow ed eseguire i comandi CLI di Airflow.

  • I comandi CLI di Airflow eseguiti tramite Google Cloud CLI consumano la environments.executeAirflowCommand quota.

Eseguire i comandi CLI di Airflow con gcloud CLI

Per eseguire i comandi CLI di Airflow nei tuoi ambienti, utilizza gcloud CLI:

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

Sostituisci quanto segue:

  • ENVIRONMENT_NAME: il nome del tuo ambiente.
  • LOCATION: la regione in cui si trova l'ambiente.
  • SUBCOMMAND: uno dei comandi CLI di Airflow supportati.
  • SUBCOMMAND_ARGUMENTS con gli argomenti per il comando CLI di Airflow.

Separatore degli argomenti dei sottocomandi

Separa gli argomenti per il comando CLI di Airflow 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 località. Puoi specificare la località con il --location flag o impostando la località predefinita.

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

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