As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

Referência de comandos da CLI do Apache Airflow

Este tópico descreve os comandos da CLI do Apache Airflow compatíveis e não suportados nos fluxos de trabalho gerenciados da Amazon para o Apache Airflow.

Pré-requisitos

A seção a seguir descreve as etapas preliminares necessárias para usar os comandos e scripts desta página.

Acesso

AWS CLI

O AWS Command Line Interface (AWS CLI) é uma ferramenta de código aberto que você pode usar para interagir com AWS serviços usando comandos em seu shell de linha de comando. Para concluir as etapas nesta página, é necessário o seguinte:

O que mudou?

Comandos CLI compatíveis

A seção a seguir lista os comandos da CLI do Apache Airflow disponíveis no Amazon MWAA.

Comandos compatíveis

Apache Airflow v3

Versões secundárias	Command
v3.0.6	detalhes dos ativos
v3.0.6	lista de ativos
v3.0.6	ativos se materializam
v3.0.6	criação de preenchimento
v3.0.6	cheat-sheet
v3.0.6	connections add
v3.0.6	connections delete
v3.0.6	dags delete
v3.0.6	dags list
v3.0.6	dags list-jobs
v3.0.6	punhetas list-import-errors
v3.0.6	dags list-runs
v3.0.6	dags next-execution
v3.0.6	dags pause
v3.0.6	dags report
v3.0.6	dags reserialize
v3.0.6	dags show
v3.0.6	dags state
v3.0.6	dags test
v3.0.6	dags trigger
v3.0.6	dags unpause
v3.0.6	db clean
v3.0.6	providers behaviours
v3.0.6	providers get
v3.0.6	providers hooks
v3.0.6	providers links
v3.0.6	providers list
v3.0.6	notificações de provedores
v3.0.6	providers secrets
v3.0.6	providers triggerer
v3.0.6	providers widgets
v3.0.6	roles add-perms
v3.0.6	roles del-perms
v3.0.6	roles create
v3.0.6	roles list
v3.0.6	tasks clear
v3.0.6	tasks failed-deps
v3.0.6	tasks list
v3.0.6	tasks render
v3.0.6	tasks state
v3.0.6	tarefas states-for-dag-run
v3.0.6	tasks test
v3.0.6	variables delete
v3.0.6	variables get
v3.0.6	variables set
v3.0.6	variables list
v3.0.6	version

Apache Airflow v2

Versões secundárias	Command
v2.0+	cheat-sheet
v2.0+	connections add
v2.0+	connections delete
v2.2+ (nota)	dags backfill
v2.0+	dags delete
v2.2+ (nota)	dags list
v2.0+	dags list-jobs
v2.6+	punhetas list-import-errors
v2.2+ (nota)	dags list-runs
v2.2+ (nota)	dags next-execution
v2.0+	dags pause
v2.0+	dags report
v2.4+	dags reserialize
v2.0+	dags show
v2.0+	dags state
v2.0+	dags test
v2.0+	dags trigger
v2.0+	dags unpause
v2.4+	db clean
v2.0+	providers behaviours
v2.0+	providers get
v2.0+	providers hooks
v2.0+	providers links
v2.0+	providers list
v2.8+	notificações de provedores
v2.6+	providers secrets
v2.7+	providers triggerer
v2.0+	providers widgets
v2.6+	roles add-perms
v2.6+	roles del-perms
v2.6+	roles create
v2.0+	roles list
v2.0+	tasks clear
v2.0+	tasks failed-deps
v2.0+	tasks list
v2.0+	tasks render
v2.0+	tarefas executadas
v2.0+	tasks state
v2.0+	tarefas states-for-dag-run
v2.0+	tasks test
v2.0+	variables delete
v2.0+	variables get
v2.0+	variables set
v2.0+	variables list
v2.0+	version

Usando comandos que analisam DAGs

Se seu ambiente estiver executando o Apache Airflow v2.0.2, os comandos da CLI que DAGs analisam falharão se o DAG usar plug-ins que dependem de pacotes instalados por meio de: requirements.txt

Você pode usar esses comandos da CLI se DAGs não usar plug-ins que dependam de pacotes instalados por meio de um. requirements.txt

Código de exemplo

A seção a seguir contém exemplos de maneiras diferentes de usar a CLI do Apache Airflow.

Definir, obter ou excluir uma variável do Apache Airflow v2

É possível usar o código de exemplo a seguir para definir, obter ou excluir uma variável no formato de <script> <mwaa env name> get | set | delete <variable> <variable value> </variable> </variable>.

[ $# -eq 0 ] && echo "Usage: $0 MWAA environment name " && exit

if [[ $2 == "" ]]; then
    dag="variables list"

elif  [ $2 == "get" ] ||  [ $2 == "delete" ] ||  [ $2 == "set" ]; then
    dag="variables $2 $3 $4 $5"

else
    echo "Not a valid command"
    exit 1
fi

CLI_JSON=$(aws mwaa --region $AWS_REGION create-cli-token --name $1) \
    && CLI_TOKEN=$(echo $CLI_JSON | jq -r '.CliToken') \
    && WEB_SERVER_HOSTNAME=$(echo $CLI_JSON | jq -r '.WebServerHostname') \
    && CLI_RESULTS=$(curl --request POST "https://$WEB_SERVER_HOSTNAME/aws_mwaa/cli" \
    --header "Authorization: Bearer $CLI_TOKEN" \
    --header "Content-Type: text/plain" \
    --data-raw "$dag" ) \
    && echo "Output:" \
    && echo $CLI_RESULTS | jq -r '.stdout' | base64 --decode \
    && echo "Errors:" \
    && echo $CLI_RESULTS | jq -r '.stderr' | base64 --decode

Adicionar uma configuração ao acionar um DAG

Você pode usar o código de exemplo a seguir com o Apache Airflow v2 para adicionar uma configuração ao acionar um DAG, como. airflow trigger_dag 'dag_name' —conf '{"key":"value"}'

import boto3
import json
import requests 
import base64
				
  mwaa_env_name = 'YOUR_ENVIRONMENT_NAME'
  dag_name = 'YOUR_DAG_NAME'
  key = "YOUR_KEY"
  value = "YOUR_VALUE"
  conf = "{\"" + key + "\":\"" + value + "\"}"
				
  client = boto3.client('mwaa')
				
  mwaa_cli_token = client.create_cli_token(
    Name=mwaa_env_name
  )
				
  mwaa_auth_token = 'Bearer ' + mwaa_cli_token['CliToken']
  mwaa_webserver_hostname = 'https://{0}/aws_mwaa/cli'.format(mwaa_cli_token['WebServerHostname'])
  raw_data = "trigger_dag {0} -c '{1}'".format(dag_name, conf)
				
  mwaa_response = requests.post(
    mwaa_webserver_hostname,
    headers={
      'Authorization': mwaa_auth_token,
      'Content-Type': 'text/plain'
    },
    data=raw_data
  )
				
  mwaa_std_err_message = base64.b64decode(mwaa_response.json()['stderr']).decode('utf8')
  mwaa_std_out_message = base64.b64decode(mwaa_response.json()['stdout']).decode('utf8')
				
  print(mwaa_response.status_code)
  print(mwaa_std_err_message)
  print(mwaa_std_out_message)

Execute comandos CLI em um túnel SSH para um bastion host

Use o exemplo a seguir para executar comandos da CLI do Airflow usando um proxy de túnel SSH para um Linux Bastion Host.