Auf Airflow-Befehlszeile zugreifen

Managed Airflow (Gen 3) | Managed Airflow (Gen 2) | Managed Airflow (Legacy Gen 1)

Apache Airflow bietet eine Befehlszeile, mit der Sie Aufgaben wie das Auslösen und Verwalten von DAGs, das Abrufen von Informationen zu DAG-Ausführungen und -Aufgaben, das Hinzufügen und Löschen von Verbindungen und Nutzern ausführen können.

Unterstützte Befehle der Airflow-Befehlszeile

Airflow in Managed Airflow (Legacy Gen 1) bietet zwei verschiedene Syntaxen für Befehlszeilenbefehle:

Eine vollständige Liste der unterstützten Airflow-Befehlszeilenbefehle finden Sie in der Referenz zum gcloud composer environments run Befehl.

Hinweis

Für die Ausführung von Airflow-Befehlszeilenbefehlen über die Google Cloud CLI gilt Folgendes:

  • Ihr Google-Konto muss die Berechtigungen haben, die Google Cloud CLI mit Managed Airflow zu verwenden und Airflow-Befehlszeilen befehle auszuführen.

  • Airflow-Befehlszeilenbefehle, die über die Google Cloud CLI ausgeführt werden, verbrauchen das environments.executeAirflowCommand Kontingent.

Befehle der Airflow-Befehlszeile mit der gcloud CLI ausführen

Zum Ausführen von Befehlen der Airflow-Befehlszeile in Ihren Umgebungen verwenden Sie die gcloud CLI:

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

Ersetzen Sie Folgendes:

  • ENVIRONMENT_NAME: der Name Ihrer Umgebung
  • LOCATION: die Region, in der sich die Umgebung befindet
  • SUBCOMMAND: einer der unterstützten Befehle der Airflow-Befehlszeile.
  • SUBCOMMAND_ARGUMENTS durch Argumente für den Befehl der Airflow-Befehlszeile

Trennzeichen für Unterbefehle

Trennen Sie die Argumente für den angegebenen Befehl der Airflow-Befehlszeile durch --:

Airflow 2

  • Geben Sie komplexe Befehlszeilenbefehle als Unterbefehl an.
  • Geben Sie nach dem Trennzeichen -- Argumente für zusammengesetzte Befehle als Unterbefehlsargumente an.

Beispiel:

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

Airflow 1

  • Geben Sie die Befehlszeilenbefehle als Unterbefehl an.
  • Geben Sie alle Argumente nach dem Trennzeichen -- an.

Beispiel:

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

Standardort

Für die meisten gcloud composer-Befehle ist ein Speicherort erforderlich. Sie können den Speicherort mit dem --location Flag oder durch Festlegen des standardmäßigen Standorts angeben.

So lösen Sie beispielsweise einen DAG namens sample_quickstart mit der ID 5077 in Ihrer Managed Airflow-Umgebung aus:

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

Nächste Schritte