Cloud Composer 1 | Cloud Composer 2 | Cloud Composer 3
Auf dieser Seite wird beschrieben, wie Sie den Status Ihrer Umgebung mithilfe von Umgebungs-Snapshots speichern und laden.
Sie können Ihre Umgebung so konfigurieren, dass Snapshots automatisch gespeichert werden. Weitere Informationen Geplante Snapshots konfigurieren.
Umgebungs-Snapshots
In Umgebungs-Snapshots wird der Status Ihrer Umgebung gespeichert. Sie können speichern und wenn Sie Umgebungs-Snapshots bei Bedarf laden möchten.
Snapshots können für Folgendes verwendet werden:
Stellen Sie Ihre Umgebung in einen früheren Zustand wieder her. Erstellen Sie Sicherungen Ihrer mithilfe von Snapshots und laden Sie dann einen der Snapshots, um Ihre zu verbessern. Sie können beispielsweise einen Aktualisierungsvorgang rückgängig machen, bei dem PyPI-Pakete installiert oder Airflow-Konfigurationsoptionen überschrieben werden, auch nachdem die Umgebung erfolgreich aktualisiert wurde.
Sie können parallele Upgrades ausführen und Umgebungen kopieren. Snapshot eines bestehenden Umgebung haben, erstellen Sie eine neue Umgebung, die dieselbe oder eine neuere Umgebung verwendet. Version von Cloud Composer erstellen und den Snapshot dann auf diesen neuen zu verbessern. Dieser Vorgang ähnelt der Migration. Pausieren Sie DAGs, bevor erstellen Sie den Snapshot, um doppelte DAG-Ausführungen zu vermeiden.
So werden Snapshots gespeichert
Ein Umgebungs-Snapshot ist eine Gruppe von Dateien, die den Status Ihrer Umgebung beschreiben und die Sicherung der Umgebungsdaten speichern.
Sie können mehrere Snapshots Ihrer Umgebung erstellen. Umgebungs-Snapshots sind nicht inkrementell. Sie können jeden Snapshot unabhängig von anderen Snapshots verwenden.
In Cloud Composer werden Snapshots nicht gelöscht, wenn Sie Ihre Umgebung löschen.
Standardmäßig speichert Cloud Composer Snapshots im Ordner snapshots/
im Bucket Ihrer Umgebung. Sie können beim Erstellen eines Snapshots auch einen benutzerdefinierten Speicherort angeben.
Während in der Cloud Storage-UI Daten der Einfachheit halber als Ordner angezeigt werden, werden Buckets in einer flachen Dateistruktur arbeiten. Das ändert nichts daran, wie Sie Snapshots in der Google Cloud Console speichern und laden. Berücksichtigen Sie dies jedoch, wenn Sie Vorgänge direkt auf die Dateien in Ihrem Bucket ausführen. Weitere Informationen Siehe Objekt-Namespace.
Sicherheitsaspekte für Snapshots
Speichern Sie vertrauliche Informationen, um dieses Sicherheitsrisiko zu minimieren. der von Airflow-DAGs wie Schlüsseln oder Passwörtern in Secret Manager Weitere Informationen finden Sie unter Konfigurieren Sie Secret Manager für Ihre Umgebung.
Prüfen Sie unbedingt die Sicherheitsberechtigungen für den Bucket Ihrer Umgebung. Wenn Sie Umgebungs-Snapshots in einem benutzerdefinierten Bucket speichern, müssen die Zugriffsberechtigungen dafür in Ihrem Projekt richtig konfiguriert sein. Achten Sie beim Zuweisen von Berechtigungen darauf, dass das Dienstkonto der Umgebung ausreichende Berechtigungen zum Speichern und Laden von Snapshots aus dem Bucket hat.
Welche Daten in Snapshots gespeichert werden
Cloud Composer speichert die folgenden Daten in Snapshots:
- Airflow-Konfigurationsüberschreibungen
- Umgebungsvariablen.
- Liste benutzerdefinierter PyPI-Pakete als Anforderungen.
- Eine Sicherung der Airflow-Datenbank, einschließlich Status der ausgeführten Aufgaben und Verlauf der DAG-Ausführungen.
- Eine Sicherung der Ordner
/dags
,/data
und/plugins
aus dem im Bucket der Umgebung. - Fernet-Schlüssel der Umgebung.
- Weitere Informationen zur Umgebungskonfiguration, z. B. Skalierungs- und Leistungsparameter der Umgebung. Cloud Composer verwendet diese Informationen nicht, wenn Snapshots geladen werden.
Welche Daten werden aus Snapshots geladen?
Cloud Composer lädt die folgenden Daten aus Snapshots:
- Airflow-Konfigurationsüberschreibungen.
- Umgebungsvariablen
Benutzerdefinierte PyPI-Pakete (sofern Sie die Installation nicht überspringen)
Der Inhalt der Airflow-Datenbank, einschließlich der Status der ausgeführten Aufgaben und der bisherige Verlauf der DAG-Ausführungen.
Der Inhalt der Ordner
/dags
,/data
und/plugins
aus dem Snapshot wird in den Bucket der Umgebung geladen.Mit dem Fernet-Schlüssel aus dem Snapshot werden die Daten aus dem Snapshot noch einmal mit dem Fernet-Schlüssel der Umgebung verschlüsselt. Der Fernet-Schlüssel der Umgebung bleibt unverändert.
Cloud Composer speichert zwar einige Informationen zur Konfiguration der Umgebung in Snapshots, diese werden jedoch nicht beim Laden von Snapshots verwendet. Die folgenden Parameter Ihrer Umgebung ändern sich nicht, wenn Sie Snapshot laden:
- Umgebungskonfiguration, z. B. Umgebungsskalierung und -leistung Parameter.
- Netzwerkkonfiguration der Umgebung.
- Inhalte des Umgebungs-Buckets außerhalb von
/dags
,/data
und/plugins
Ordner. - Umgebungslabels.
Alle Einstellungen, die Sie in der Cloud Composer-Infrastruktur ohne Verwendung der Cloud Composer API angewendet haben, gehen beim Laden eines Snapshots möglicherweise verloren.
Teilweise abgeschlossene Vorgänge
Beim Laden eines Snapshots kann der Vorgang erfolgreich, fehlgeschlagen oder teilweise sein Abgeschlossen:
- Bei erfolgreichen Vorgängen werden alle Daten aus dem Snapshot geladen.
- Fehlgeschlagene Vorgänge bringen keine Änderungen mit sich.
- Bei teilweise abgeschlossenen Vorgängen wird eine Teilmenge der Daten aus dem Snapshot geladen. Solche Vorgänge werden als fehlgeschlagen gemeldet, aber in der Fehlermeldung wird angegeben, welche Daten erfolgreich geladen wurden. Wenn z. B. PyPI-Pakete installiert sind, aber die Überschreibungen der Airflow-Konfigurationsoptionen waren nicht erfolgreich, wird der Fehler gibt dies an.
Bei einem teilweise abgeschlossenen Vorgang können Sie versuchen, denselben Snapshot noch einmal zu laden. Cloud Composer überspringt Schritte, die im vorherigen Versuch. Wenn ein Vorgang beispielsweise aufgrund einer Zeitüberschreitung fehlgeschlagen ist, die Datenbank aber erfolgreich geladen wurde, wird sie beim nächsten Versuch nicht noch einmal geladen.
Hinweise
Snapshots werden in Cloud Composer 2 Version 2.0.9 und höher unterstützt. Cloud Composer 1 unterstützt das Speichern von Umgebungs-Snapshots für Versionen >= 1.18.5.
Snapshots erstellen keine Umgebung. Wenn Sie einen Snapshot aus einer Umgebung in eine andere laden möchten, müssen Sie zuerst eine neue Umgebung erstellen und dann den Snapshot dorthin laden.
Sie können keine Snapshots in Umgebungen mit dem Status „Fehler“ laden. Solche Umgebungen können nicht durch Laden eines Snapshots korrigiert werden. Sie können jedoch weiterhin einen vorhandenen Snapshot in eine neue Umgebung laden.
Snapshots können nur in die gleiche oder eine höhere Version von Cloud Composer oder Airflow. Sie können beispielsweise keine Snapshot von Cloud Composer 2.0.2 in eine Umgebung mit Cloud Composer 2.0.1. Ein weiteres Beispiel: Sie können einen Snapshot nicht von Airflow 2.2.3 in Airflow 2.1.4 laden.
Durch Snapshots ändert sich die Cloud Composer-Version nicht. Wenn Sie Ihre Umgebung auf eine neuere Cloud Composer-Version aktualisieren und dann einen Snapshot aus einer früheren Version laden, bleibt die aktuelle Cloud Composer-Version in Ihrer Umgebung erhalten. Wenn Sie z. B. einen Snapshot aus einer Cloud Composer 2.0.1 zu Cloud Composer 2.0.2 ändert sich nicht die Umgebung auf Cloud Composer 2.0.1 zurücksetzen.
Die maximale Größe der Airflow-Datenbank, die Snapshots unterstützt, beträgt 20 GB. Wenn die Datenbank Ihrer Umgebung über 20 GB, Reduzieren Sie die Größe der Airflow-Datenbank, bevor Sie Snapshot.
Die Gesamtzahl der Objekte in den Ordnern
/dags
,/plugins
und/data
im Bucket der Umgebung muss unter 100.000 liegen, damit Snapshots erstellt werden können.Wenn Sie den XCom-Mechanismus zum Übertragen von Dateien verwenden, müssen Sie [entsprechend den Airflow-Richtlinien verwenden][ext-airflow-xcom-backend]. Die Übertragung großer Dateien oder einer großen Anzahl von Dateien mit XCom wirkt sich auf die Leistung der Airflow-Datenbank aus und kann zu Fehlern beim Laden von Snapshots oder beim Upgraden Ihrer Umgebung führen. Für die Übertragung großer Datenmengen können Sie Alternativen wie Cloud Storage verwenden.
Der Name eines Objekts im Bucket der Umgebung darf maximal 1.024 Zeichen lang sein. Andernfalls können keine Snapshots erstellt werden.
Wenn Sie Snapshots an einem Speicherort außerhalb des Buckets Ihrer Umgebung speichern, muss das Dienstkonto Ihrer Umgebung Lese- und Schreibberechtigungen für den angegebenen Speicherort haben. Beispiel: Der Parameter Die Rolle Storage-Objekt-Administrator verfügt über solche Berechtigungen. Ich auf ein Projekt oder einen bestimmten Bucket anwenden können.
Das Erstellen und Speichern von Snapshots ist mit zusätzlichen Kosten verbunden, die mit zu Cloud Storage hinzufügen. Weitere Informationen finden Sie unter Preise.
Umgebungs-Snapshot speichern
Cloud Composer speichert Umgebungs-Snapshots in einem Unterordner, der sich relativ zum von Ihnen angegebenen Ordner befindet.
Der Ordnername enthält die Projekt-ID, den Speicherort der Umgebung,
Name der Umgebung und den Zeitstempel, an dem der Snapshot gespeichert wurde. Beispiel: /snapshots/example-project_us-central1_example-environment_2022-01-05T18-59-00
.
Console
So erstellen Sie einen Snapshot Ihrer Umgebung:
Rufen Sie in der Google Cloud Console die Seite Umgebungen auf.
Klicken Sie in der Liste der Umgebungen auf den Namen Ihrer Umgebung. Die Seite Umgebungsdetails wird geöffnet.
Klicken Sie auf Snapshot speichern.
Wählen Sie im Dialogfeld Snapshot speichern aus, wo der Snapshot gespeichert werden soll:
Wenn Sie den Snapshot im Ordner
/snapshots
im Bucket der Umgebung speichern möchten, wählen Sie Snapshot-Ordner im Umgebungs-Bucket verwenden (Standard) aus.Wenn Sie den Snapshot im benutzerdefinierten Ordner speichern möchten, wählen Sie Benutzerdefinierten Ordner in einem anderen Bucket verwenden aus und geben Sie einen Speicherort an.
Klicken Sie auf Speichern.
gcloud
Mit dem Befehl gcloud beta composer environments snapshots save
wird ein Snapshot Ihrer Umgebung gespeichert.
- Das Argument
snapshot-location
gibt einen Ordner an, in dem sich der Snapshot befindet gespeichert. Standardmäßig werden Snapshots im Ordner/snapshots
im Bucket Ihrer Umgebung gespeichert. Beispiel:gs://us-central1-example-916807e1-bucket/snapshots
. Sie können auch angeben, in einem anderen Ordner.
Führen Sie folgenden Befehl aus, um einen Snapshot Ihrer Umgebung zu speichern:
gcloud beta composer environments snapshots save \
ENVIRONMENT_NAME \
--location LOCATION \
--snapshot-location "SNAPSHOTS_FOLDER"
Ersetzen Sie:
ENVIRONMENT_NAME
durch den Namen der Umgebung.LOCATION
durch die Region, in der sich die Umgebung befindet.- Optional:
SNAPSHOTS_FOLDER
mit dem URI eines Bucket-Ordners, in dem der Snapshot gespeichert werden soll. Wenn Sie dieses Argument weglassen, speichert Cloud Composer Snapshot im Ordner/snapshots
im Bucket Ihrer Umgebung
Im folgenden Beispiel wird der Standardspeicherort verwendet:
gcloud beta composer environments snapshots save \
example-environment \
--location us-central1
Im folgenden Beispiel wird die Datei in einem benutzerdefinierten Ordner gespeichert:
gcloud beta composer environments snapshots save \
example-environment \
--location us-central1 \
--snapshot-location "gs://example-bucket/environment_snapshots"
API
Erstellen Sie eine API-Anfrage
environments.saveSnapshot
.Geben Sie im Anfragetext im Feld
snapshotLocation
den Ordner an, in dem der Snapshot gespeichert werden soll.
{
"snapshotLocation": "SNAPSHOTS_FOLDER"
}
Ersetzen Sie:
SNAPSHOTS_FOLDER
durch den URI eines Bucket-Ordners, in dem um den Snapshot zu speichern.
Beispiel:
// POST https://composer.googleapis.com/v1beta1/projects/example-project/
// locations/us-central1/environments/example-environment:saveSnapshot
{
"snapshotLocation": "gs://us-central1-example-916807e1-bucket/snapshots"
}
Terraform
Es ist nicht möglich, Umgebungs-Snapshots aus Terraform zu speichern und zu laden.
Das Speichern und Laden von Snapshots sind Aktionen, die in einer Umgebung ausgeführt werden. Die resultierenden Snapshots sind nicht Teil der Definition einer Umgebung. Da Terraform nur die Konfiguration der Cloud Composer-Umgebung verwaltet, können Sie keine Umgebungs-Snapshots damit speichern oder daraus laden.
Umgebungs-Snapshot laden
Betrachten Sie die folgende Situation. Beispiel: catch-up ist aktiviert und Airflow führt einen DAG aus. nach einem Zeitplan zwischen dem Zeitpunkt der Erstellung des Snapshots und der Erstellung geladen. In diesem Fall hat Airflow nach dem Laden des Snapshots keine Informationen zur Ausführung des DAG. Daher führt Airflow den DAG für den und Daten.
Als weiteres Beispiel sehen Sie sich einen DAG an, der täglich ausgeführt wird. Sie nehmen eine einen Snapshot erstellen, führt Airflow diesen DAG aus. Danach laden Sie am selben Tag. In diesem Fall führt Airflow den DAG noch einmal aus, auch wenn der Nachholbedarf deaktiviert.
Console
So laden Sie einen Snapshot in Ihre Cloud Composer 2-Umgebung:
Rufen Sie in der Google Cloud Console die Seite Umgebungen auf.
Klicken Sie in der Liste der Umgebungen auf den Namen Ihres zu verbessern. Die Seite Umgebungsdetails wird geöffnet.
Klicken Sie auf Snapshot laden.
Klicken Sie im Dialogfeld Snapshot laden auf Durchsuchen.
Wählen Sie einen Ordner aus, in dem der Snapshot gespeichert wird. Unter dem Namen des Ordners werden die ID Ihres Projekts, Standort der Umgebung und der Zeitstempel der Snapshot wurde gespeichert. Beispiel:
/snapshots/example-project_us-central1_example-environment_2022-01-05T18-59-00
Optional: Wenn Sie die Installation benutzerdefinierter PyPI-Pakete aus dem Snapshot überspringen möchten, wählen Sie Installation von PyPI-Paketen überspringen aus. Wenn Sie eine Snapshot einer Umgebung mit installierter benutzerdefinierte PyPI-Pakete, installiert Cloud Composer diese benutzerdefinierten Pakete nicht.
Klicken Sie auf Laden und warten Sie, bis Cloud Composer den Snapshot geladen hat.
gcloud
Mit dem Befehl gcloud beta composer environments snapshots load
wird ein Snapshot in Ihre Umgebung geladen.
Das Argument
--snapshot-path
gibt einen Ordner an, in dem sich der Snapshot befindet befindet.Der Name des Ordners enthält die ID Ihres Projekts, den Ort und den Zeitstempel, an dem der Snapshot gespeichert wurde. Beispiel:
gs://us-central1-example-916807e1-bucket/snapshots/example-project_us-central1_example-environment_2022-01-05T18-59-00
Optional: Mit dem Argument
--skip-pypi-packages-installation
wird die Installation benutzerdefinierter PyPI-Pakete aus dem Snapshot übersprungen. Wenn Sie einen Snapshot einer Umgebung mit installierten benutzerdefinierten PyPI-Paketen laden, werden diese benutzerdefinierten Pakete von Cloud Composer nicht installiert.
gcloud beta composer environments snapshots load \
DESTINATION_ENVIRONMENT_NAME \
--location LOCATION \
--snapshot-path "SNAPSHOT_PATH"
Ersetzen Sie:
DESTINATION_ENVIRONMENT_NAME
durch den Namen der Umgebung, in der Sie den Snapshot laden möchten.LOCATION
durch die Region, in der sich die Umgebung befindet.SNAPSHOT_PATH
durch den URI eines Buckets, gefolgt vom Pfad zum Snapshot.
Beispiel:
gcloud beta composer environments snapshots load \
example-environment \
--location us-central1 \
--snapshot-path "gs://us-central1-example-916807e1-bucket/snapshots/example-project_us-central1_example-environment_2022-01-05T18-59-00"
API
Erstellen Sie eine API-Anfrage
environments.loadSnapshot
.Geben Sie im Anfragetext im Feld
snapshotPath
den URI eines Buckets gefolgt vom Pfad zum Snapshot an. Der Name enthält der Ordner die ID Ihres Projekts, den Speicherort der Umgebung und Zeitstempel, der angibt, wann der Snapshot gespeichert wurde. Beispiel:gs://us-central1-example-916807e1-bucket/snapshots/example-project_us-central1_example-environment_2022-01-05T18-59-00
Optional: Im Anfragetext im Feld
skipPypiPackagesInstallation
geben Sie an, ob Cloud Composer die Installation benutzerdefinierter PyPI-Pakete aus dem Snapshot. Wenn Sie eine Snapshot einer Umgebung mit installierter benutzerdefinierte PyPI-Pakete, installiert Cloud Composer diese benutzerdefinierten Pakete nicht.Dieses Feld ist optional. Wenn Sie dieses Feld weglassen, installiert Cloud Composer PyPI-Pakete aus dem Snapshot.
{
"snapshotPath": "SNAPSHOT_PATH"
}
Ersetzen Sie:
SNAPSHOT_PATH
durch den URI eines Bucket-Ordners, in dem Snapshot speichern.
Beispiel:
// POST https://composer.googleapis.com/v1beta1/projects/example-project/
// locations/us-central1/environments/example-environment:loadSnapshot
{
"snapshotPath": "gs://us-central1-example-916807e1-bucket/snapshots/example-project_us-central1_example-environment_2022-01-05T18-59-00",
"skipPypiPackagesInstallation": "False"
}
Terraform
Es ist nicht möglich, mit Terraform Umgebungs-Snapshots zu speichern und zu laden.
Das Speichern und Laden von Snapshots sind Aktionen, die in einer Umgebung ausgeführt werden. Die resultierenden Snapshots sind nicht Teil der Definition einer Umgebung. Da Terraform nur die Konfiguration der Cloud Composer-Umgebung verwaltet, können Sie keine Umgebungs-Snapshots damit speichern oder daraus laden.