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

Airflow administrado (3ª gen.) | Airflow administrado (2ª gen.) | Airflow administrado (1ª gen. heredada)

Apache Airflow tiene una interfaz de línea de comandos (CLI) que puedes usar para realizar tareas como activar y administrar DAG, obtener información sobre las ejecuciones y tareas de DAG, agregar y borrar conexiones y usuarios.

Comandos compatibles con la CLI de Airflow

Airflow en Airflow administrado (1ª gen. heredada) proporciona dos sintaxis diferentes para los comandos de la CLI:

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

Antes de comenzar

Para ejecutar comandos de la CLI de Airflow a través de Google Cloud CLI, haz lo siguiente:

  • Tu Cuenta de Google debe tener permisos para usar Google Cloud CLI con Airflow administrado y ejecutar comandos de la CLI de Airflow.

  • Los comandos de la CLI de Airflow que se ejecutan a través de Google Cloud CLI consumen la environments.executeAirflowCommand cuota.

Ejecuta comandos de la CLI de Airflow con gcloud CLI

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

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

Reemplaza lo siguiente:

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

Separador de argumentos del subcomando

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

Airflow 2

  • Especifica los comandos compuestos de la CLI como subcomando.
  • Especifica los argumentos para los comandos compuestos como argumentos de subcomandos, 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 gcloud composer requiere una ubicación. Puedes especificar la ubicación con la marca --location o si configuras la ubicación predeterminada.

Por ejemplo, para activar un DAG con el nombre sample_quickstart y el ID 5077 en tu entorno de Airflow administrado, ejecuta 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

¿Qué sigue?