Cloud Composer 1 | Cloud Composer 2 | Cloud Composer 3
Auf dieser Seite wird erläutert, wie Sie Informationen zu DAGs in Ihrer Umgebung abrufen.
Informationen zu DAGs aufrufen
Cloud Composer bietet mehrere Möglichkeiten, detaillierte Informationen zu DAGs in Ihrer Umgebung abzurufen:
- Die DAG-UI ist ein Bereich der Google Cloud Console-Oberfläche für Cloud Composer zum Anzeigen und Überwachen von DAGs, DAG-Ausführungen und individuelle Aufgaben.
- Die Airflow-Benutzeroberfläche ist die integrierte Weboberfläche von Airflow.
- Die Airflow-Befehlszeile ist die Befehlszeile von Airflow. Ich
Informationen zu DAGs können Sie abrufen, indem Sie Airflow-Befehlszeilenbefehle mit
gcloud
Cloud Composer DAG-Benutzeroberfläche
Die DAG-Benutzeroberfläche ist ein Bereich der Google Cloud Console-Oberfläche für Cloud Composer, in dem DAGs, DAG-Ausführungen und einzelne Aufgaben angezeigt und überwacht werden können.
In der DAG-UI haben Sie folgende Möglichkeiten:
Liste der DAGs in Ihrer Umgebung mit Zeitplanintervallen, DAG-Status und Beschreibungen aufrufen
Sie können DAGs pausieren, die Pausierung aufheben und auslösen.
Details zur DAG-Ausführung ansehen, einschließlich erfolgreicher, aktiver und fehlgeschlagener Ausführungen, Uhrzeit seit der letzten abgeschlossenen Ausführung. Für jeden DAG können Sie den Verlauf der DAG-Ausführungen und Aufgabeninstanzen sehen, die mit diesem DAG verknüpft sind, einschließlich Logs für ausgeführte Aufgaben.
DAG-Ausführungsdetails filtern. Sie können beispielsweise ein Zeitintervall auswählen und Abfragen erstellen, um die gewünschten Informationen auszuwählen.
Detaillierte Informationen zu einzelnen DAGs und Aufgaben aufrufen Dazu gehören visualisierte DAG-Diagramme, Informationen zu den Aufgaben innerhalb eines DAG, DAG-Quellcode und zusätzliche Informationen zu DAGs.
Hinweise
Ihr Konto muss eine Rolle haben, die auf die DAG-UI zugreifen und DAG aufrufen kann Details. Weitere Informationen finden Sie unter Zugriffssteuerung.
Für die DAG-UI ist die aktivierte DAG-Serialisierung erforderlich.
Die DAG-Benutzeroberfläche wird in Cloud Composer 1.17.8 und höher unterstützt.
Liste der DAGs für Ihre Umgebung aufrufen
Console
Auf dem Tab DAGs Ihrer Umgebung werden die Liste der DAGs zusammen mit dem DAG angezeigt. Ausführungsdetails für jeden DAG.
So rufen Sie die Liste der DAGs auf:
Rufen Sie in der Google Cloud Console die Seite Umgebungen auf.
Klicken Sie in der Spalte DAG-Liste auf den Link DAGs für Ihre Umgebung.
Sie können Filter verwenden, um die Details nur für bestimmte DAGs oder für bestimmte Bedingungen zu erfüllen. Beispiel:
- Wählen Sie das Feld Filter aus.
- Wählen Sie in der Drop-down-Liste die Property DAG-ID aus.
- Geben Sie die Kennung des DAG an. Die Ergebnisse enthalten nur Details für die ausgewählte DAG.
- Optional: Um weitere DAGs einzubeziehen, fügen Sie
OR-Operatoren gefolgt von DAG-IDs hinzu. - Optional: Wenn Sie nach anderen Bedingungen filtern möchten, fügen Sie dem Feld Filter weitere Properties hinzu. Wenn Sie beispielsweise nach DAGs mit fehlgeschlagenen Ausführungen filtern möchten, geben Sie
Failed runs:>0an.
Airflow-UI
So rufen Sie die Liste der DAGs in der Airflow-Weboberfläche auf:
Rufen Sie in der Google Cloud Console die Seite Umgebungen auf.
Klicken Sie in der Spalte Airflow-Webserver auf den Link Airflow für Ihre Umgebung.
Melden Sie sich mit einem Google-Konto an, das über die entsprechenden Berechtigungen verfügt.
Auf der Seite DAGs der Airflow-Weboberfläche wird eine Liste der DAGs für Ihre Umgebung angezeigt.
gcloud
Führen Sie in Airflow 1.10.* den Befehl list_dags der Airflow-Befehlszeile aus:
gcloud composer environments run ENVIRONMENT_NAME \
--location LOCATION \
list_dags
Führen Sie in Airflow 2 den Befehl dags list der Airflow-Befehlszeile aus:
gcloud composer environments run ENVIRONMENT_NAME \
--location LOCATION \
dags list -- -o plain
Ersetzen Sie:
ENVIRONMENT_NAMEdurch den Namen der Umgebung.LOCATIONdurch die Region, in der sich die Umgebung befindet.
Verlauf von DAG-Ausführungen und -Aufgaben ansehen
Console
Auf der Seite DAG-Details finden Sie auf dem Tab Ausführungen den Verlauf der DAG-Ausführungen. für einen einzelnen DAG.
So rufen Sie den Verlauf von DAG-Ausführungen auf:
Rufen Sie in der Google Cloud Console die Seite Umgebungen auf.
Klicken Sie in der Spalte DAG-Liste auf den Link DAGs für Ihre Umgebung.
Wählen Sie einen DAG aus.
Rufen Sie auf der Seite DAG-Details den Tab Ausführungen auf.
Wählen Sie in der Liste eine DAG-Ausführung aus, um die Details dazu aufzurufen, z. B. den Status der Aufgabeninstanzen für diese DAG-Ausführung, die Anzahl der Versuche und die Ausführungsdauer. Sie können einzelne Aufgaben auswählen, die Sie sich ansehen möchten Taskinstanzlogs.
Airflow-UI
So rufen Sie die Liste der DAGs in der Airflow-Weboberfläche auf:
Rufen Sie in der Google Cloud Console die Seite Umgebungen auf.
Klicken Sie in der Spalte Airflow-Webserver auf den Link Airflow für Ihre Umgebung.
Melden Sie sich mit einem Google-Konto an, das über die entsprechenden Berechtigungen verfügt.
Wählen Sie in der Airflow-Weboberfläche im Menü die Option Durchsuchen > DAG-Ausführungen: Auf der Seite DAG-Ausführungen werden DAG-Ausführungen für Ihre Umgebung angezeigt. Sie können dem Link in der Run ID (Ausführungs-ID) um zusätzliche Informationen zu Aufgaben zu erhalten.
gcloud
Führen Sie in Airflow 1.10.* den Befehl list_dag_runs der Airflow-Befehlszeile aus:
gcloud composer environments run ENVIRONMENT_NAME \
--location LOCATION \
list_dag_runs -- DAG_ID
Führen Sie in Airflow 2 den Befehl dags list-runs der Airflow-Befehlszeile aus:
gcloud composer environments run ENVIRONMENT_NAME \
--location LOCATION \
dags list-runs -- -d DAG_ID
Ersetzen Sie:
ENVIRONMENT_NAMEdurch den Namen der Umgebung.LOCATIONdurch die Region, in der sich die Umgebung befindet.DAG_IDdurch den Namen des DAG.
Mit den Airflow-Befehlen tasks state und tasks states-for-dag-run können Sie zusätzliche Informationen zu Aufgabeninstanzen abrufen.
Weitere Informationen finden Sie unter Auf die Airflow-Befehlszeile zugreifen und die Referenz zur Airflow-Befehlszeile für Airflow 1 und Airflow 2.
DAG-Diagramme ansehen
Console
Auf dem Tab Diagramm der Seite DAG-Details wird ein DAG mit Aufgabenabhängigkeiten visualisiert.
So rufen Sie das Diagramm eines DAG auf:
Rufen Sie in der Google Cloud Console die Seite Umgebungen auf.
Klicken Sie in der Spalte DAG-Liste auf den Link DAGs für Ihre Umgebung.
Wählen Sie einen DAG aus.
Wechseln Sie auf der Seite DAG-Details zum Tab Diagramm.
Optional: Wenn Sie zusätzliche Informationen zu Aufgaben sehen möchten, wählen Sie einzelne Aufgaben im Diagramm aus.
Airflow-UI
So rufen Sie das Diagramm eines DAGs in der Airflow-Weboberfläche auf:
Rufen Sie in der Google Cloud Console die Seite Umgebungen auf.
Klicken Sie in der Spalte Airflow-Webserver auf den Link Airflow für Ihre Umgebung.
Melden Sie sich mit einem Google-Konto an, das über die entsprechenden Berechtigungen verfügt.
Auf der Seite DAGs der Airflow-Weboberfläche wird eine Liste der DAGs für Ihre Umgebung angezeigt.
Klicken Sie für Ihren DAG in der Spalte Links auf den Link Grafikansicht.
DAG-Quellcode und zusätzliche Informationen zu DAGs ansehen
Console
Sie können den Quellcode Ihrer DAGs und zusätzliche Informationen wie DAG-IDs und Links zu DAG-Definitionsdateien in der Umgebung Bucket.
Rufen Sie in der Google Cloud Console die Seite Umgebungen auf.
Klicken Sie in der Spalte DAG-Liste auf den Link DAGs für Ihre Umgebung.
Wählen Sie einen DAG aus.
Den DAG-Quellcode finden Sie auf dem Tab Diagramm.
Weitere Informationen zum DAG finden Sie auf dem Tab Quelle.
Airflow-UI
So rufen Sie das Diagramm eines DAGs in der Airflow-Weboberfläche auf:
Rufen Sie in der Google Cloud Console die Seite Umgebungen auf.
Klicken Sie in der Spalte Airflow-Webserver auf den Link Airflow für Ihre Umgebung.
Melden Sie sich mit einem Google-Konto an, das über die entsprechenden Berechtigungen verfügt.
Klicken Sie in der Airflow-Weboberfläche auf der Seite DAGs auf den Namen Ihres DAG.
Gehen Sie auf der Seite mit den DAG-Details zu den verfügbaren Tabs, die Sie ansehen möchten Informationen zum DAG.