Snowflake-Stagingbereiche mit Diensten verwenden¶
Snowflake supports various storage volume types for your application containers, including internal stage, local storage, memory storage, and block storage volumes. This section explains how to configure volumes and volume mounts for internal stages. A An internal stage volume is a volume configured to use a Snowflake stage as persistent storage.
Mit Staging-Volumes kann Ihr Service auf die Objekte eines internen Stagingbereichs zugreifen, als wären sie Dateien auf Ihrem Dateisystem, was Ihren Servicecode im Vergleich zur Verwendung eines Snowflake-Treibers und den SQL-Befehlen GET und PUT, um auf diese Objekte zuzugreifen, vereinfacht. Staging-Volumes können für Szenarien mit Streaming-Lese- oder Schreibvorgängen großer Datendateien ebenfalls eine höhere Performance bieten.
Wenn Ihre Dateisystemoperationen einfach in die Streaming-Operationen GET und PUT übersetzt werden können, dann eignen sich Staging-Volumes gut für Ihr Szenario. Wenn Ihre Anwendung Dateien umbenennen oder verschieben, vorhandene Dateien ändern oder dateisystembasierte Sperren ausführen muss, ist das Staging-Volume nicht gut für Ihren Workload geeignet.
Bemerkung
Derzeit gibt es zwei Implementierungen für Staging-Volumes: eine allgemein verfügbare Version und eine veraltete Version. Snowflake empfiehlt, dass Sie die allgemein verfügbare Version für neue Dienste verwenden und Ihre bestehenden Anwendungen von der veralteten Version migrieren.
Die Staging-Volume-Implementierung streamt Dateiinhalte direkt zum und aus dem Cloudspeicher und stellt sicher, dass Sie immer die neuesten Inhalte erhalten. Beachten Sie die folgenden Punkte, wenn Sie ein Staging-Volume verwenden:
A stage volume is optimized for large, sequential reads and writes, providing strong performance for these access patterns. For best results, read and write data in large, contiguous chunks.
Reads always return the latest data, which lets data sharing occur between services.
Zufällige Schreibvorgänge oder Anhänge von Dateien werden nicht unterstützt. Der Versuch, diese Vorgänge auszuführen, führt zu einem Fehler. Snowflake empfiehlt die Verwendung von Blockspeicher-Volumes für diese Workloads.
Configure a Snowflake stage as a storage volume in a service specification¶
To create a service where service containers use a stage volume, you perform two steps to specify the required settings in the service specification:
Definieren Sie ein Staging-Volume, das den Snowflake-Stagingbereich identifiziert, der als Speichervolume verwendet werden soll.
Specify where to mount the stage volume in your application container.
Schritt 1: Staging-Volume definieren¶
Um ein Staging-Volume zu definieren, fügen Sie das Feld spec.volumes in der Service-Spezifikation hinzu, wie im folgenden Beispiel gezeigt. Das Beispiel zeigt nur die minimal erforderlichen Felder:
spec:
containers:
..
volumes:
- name: <name>
source: stage
stageConfig:
name: <stage_name>
The following list defines the fields from the example:
name: Provides the name of the volume.source: Identifies the type of the volume (stage).stageConfig.name: Identifies the Snowflake internal stage or folder on a stage to mount; for example@my_stage,@my_stage/folder, or@my_db.my_schema.my_stage/folder/nestedfolder. Double quotes must surround this value.
Sie können die folgenden optionalen Felder in stageConfig aufnehmen:
Feld
stageConfig.resources: Die Snowflake-Komponente, die das eingebundene Staging-Volume bereitstellt, benötigt CPU und Arbeitsspeicherressourcen. Verwenden Sie dieses Feld, um diese CPU- und Arbeitsspeicheranforderungen anzugeben, ähnlich wie die Ressourcenspezifikationen für Ihre Anwendungscontainer. Weitere Informationen dazu finden Sie unter Feld containers.resources. Wenn dieses Feld nicht angegeben ist, gelten die folgenden Standardeinstellungen für Ressourcen:resources.requests.cpu: 0resources.requests.memory: 0.5Giresources.limits.cpu: 0.5resources.limits.memory: 1Gi
Bei den meisten Anwendungen mit typischem Datenverkehr zu Staging-Volumes müssen Sie dieses Feld nicht festlegen, da die Standard-Ressourceneinstellungen ausreichen sollten. Wenn Ihre Anwendung jedoch eine hohe Anzahl von Lese- und Schreiboperationen ausführt, können die Standardeinstellungen zu Leistungseinschränkungen oder Lese-/Schreibfehlern führen. Weitere Informationen dazu finden Sie unter Gemeinsame Richtlinien für beide Implementierungen von Stagingbereich-Volumes.
Um diese Probleme zu vermeiden, überprüfen Sie CPU und Speichermetriken für den Container (
stage-mount-v2-sidecar-<Name_des_Staging-Volumes>). Snowflake fügt diesen Container zu Ihrem Service hinzu, der die Implementierung des von Ihnen konfigurierten Staging-Volumes bereitstellt. So können Sie genau sehen, welche Ressourcen Ihr Staging-Volume verwendet und ob es durch CPU oder Arbeitsspeicher eingeschränkt ist. Verwenden Sie diese Kennzahlen, um die CPU- und Arbeitsspeicherbeschränkungen nach Bedarf zu aktualisieren.Feld
stageConfig.metadataCache: Wenn Ihre Anwendung häufig Dateimetadaten abruft oder Dateien in einem Snowflake-Stagingbereich in einer Schleife auflistet und Sie nicht erwarten, dass sich die Daten häufig ändern, können Sie das Caching von Metadaten für das Snowflake-Staging-Speichervolume aktivieren, um die Leistung erheblich zu verbessern. Der Cache speichert diese Metadaten für einen bestimmten Zeitraum und wird danach gelöscht. Wenn die Anwendung dann versucht, auf die Metadaten zuzugreifen, aktualisiert Snowflake den Cache. Verwenden Sie die Einheiten Stunden, Minuten und Sekunden, um denmetadataCacheanzugeben. Beispiel:90s,5m,1h,1h30m,1h30m45s. Wenn nicht angegeben, erfolgt kein Caching.Bemerkung
Konfigurieren Sie das Caching von Metadaten nur dann, wenn sich die Daten in Ihrem Snowflake-Stagingbereich während der Lebensdauer des Service nicht ändern, z. B. ein Service mit schreibgeschützten Workloads, der ein statisches Dataset im Stagingbereich verarbeiten muss. Konfigurieren Sie das Caching von Metadaten nicht für Workloads, bei denen die Daten in Ihrem Snowflake-Stagingbereich aktualisiert werden, während der Service ausgeführt wird.
Das folgende Feld spec.volumes definiert ein Snowflake-Staging-Volume. Das Feld enthält die optionalen stageConfig-Felder:
spec:
containers:
..
volumes:
- name: <name>
source: stage
stageConfig:
name: <stage_name>
metadataCache: 1h
resources:
requests:
cpu: 0.35
memory: 0.4Gi
limits:
cpu: 2.0
memory: 1Gi
Schritt 2: Angeben, wo das Staging-Volume im Container eingebunden werden soll¶
After you define a Snowflake stage storage volume by adding the spec.volumes field, use the spec.containers.volumeMounts field to describe where to mount the stage volume in your application containers, as shown in the following example:
spec:
containers:
name: ...
image: ...
volumeMounts:
- name: <name>
mountPath: <absolute_directory_path>
Die Angaben, die Sie in diesem Feld machen, sind für alle unterstützten Speicher-Volume-Typen konsistent und gelten für beide Implementierungen von Stagingbereich-Volumes.
Beispiel¶
In der Beispiel-Servicespezifikation bindet der app-Container einen internen Stagingbereich @ai_models_stage ein:
spec:
containers:
- name: app
image: <image1-name>
volumeMounts:
- name: ai-models
mountPath: /opt/ai-model
volumes:
- name: ai-models
source: stage
stageConfig:
name: "@ai_models_stage"
Anforderungen an die Zugriffssteuerung¶
Die Rolle des Eigentümers des Dienstes ist die Rolle, mit der der Dienst erstellt wird. Es ist auch die Rolle, die die Dienste bei der Interaktion mit Snowflake verwenden. Diese Eigentümerrolle legt die Berechtigungen fest, die Anwendungs-Containern für den Zugriff auf einen gemounteten Stagingbereich gewährt werden. Der Eigentümer muss über die READ-Berechtigung für den Stagingbereich verfügen.
Wenn die Eigentümerrolle nicht die WRITE-Berechtigung für einen Stagingbereich hat, ist die Einbindung für diesen Stagingbereich schreibgeschützt. Das heißt, die Container können die Dateien nur aus dem Stagingbereich lesen. Die Rolle des Eigentümers benötigt die WRITE-Berechtigung auf einem Stagingbereich, damit das Staging-Mount sowohl Lese- als auch Schreibzugriffe unterstützt.
About the deprecated implementation¶
The deprecated stage-volume implementation uses a shared cache for reads and writes. Although this works well for some scenarios, you can’t control whether data is read from the cache or directly from the stage, which might not be suitable for all applications. Additionally, when you use the cache for reads and writes, this can introduce performance overhead.
Code aus der veralteten Implementierung migrieren¶
Die neuere Implementierung ersetzt die veraltete Implementierung mit folgenden Verhaltensänderungen:
Die neuere Staging-Volume-Implementierung streamt Dateiinhalte direkt zum und aus dem Cloudspeicher und stellt sicher, dass Sie immer die neuesten Inhalte erhalten. Dies führt zu vorhersehbaren Verhaltensweisen und einem deutlich schnelleren Durchsatz. Die veraltete Stagingbereich-Volume-Implementierung speichert Blöcke von Dateidaten im Cache, sodass es schwierig ist zu erkennen, ob Sie die neuesten Daten lesen.
Die Performance bei zufälligen Lesevorgängen kann bei der neuen Implementierung geringer sein, da das Caching entfernt wurde. Ohne einen lokalen Festplattencache wird die Konsistenz zwischen Volumes jedoch verbessert. Dateiänderungen werden beim Schließen der Datei direkt in den unterstützenden Stagingbereich geschrieben, ohne dass eine lokale Festplattenpufferung erfolgt.
Lesevorgänge geben immer die neuesten Daten zurück, sodass sich diese Konfiguration besser für das Data Sharing zwischen Services eignet.
Zufällige Schreibvorgänge oder Anhänge von Dateien werden nicht unterstützt. Der Versuch, diese Vorgänge auszuführen, führt zu einem Fehler. Snowflake empfiehlt die Verwendung von Blockspeicher-Volumes für diese Workloads.
Specify a Snowflake stage volume in a service specification (deprecated)¶
To create a service where service containers use Snowflake stage volume, specify the required settings in the service specification as shown in the following steps:
To specify the stage volume, use the
spec.volumesfield as shown in the following example:volumes: - name: <name> source: <stage_name>
Die folgenden Felder sind erforderlich:
name: The name of the volume.source: The Snowflake internal stage or folder on the stage to mount; for example@my_stage,@my_stage/folder. Quotes must surround this value.
To describe where to mount the stage volume in your application containers, use the
spec.containers.volumeMountsfield, as shown in the following example:volumeMounts: - name: <name> mountPath: <absolute_directory_path>
Die Angaben, die Sie in diesem Feld machen, sind für alle unterstützten Speicher-Volume-Typen konsistent und gelten für beide Implementierungen von Stagingbereich-Volumes.
Beispiel (veraltet)¶
In the example service specification, the app container mounts an internal stage @model_stage by using the deprecated stage volume implementations:
spec:
containers:
- name: app
image: <image1-name>
volumeMounts:
- name: models-legacy
mountPath: /opt/model-legacy
volumes:
- name: models-legacy
source: "@model_stage"
The volumeMounts field specifies where inside the container to mount the stage volume. This specification remains the same for both the stage volume implementations.
Richtlinien bei der Verwendung von Stagingbereich-Volumes¶
This section provides you with guidelines to follow when you implement application code in which a container uses a Snowflake stage as storage volume.
Gemeinsame Richtlinien für beide Implementierungen von Stagingbereich-Volumes¶
Der Stagingbereich ist für sequentielles Lesen und Schreiben optimiert.
E/A-Operationen im Stagingbereich können höhere Latenzen aufweisen als E/A-Operationen auf dem Dateisystem und den Blockspeicher-Volumes des Containers. Sie sollten immer den Statuscode von E/A-Operationen überprüfen, um sicherzustellen, dass sie erfolgreich waren.
Im Stagingbereich werden Uploaddateien asynchron aktualisiert. Änderungen an Dateien auf einem Stagingbereich werden erst dann garantiert, wenn der Datei-Deskriptor erfolgreich geschlossen oder geleert wurde. Es kann eine gewisse Verzögerung geben, bevor die Änderungen an Dateien in einem Stagingbereich für andere Container und Snowflake sichtbar werden.
Jedes Verzeichnis in einem gemounteten Stagingbereich sollte weniger als 100.000 Dateien enthalten. Rechnen Sie damit, dass die Latenz von
readdirmit der Anzahl der Dateien im Verzeichnis zunimmt.
Guidelines when using the deprecated version of the stage volume implementation¶
Vermeiden Sie das gleichzeitige Schreiben in mehrere Dateien innerhalb eines Stagingbereichs.
Der Stagingbereich ist kein Netzwerkdateisystem. Verwenden Sie keine Stagingbereiche für die Koordination mehrerer Clients.
Öffnen Sie nicht mehrere Handles für dieselbe Datei gleichzeitig. Verwenden Sie geöffnete Datei-Handles entweder für Lese- oder für Schreiboperationen, aber nicht für eine Mischung aus beidem. Um aus einer Datei zu lesen, nachdem Sie in sie geschrieben haben, schließen Sie die Datei und öffnen Sie sie dann erneut, bevor Sie lesen.
Guidelines when using the generally available stage volume implementation¶
Gleichzeitige Schreibvorgänge auf dieselbe Datei aus mehreren Stagingbereichen (dasselbe Stagingbereich-Volume in verschiedenen Containern) werden nicht empfohlen.
Das Fehlen eines lokalen Festplattencaches verbessert die Konsistenz zwischen Einbindungen. Dateiänderungen werden beim Schließen der Datei direkt in den unterstützenden Stagingbereich geleert, ohne dass eine lokale Festplattenpufferung erfolgt. Lesevorgänge geben immer die neuesten Daten zurück, sodass sich die neue Einbindung von Stagingbereichen besser für das Data Sharing zwischen Services eignet.
Die optimalen Ergebnisse erzielen Sie, wenn Sie Daten in großen, zusammenhängenden Blöcken lesen und schreiben. Die Leistungseinbußen bei kleinen Lese- und Schreibvorgängen im Vergleich zur allgemein verfügbaren Stagingbereich-Volume-Implementierung können die Performancegewinne der neuen Implementierung abschwächen.
Einschränkungen bei der Verwendung von Stagingbereich-Volumes¶
In diesem Abschnitt werden die Einschränkungen beschrieben, die Sie bei der Implementierung von Anwendungscode beachten sollten, in dem Container Stagingbereich-Volumes verwenden. Wenn Sie Probleme mit diesen Beschränkungen haben, wenden Sie sich an Ihren Kundenbetreuer.
Gemeinsame Einschränkungen für beide Implementierungen von Stagingbereich-Volumes¶
Sie können nur einen Stagingbereich oder ein Unterverzeichnis in einen Stagingbereich einbinden, z. B. @my_stage,
@my_stage/folder. Sie können keine einzelne Datei in einen Stagingbereich einbinden, z. B.@my_stage/folder.Externe Stagingbereiche werden nicht unterstützt. Es werden nur Snowflake-interne Stagingbereiche unterstützt.
Stagingbereiche sind nicht vollständig POSIX-kompatible Dateisysteme. Beispiel:
Dateien und Verzeichnisse werden nicht atomar umbenannt.
Harte Links werden nicht unterstützt.
Das Linux-Kernel-Subsystem inode notify (
inotify), das Änderungen an Dateisystemen überwacht, funktioniert nicht im Stagingbereich.
Limitations when using the deprecated version of the stage volume implementation¶
Pro Service sind maximal 5 Stagingbereich-Volumes erlaubt. Weitere Informationen dazu finden Sie unter spec.volumes.
Es werden maximal 8 Staging-Volumess pro Computepool-Knoten unterstützt. Snowflake verwaltet die Beschränkung des Stagingbereichs pro Knoten ähnlich wie Speicher, CPU und GPU. Das Starten einer neuen Dienstinstanz kann Snowflake dazu veranlassen, neue Knoten zu starten, wenn keine vorhandenen Knoten die Kapazität haben, den angeforderten Stagingbereich zu unterstützen.
Die Funktionen für Stagingbereich-Volumes variieren je nach Cloudplattform für Ihr Snowflake-Konto:
Konten auf AWS unterstützen interne Stagingbereiche sowohl mit SNOWFLAKE_FULL- als auch mit SNOWFLAKE_SSE-Stagingbereich-Verschlüsselung. Weitere Informationen dazu finden Sie unter Parameter für interne Stagingbereiche.
Konten auf Azure unterstützen derzeit interne Stagingbereiche mit SNOWFLAKE_SSE-Verschlüsselung Verwenden Sie bei der Ausführung von CREATE STAGE den Parameter ENCRYPTION zur Angabe des Verschlüsselungstyps:
CREATE STAGE my_stage ENCRYPTION = (TYPE = 'SNOWFLAKE_SSE');Konten auf Google Cloud werden nicht unterstützt.
Gleichzeitige Schreibvorgänge auf dieselbe Datei aus mehreren Stagingbereichen (dasselbe Stagingbereich -Volume in verschiedenen Containern) werden nicht unterstützt.
Einschränkungen bei der Verwendung der allgemein verfügbaren Version der Stagingbereich-Volume-Implementierung¶
Zufällige Schreibvorgänge oder Anhänge von Dateien werden nicht unterstützt.
Jeder eingebundene Stagingbereich erfordert 512 MB Arbeitsspeicher pro Stagingbereich. Das bedeutet, dass die Anzahl der Stagingbereiche, die verwendet werden können, je nach Größe der Instanz begrenzt ist. Das Einbinden des Volumes in mehrere Container erhöht nicht den Speicherverbrauch.
A maximum of 20 stage volumes are allowed per service. For more information, see spec.volumes.