Aufgrund der Mikrodienstarchitektur von Cloud Composer umfasst das End-to-End-Aktivitäts-Monitoring Ihrer Airflow-Konfiguration mehrere Messwerte. In dieser Anleitung wird ein Ansatz zur Verwendung der logbasierten Messwerte der Operations Suite von Google Cloud gezeigt, um Monitoring und Benachrichtigungen anhand eines benutzerdefinierten Messwerts einzurichten.
Lernziele
- Einfachen DAG bereitstellen, der im Abstand weniger Minuten in der Cloud Composer-Umgebung ausgeführt wird
- Logs nutzen, die die Operations Suite von Google Cloud für Cloud Composer generiert, um mithilfe der logbasierten Messwerte einen benutzerdefinierten Messwert zu erstellen
- Monitoring und Benachrichtigungen anhand des benutzerdefinierten Messwerts einrichten
Kosten
In diesem Dokument verwenden Sie die folgenden kostenpflichtigen Komponenten von Google Cloud:
- Cloud Composer
Mit dem Preisrechner können Sie eine Kostenschätzung für Ihre voraussichtliche Nutzung vornehmen.
Hinweis
- Melden Sie sich bei Ihrem Google Cloud-Konto an. Wenn Sie mit Google Cloud noch nicht vertraut sind, erstellen Sie ein Konto, um die Leistungsfähigkeit unserer Produkte in der Praxis sehen und bewerten zu können. Neukunden erhalten außerdem ein Guthaben von 300 $, um Arbeitslasten auszuführen, zu testen und bereitzustellen.
-
Wählen Sie in der Google Cloud Console auf der Seite der Projektauswahl ein Google Cloud-Projekt aus oder erstellen Sie eines.
-
Die Abrechnung für das Google Cloud-Projekt muss aktiviert sein.
-
Wählen Sie in der Google Cloud Console auf der Seite der Projektauswahl ein Google Cloud-Projekt aus oder erstellen Sie eines.
-
Die Abrechnung für das Google Cloud-Projekt muss aktiviert sein.
- Erstellen Sie eine Cloud Composer-Umgebung.
- Sorgen Sie dafür, dass Sie die entsprechenden Berechtigungen haben. Die folgenden Berechtigungen sind erforderlich, um auf Logs und Messwerte für die Cloud Composer-Umgebung zuzugreifen:
- Schreibgeschützter Zugriff auf Logging und Monitoring:
logging.viewer
undmonitoring.viewer
- Schreibgeschützter Zugriff auf Logging, einschließlich privater Logs:
logging.privateLogViewer
- Lese-/Schreibzugriff auf Monitoring:
monitoring.editor
Weitere Informationen finden Sie unter Zugriffssteuerung.
- Schreibgeschützter Zugriff auf Logging und Monitoring:
DAG in die Umgebung aufnehmen
Laden Sie den folgenden DAG in den Cloud Storage-Bucket für die Umgebung hoch:
import airflow from airflow import DAG from airflow.operators.bash_operator import BashOperator from datetime import timedelta default_args = { 'retries': 1, 'retry_delay': timedelta(minutes=5), 'start_date': airflow.utils.dates.days_ago(0) } dag = DAG( 'liveness', default_args=default_args, description='liveness monitoring dag', schedule_interval=timedelta(minutes=1)) t1 = BashOperator( task_id='echo', bash_command='echo test', dag=dag, depends_on_past=False)
Warten Sie, bis Airflow den DAG geplant hat. Sie können den Status in der Airflow-Weboberfläche prüfen.
Logbasierten Zählermesswert in der Operations Suite von Google Cloud erstellen
Zum Log-Explorer
Achten Sie darauf, dass oben auf der Seite das richtige Projekt ausgewählt ist, oder wählen Sie über das Drop-down-Menü oben auf der Seite ein Projekt aus.
Wählen Sie im Ressourcenfeld die Option Cloud Composer-Umgebung und dann den Standort und den Umgebungsnamen aus.
Wählen Sie im Feld für den Logtyp airflow-worker aus.
Erstellen Sie in der Filterleiste einen Filter, damit nur Logs angezeigt werden, die der Aktivitäts-DAG ausgibt. Geben Sie dafür das folgende Label ein: label:workflow:liveness.
Klicken Sie oben auf der Seite auf Messwert erstellen. Der Messwerteditor wird auf der rechten Seite und der Anzeigebereich mit Ihren Logs auf der linken Seite angezeigt.
Legen Sie im Messwerteditor Werte für die folgenden Felder fest:
- Name: Wählen Sie einen Namen aus, der unter den logbasierten Messwerten in Ihrem Projekt nur einmal vorkommt, z. B. liveness-logs-cnt.
- Beschreibung: Beschreiben Sie den Messwert.
- Typ: Zähler
Klicken Sie auf Messwert erstellen. Die Seite "Logbasierte Messwerte" wird angezeigt.
Benachrichtigungsrichtlinie erstellen
Klicken Sie auf der Seite "Logbasierte Messwerte" das Kästchen für den Messwert an, für den Sie eine Richtlinie erstellen möchten, und wählen Sie im Menü rechts neben dem Messwerteintrag Benachrichtigung mit dem Messwert erstellen aus. Die Seite Neue Benachrichtigungsrichtlinie erstellen wird angezeigt.
Klicken Sie auf der Seite Neue Benachrichtigungsrichtlinie erstellen im Bereich Bedingungen auf Bearbeiten. Ein bereits ausgefülltes Fenster Messwert erstellen wird angezeigt.
(Optional) Geben Sie einen Namen für die Bedingung ein.
Wählen Sie im Bereich "Ziel" für Aggregator den Wert Anzahl aus.
Legen Sie im Bereich "Konfiguration" für Grenzwert den Wert nach Bedarf fest.
Klicken Sie auf Speichern. Der Bereich Neue Benachrichtigungsrichtlinie erstellen wird mit der fertigen Bedingung angezeigt.
Füllen Sie die Bereiche Benachrichtigungen, Dokumentation und Richtlinie benennen der Benachrichtigungsrichtlinie aus.
Klicken Sie auf Speichern.
Bereinigen
Damit Ihrem Google Cloud-Konto die in dieser Anleitung verwendeten Ressourcen nicht in Rechnung gestellt werden, löschen Sie entweder das Projekt, das die Ressourcen enthält, oder Sie behalten das Projekt und löschen die einzelnen Ressourcen.
- Wechseln Sie in der Google Cloud Console zur Seite Ressourcen verwalten.
- Wählen Sie in der Projektliste das Projekt aus, das Sie löschen möchten, und klicken Sie dann auf Löschen.
- Geben Sie im Dialogfeld die Projekt-ID ein und klicken Sie auf Shut down (Beenden), um das Projekt zu löschen.
Nächste Schritte
Umzu erfahren, wie Sie Messwerte für die Cloud Composer-Umgebung mithilfe eines benutzerdefinierten Dashboards ansehen können, lesen Sie die Informationen unter Umgebungs- und Workflow-Monitoring in der Operations Suite von Google Cloud.