Acceder a la interfaz de línea de comandos de Airflow

Cloud Composer 3 | Cloud Composer 2 | Cloud Composer 1

Apache Airflow tiene una interfaz de línea de comandos (CLI) que puedes usar para realizar tareas como activar y gestionar DAGs, obtener información sobre ejecuciones de DAGs y tareas, y añadir y eliminar conexiones y usuarios.

Comandos de la CLI de Airflow admitidos

Airflow en Cloud Composer 1 ofrece dos sintaxis diferentes para los comandos de la CLI:

Para ver una lista completa de los comandos de la CLI de Airflow compatibles, consulta la referencia del comando gcloud composer environments run.

Antes de empezar

  • Debes tener permisos para usar la CLI de Google Cloud con Cloud Composer y ejecutar comandos de la CLI de Airflow.

  • Los comandos de la CLI de Airflow consumen la environments.executeAirflowCommand cuota.

Ejecutar comandos de la CLI de Airflow

Para ejecutar comandos de la CLI de Airflow en tus entornos, usa la CLI de gcloud:

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

Sustituye lo siguiente :

  • ENVIRONMENT_NAME: el nombre de tu entorno.
  • LOCATION: la región en la que se encuentra el entorno.
  • SUBCOMMAND: uno de los comandos de la CLI de Airflow admitidos.
  • SUBCOMMAND_ARGUMENTS con argumentos para el comando de la CLI de Airflow.

Separador de argumentos de subcomando

Separa los argumentos del comando de la CLI de Airflow especificado con --:

Airflow 2

  • Especifica comandos de la CLI compuestos como subcomandos.
  • Especifica los argumentos de los comandos compuestos como argumentos de subcomando después de un separador --.

Ejemplo:

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

Airflow 1

  • Especifica los comandos de la CLI como subcomando.
  • Especifica los argumentos después de un separador --.

Ejemplo:

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

Ubicación predeterminada

La mayoría de los comandos de gcloud composer requieren una ubicación. Puedes especificar la ubicación con la marca --location o configurar la ubicación predeterminada.

Por ejemplo, para activar un DAG llamado sample_quickstart con el ID 5077 en tu entorno de Cloud Composer, haz lo siguiente:

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

Siguientes pasos