Snowflake Insert-Aktivität in Jitterbit Studio
Einführung
Eine Snowflake Insert-Aktivität verwendet ihre Snowflake-Verbindung und fügt Tabellendaten (entweder als CSV-Datei oder direkt den Spalten einer Tabelle zugeordnet) in Snowflake ein. Sie dient als Ziel zum Verarbeiten von Daten in einem Vorgang.
Erstellen einer Snowflake Insert-Aktivität
Eine Instanz einer Snowflake Insert-Aktivität wird aus einer Snowflake-Verbindung mit dem Aktivitätstyp Insert erstellt.
Um eine Aktivitätsinstanz zu erstellen, ziehen Sie den Aktivitätstyp auf die Design-Canvas oder kopieren Sie den Aktivitätstyp und fügen Sie ihn auf der Design-Canvas ein. Weitere Informationen finden Sie unter Erstellen einer Aktivitäts- oder Tool-Instanz in Komponentenwiederverwendung.
Eine vorhandene Snowflake Insert-Aktivität kann von diesen Orten aus bearbeitet werden:
- Die Design-Canvas (siehe Komponentenaktionsmenü in Design-Canvas).
- Die Registerkarte Komponenten des Projektbereichs (siehe Komponentenaktionsmenü in Registerkarte „Komponenten" des Projektbereichs).
Konfigurieren einer Snowflake Insert-Aktivität
Führen Sie diese Schritte aus, um eine Snowflake Insert-Aktivität zu konfigurieren:
-
Schritt 1: Namen eingeben und Objekt auswählen
Geben Sie einen Namen für die Aktivität ein und wählen Sie ein Objekt aus, entweder eine Tabelle oder eine Ansicht. -
Schritt 2: Ansatz auswählen
Für das Einfügen von Daten in Snowflake werden verschiedene Ansätze unterstützt. Wählen Sie zwischen Stage File oder SQL Insert. Bei Verwendung des Ansatzes Stage File können Sie zwischen den Stage-Dateitypen Amazon S3 oder Internal wählen. -
Schritt 3: Datenschemas überprüfen
Alle vom Endpunkt generierten Request- oder Response-Schemas werden angezeigt.
Schritt 1: Namen eingeben und Objekt auswählen
Geben Sie in diesem Schritt einen Namen für die Aktivität ein und wählen Sie eine Tabelle oder Ansicht aus (siehe Snowflakes Übersicht über Ansichten). Jedes Benutzeroberflächenelement dieses Schritts wird nachfolgend beschrieben.
-
Endpunktmenü: Wenn mehrere Endpunkte desselben Connector-Typs konfiguriert sind, zeigt ein Menü oben auf dem Bildschirm den aktuellen Endpunktnamen an. Klicken Sie auf das Menü, um zu einem anderen Endpunkt zu wechseln. Weitere Informationen finden Sie unter Zugewiesenen Endpunkt ändern in Konfigurationsbildschirme.
- Endpunkt bearbeiten: Wird angezeigt, wenn Sie den Mauszeiger über den aktuellen Endpunktnamen bewegen. Klicken Sie, um die Verbindungskonfiguration des aktuell ausgewählten Endpunkts zu bearbeiten.
-
Name: Geben Sie einen Namen ein, um die Aktivität zu identifizieren. Der Name muss für jede Snowflake Insert-Aktivität eindeutig sein und darf keine Schrägstriche
/oder Doppelpunkte:enthalten. -
Objekt auswählen: Dieser Bereich zeigt Objekte an, die im Snowflake-Endpunkt verfügbar sind. Beim erneuten Öffnen einer vorhandenen Aktivitätskonfiguration wird nur das ausgewählte Objekt angezeigt, anstatt die gesamte Objektliste neu zu laden.
-
Ausgewähltes Snowflake-Objekt: Nach der Auswahl eines Objekts wird es hier aufgelistet.
-
Suche: Geben Sie einen beliebigen Spaltenwert in das Suchfeld ein, um die Objektliste zu filtern. Bei der Suche wird die Groß-/Kleinschreibung nicht beachtet. Wenn Objekte bereits in der Tabelle angezeigt werden, werden die Tabellenergebnisse mit jedem Tastendruck in Echtzeit gefiltert. Um Objekte vom Endpunkt beim Suchen neu zu laden, geben Sie Suchkriterien ein und aktualisieren Sie dann wie nachfolgend beschrieben.
-
-
Aktualisieren: Klicken Sie auf das Aktualisierungssymbol oder auf das Wort Aktualisieren, um Objekte vom Snowflake-Endpunkt neu zu laden. Dies kann nützlich sein, wenn Objekte zu Snowflake hinzugefügt wurden. Diese Aktion aktualisiert alle Metadaten, die zum Erstellen der Tabelle der angezeigten Objekte verwendet werden.
-
Objekt auswählen: Klicken Sie in der Tabelle auf eine beliebige Stelle in einer Zeile, um ein Objekt auszuwählen. Es kann nur ein Objekt ausgewählt werden. Die für jedes Objekt verfügbaren Informationen werden vom Snowflake-Endpunkt abgerufen:
-
Name: Der Name eines Objekts, entweder eine Tabelle oder eine Ansicht.
-
Typ: Der Typ des Objekts, entweder eine Tabelle oder eine Ansicht.
-
Tipp
Wenn die Tabelle nicht mit verfügbaren Objekten gefüllt wird, ist die Snowflake-Verbindung möglicherweise nicht erfolgreich. Stellen Sie sicher, dass Sie verbunden sind, indem Sie die Verbindung erneut öffnen und die Anmeldedaten erneut testen.
-
Speichern und beenden: Falls aktiviert, klicken Sie, um die Konfiguration für diesen Schritt zu speichern und die Aktivitätskonfiguration zu schließen.
-
Weiter: Klicken Sie, um die Konfiguration für diesen Schritt vorübergehend zu speichern und zum nächsten Schritt zu wechseln. Die Konfiguration wird erst gespeichert, wenn Sie auf die Schaltfläche Fertig im letzten Schritt klicken.
-
Änderungen verwerfen: Klicken Sie nach dem Vornehmen von Änderungen, um die Konfiguration zu schließen, ohne Änderungen an einem Schritt zu speichern. Eine Meldung fordert Sie auf zu bestätigen, dass Sie die Änderungen verwerfen möchten.
Schritt 2: Wählen Sie einen Ansatz
Für das Einfügen von Daten in Snowflake werden verschiedene Ansätze unterstützt. Wählen Sie zwischen SQL Insert oder Stage File. Bei Verwendung des Stage File-Ansatzes wählen Sie entweder die Amazon S3- oder Internal-Stagingdateitypen.
- SQL Insert-Ansatz
- Amazon S3 Stage File-Ansatz
- Google Cloud Storage Stage File-Ansatz
- Internal Stage File-Ansatz
- Microsoft Azure Stage File-Ansatz
SQL Insert-Ansatz
Bei diesem Ansatz werden die Tabellenspalten im folgenden Datenschema-Schritt angezeigt, sodass sie in einer Transformation zugeordnet werden können.
-
Ansatz: Verwenden Sie das Dropdown-Menü, um SQL Insert auszuwählen.
-
Zurück: Klicken Sie, um zum vorherigen Schritt zurückzukehren und die Konfiguration vorübergehend zu speichern.
-
Weiter: Klicken Sie, um zum nächsten Schritt zu wechseln und die Konfiguration vorübergehend zu speichern. Die Konfiguration wird erst gespeichert, wenn Sie auf die Schaltfläche Fertig im letzten Schritt klicken.
-
Änderungen verwerfen: Klicken Sie nach dem Vornehmen von Änderungen, um die Konfiguration zu schließen, ohne Änderungen an einem Schritt zu speichern. Eine Meldung fordert Sie auf zu bestätigen, dass Sie die Änderungen verwerfen möchten.
Amazon S3 Stage File-Ansatz
Dieser Ansatz ermöglicht das Einfügen einer CSV-Datei in Snowflake mit einer Amazon S3-Quelle. Die Datei wird bereitgestellt und dann gemäß den Spezifikationen des Anforderungsdatenschemas in die Tabelle kopiert.
Informationen zu Anfragen an Amazon S3 finden Sie unter Making Requests in der Amazon S3-Dokumentation.
-
Ansatz: Verwenden Sie das Dropdown-Menü, um Stage File auszuwählen.
-
Stage-Typ: Wählen Sie Amazon S3, um Daten aus dem Amazon S3-Speicher abzurufen.
-
Authentifizierungstyp: Wählen Sie zwischen Credentials oder Storage Integration. Credentials erfordert die Amazon S3-Zugriffschlüssel-ID und den geheimen Zugriffschlüssel. Storage Integration erfordert nur den Namen der Speicherintegration. Diese Authentifizierungstypen werden nachfolgend behandelt.
Credentials-Authentifizierung
Der Authentifizierungstyp Credentials erfordert die Amazon S3-Zugriffschlüssel-ID und den geheimen Zugriffschlüssel (Informationen zu Anfragen an Amazon S3 finden Sie unter Making Requests in der Amazon S3-Dokumentation).
-
Authentication Type: Wählen Sie Credentials.
-
Access Key ID: Geben Sie die Amazon S3 Access Key ID ein.
-
Secret Access Key: Geben Sie den Amazon S3 Secret Access Key ein.
Storage Integration-Authentifizierung
Der Authentifizierungstyp Storage Integration erfordert die Erstellung einer Snowflake Storage Integration. Informationen zum Erstellen einer Snowflake Storage Integration finden Sie unter Create Storage Integration in der Snowflake-Dokumentation.
-
Authentication Type: Wählen Sie Storage Integration.
-
Storage Integration Name: Geben Sie den Namen der Snowflake Storage Integration ein.
Zusätzliche Optionen
Für beide Authentifizierungstypen Credentials und Storage Integration stehen diese zusätzlichen Optionen zur Verfügung:
-
Bucket Name: Geben Sie einen gültigen Bucket-Namen für einen vorhandenen Bucket auf dem Amazon S3-Server ein. Dies wird ignoriert, wenn
bucketNameim DatenschemaInsertAmazonS3Requestangegeben ist. -
File Path: Geben Sie den Dateipfad ein.
-
On Error: Wählen Sie eine dieser Optionen aus dem Dropdown On Error; zusätzliche Optionen werden je nach Bedarf angezeigt:
-
Abort_Statement: Bricht die Verarbeitung ab, wenn Fehler auftreten.
-
Continue: Setzt das Laden der Datei fort, auch wenn Fehler auftreten.
-
Skip_File: Überspringt die Datei, wenn Fehler in der Datei auftreten.
-
Skip_File_\<num>: Überspringt die Datei, wenn die Anzahl der Fehler in der Datei gleich oder größer als die unter Skip File Number angegebene Anzahl ist.
-
Skip_File_\<num>%: Überspringt die Datei, wenn der Prozentsatz der Fehler in der Datei den unter Skip File Number Percentage angegebenen Prozentsatz überschreitet.
-
-
Error on Column Count Mismatch: Wenn ausgewählt, wird ein Fehler im Fehlerknoten des Antwortschemas gemeldet, wenn die Quell- und Zielspaltenzahlen nicht übereinstimmen. Wenn Sie diese Option nicht auswählen, schlägt der Vorgang nicht fehl und die bereitgestellten Daten werden eingefügt.
-
Back: Klicken Sie, um zum vorherigen Schritt zurückzukehren und die Konfiguration vorübergehend zu speichern.
-
Next: Klicken Sie, um zum nächsten Schritt zu wechseln und die Konfiguration vorübergehend zu speichern. Die Konfiguration wird erst gespeichert, wenn Sie auf der letzten Seite auf die Schaltfläche Finished klicken.
-
Discard changes: Klicken Sie nach dem Vornehmen von Änderungen, um die Konfiguration zu schließen, ohne die in einem beliebigen Schritt vorgenommenen Änderungen zu speichern. Eine Meldung fordert Sie auf zu bestätigen, dass Sie die Änderungen verwerfen möchten.
Internal Stage File-Ansatz
Dieser Ansatz ermöglicht das Einfügen einer CSV-Datei in Snowflake. Die Datei wird bereitgestellt und dann gemäß den Spezifikationen des Anforderungsdatenschemas in die Tabelle kopiert.
-
Approach: Verwenden Sie das Dropdown, um Stage File auszuwählen.
-
Stage Type: Wählen Sie Internal, um die Daten aus einer internen Quelle abzurufen.
-
On Error: Wählen Sie eine dieser Optionen aus dem Dropdown On Error; zusätzliche Optionen werden je nach Bedarf angezeigt:
-
Abort_Statement: Bricht die Verarbeitung ab, wenn Fehler auftreten.
-
Continue: Setzt das Laden der Datei fort, auch wenn Fehler auftreten.
-
Skip_File: Überspringt die Datei, wenn Fehler in der Datei auftreten.
-
Skip_File_\<num>: Überspringt die Datei, wenn die Anzahl der Fehler in der Datei gleich oder größer als die unter Skip File Number angegebene Anzahl ist.
-
Skip_File_\<num>%: Überspringt die Datei, wenn der Prozentsatz der Fehler in der Datei den unter Skip File Number Percentage angegebenen Prozentsatz überschreitet.
-
-
Error on Column Count Mismatch: Wenn ausgewählt, wird ein Fehler im Fehlerknoten des Antwortschemas gemeldet, wenn die Quell- und Zielspaltenzahlen nicht übereinstimmen. Wenn Sie diese Option nicht auswählen, schlägt der Vorgang nicht fehl und die bereitgestellten Daten werden eingefügt.
-
Back: Klicken Sie, um zum vorherigen Schritt zurückzukehren und die Konfiguration vorübergehend zu speichern.
-
Next: Klicken Sie, um zum nächsten Schritt zu wechseln und die Konfiguration vorübergehend zu speichern. Die Konfiguration wird erst gespeichert, wenn Sie auf der letzten Seite auf die Schaltfläche Finished klicken.
-
Änderungen verwerfen: Nach dem Vornehmen von Änderungen klicken Sie hier, um die Konfiguration zu schließen, ohne die an einem Schritt vorgenommenen Änderungen zu speichern. Eine Meldung fordert Sie auf, zu bestätigen, dass Sie die Änderungen verwerfen möchten.
Google Cloud Storage Stage File-Ansatz
Mit diesem Ansatz können Sie eine CSV-Datei in Google Cloud Storage einfügen. Die Datei wird bereitgestellt und dann gemäß den Spezifikationen des Request-Datenschemas in die Tabelle kopiert.
-
Ansatz: Verwenden Sie das Dropdown-Menü, um Stage File auszuwählen.
-
Stage-Typ: Wählen Sie Google Cloud Storage aus, um Daten aus einer internen Quelle abzurufen.
-
Name der Speicherintegration: Geben Sie den Namen der Snowflake-Speicherintegration ein.
-
Bucket-Name: Geben Sie einen gültigen Bucket-Namen für einen vorhandenen Bucket in Google Cloud Storage ein. Dies wird ignoriert, wenn
bucketNameim DatenschemaInsertGoogleCloudRequestangegeben ist. -
Dateipfad: Geben Sie den Dateipfad ein.
-
Bei Fehler: Wählen Sie eine dieser Optionen aus dem Dropdown-Menü Bei Fehler aus. Weitere Optionen werden je nach Bedarf angezeigt:
-
Abort_Statement: Bricht die Verarbeitung ab, wenn Fehler auftreten.
-
Continue: Setzt das Laden der Datei fort, auch wenn Fehler auftreten.
-
Skip_File: Überspringt die Datei, wenn Fehler in der Datei auftreten.
-
Skip_File_\<num>: Überspringt die Datei, wenn die Anzahl der Fehler in der Datei gleich oder größer als die unter Skip File Number angegebene Anzahl ist.
-
Skip_File_\<num>%: Überspringt die Datei, wenn der Prozentsatz der Fehler in der Datei den unter Skip File Number Percentage angegebenen Prozentsatz überschreitet.
-
-
Fehler bei Spaltenzahlabweichung: Wenn diese Option aktiviert ist, wird ein Fehler im Fehlerknoten des Response-Schemas gemeldet, wenn die Quell- und Zielspaltenzahlen nicht übereinstimmen. Wenn Sie diese Option nicht aktivieren, schlägt der Vorgang nicht fehl und die bereitgestellten Daten werden eingefügt.
-
Zurück: Klicken Sie hier, um zum vorherigen Schritt zurückzukehren und die Konfiguration vorübergehend zu speichern.
-
Weiter: Klicken Sie hier, um zum nächsten Schritt zu wechseln und die Konfiguration vorübergehend zu speichern. Die Konfiguration wird erst gespeichert, wenn Sie auf der letzten Seite auf die Schaltfläche Fertig klicken.
-
Änderungen verwerfen: Nach dem Vornehmen von Änderungen klicken Sie hier, um die Konfiguration zu schließen, ohne die an einem Schritt vorgenommenen Änderungen zu speichern. Eine Meldung fordert Sie auf, zu bestätigen, dass Sie die Änderungen verwerfen möchten.
Microsoft Azure Stage File-Ansatz
Mit diesem Ansatz können Sie eine CSV-Datei mit einer Microsoft Azure-Quelle in Snowflake einfügen. Die Datei wird bereitgestellt und dann gemäß den Spezifikationen des Request-Datenschemas in die Tabelle kopiert.
-
Ansatz: Verwenden Sie das Dropdown-Menü, um Stage File auszuwählen.
-
Stage-Typ: Wählen Sie Microsoft Azure aus, um Daten aus Microsoft Azure-Speichercontainern abzurufen.
-
Authentifizierungstyp: Wählen Sie zwischen Credentials oder Storage Integration. Credentials erfordert ein Microsoft Azure Shared Access Signature (SAS)-Token und einen Speicherkontonamen. Storage Integration erfordert nur einen Namen für die Speicherintegration. Diese Authentifizierungstypen werden nachfolgend behandelt.
Credentials-Authentifizierung
Der Authentifizierungstyp Credentials erfordert ein Microsoft Azure SAS-Token und einen Speicherkontonamen.
-
Authentifizierungstyp: Wählen Sie Credentials aus.
-
Azure SAS-Token: Geben Sie das Microsoft Azure SAS-Token ein. Informationen zum Erstellen von SAS-Tokens für Speichercontainer in Microsoft Azure finden Sie unter Create SAS tokens for your storage containers in der Microsoft Azure-Dokumentation.
-
Speicherkontoname: Geben Sie den Microsoft Azure-Speicherkontonamen ein.
Storage Integration-Authentifizierung
Der Authentifizierungstyp Storage Integration erfordert die Erstellung einer Snowflake-Speicherintegration. Informationen zum Erstellen einer Snowflake-Speicherintegration finden Sie unter Create Storage Integration in der Snowflake-Dokumentation.
-
Authentifizierungstyp: Wählen Sie Storage Integration.
-
Name der Storage Integration: Geben Sie den Namen der Snowflake-Storage-Integration ein.
Zusätzliche Optionen
Für beide Authentifizierungsmethoden Credentials und Storage Integration stehen diese zusätzlichen Optionen zur Verfügung:
-
Master Key: Geben Sie den Master Key ein, der für die clientseitige Verschlüsselung (CSE) in Microsoft Azure verwendet wird. Dieser wird ignoriert, wenn
azureMasterKeyim DatenschemaInsertMicrosoftAzureCloudRequestangegeben ist.Hinweis
Informationen zum Erstellen von Schlüsseln in Microsoft Azure finden Sie unter Quickstart: Set and retrieve a key from Azure Key Vault using the Azure portal in der Microsoft Azure-Dokumentation.
Informationen zur Storage-CSE in Microsoft Azure finden Sie unter Client-side encryption for blobs in der Microsoft Azure-Dokumentation.
-
Container Name: Geben Sie einen gültigen Bucket-Namen für einen vorhandenen Storage-Container in Microsoft Azure ein. Dieser wird ignoriert, wenn
containerNameim DatenschemaInsertMicrosoftAzureCloudRequestangegeben ist. -
File Path: Geben Sie den Dateipfad ein.
-
On Error: Wählen Sie eine dieser Optionen aus dem Dropdown On Error; je nach Auswahl werden zusätzliche Optionen angezeigt:
-
Abort_Statement: Bricht die Verarbeitung ab, wenn Fehler auftreten.
-
Continue: Setzt das Laden der Datei fort, auch wenn Fehler auftreten.
-
Skip_File: Überspringt die Datei, wenn Fehler in der Datei auftreten.
-
Skip_File_\<num>: Überspringt die Datei, wenn die Anzahl der Fehler in der Datei gleich oder größer als die in Skip File Number angegebene Anzahl ist.
-
Skip_File_\<num>%: Überspringt die Datei, wenn der Prozentsatz der Fehler in der Datei den in Skip File Number Percentage angegebenen Prozentsatz überschreitet.
-
-
Error on Column Count Mismatch: Wenn aktiviert, wird ein Fehler im Fehlerknoten des Antwortsschemas gemeldet, wenn die Spaltenanzahl der Quelle und des Ziels nicht übereinstimmen. Wenn Sie diese Option nicht aktivieren, schlägt der Vorgang nicht fehl und die bereitgestellten Daten werden eingefügt.
-
Back: Klicken Sie, um zum vorherigen Schritt zurückzukehren und die Konfiguration vorübergehend zu speichern.
-
Next: Klicken Sie, um zum nächsten Schritt zu wechseln und die Konfiguration vorübergehend zu speichern. Die Konfiguration wird erst gespeichert, wenn Sie auf der letzten Seite auf die Schaltfläche Finished klicken.
-
Discard changes: Klicken Sie nach Änderungen, um die Konfiguration zu schließen, ohne die Änderungen an einem Schritt zu speichern. Eine Meldung fordert Sie auf zu bestätigen, dass Sie die Änderungen verwerfen möchten.
Schritt 3: Datenschemas überprüfen
Die vom Endpunkt generierten Request- und Response-Schemas werden angezeigt. Die angezeigten Schemas hängen vom im vorherigen Schritt angegebenen Approach ab.
Diese Unterabschnitte beschreiben die Request- und Response-Strukturen für jede Kombination aus Approach und Stage-Typ:
- SQL insert approach
- Amazon S3 stage file approach
- Google Cloud Storage stage file approach
- Internal stage file approach
- Microsoft Azure stage file approach
Diese Aktionen sind bei jedem Approach verfügbar:
-
Data Schemas: Diese Datenschemas werden von angrenzenden Transformationen geerbt und werden erneut während der Transformationszuordnung angezeigt.
Hinweis
Daten, die in einer Transformation bereitgestellt werden, haben Vorrang vor der Aktivitätskonfiguration.
Tipp
Wenn ein einfaches Anführungszeichen (
') in einer Request-Payload vorhanden ist, wird zur Laufzeit ein Syntaxfehler zurückgegeben. Sie können die Einstellung Escape special characters in der Verbindung aktivieren, damit die Aktivität einfache Anführungszeichen (') zur Laufzeit automatisch escaped.
Beziehen Sie sich auf die Snowflake SQL-Befehle und die Snowflake API-Referenz für weitere Informationen.
-
Aktualisieren: Klicken Sie auf das Aktualisierungssymbol oder auf das Wort Aktualisieren, um Schemas vom Snowflake-Endpunkt neu zu generieren. Diese Aktion generiert auch ein Schema an anderen Stellen im Projekt neu, an denen auf dasselbe Schema verwiesen wird, z. B. in einer angrenzenden Transformation.
-
Zurück: Klicken Sie, um die Konfiguration für diesen Schritt vorübergehend zu speichern und zum vorherigen Schritt zurückzukehren.
-
Fertig: Klicken Sie, um die Konfiguration für alle Schritte zu speichern und die Aktivitätskonfiguration zu schließen.
-
Änderungen verwerfen: Klicken Sie nach dem Vornehmen von Änderungen, um die Konfiguration zu schließen, ohne Änderungen an einem Schritt zu speichern. Eine Meldung fordert Sie auf zu bestätigen, dass Sie die Änderungen verwerfen möchten.
SQL Insert-Ansatz
Wenn der Ansatz SQL Insert ist, werden die Tabellenspalten angezeigt, sodass sie in einer Transformation zugeordnet werden können.
-
Anfrage
Anfrage-Schemafeld/-Knoten Hinweise tableKnoten mit dem Tabellennamen. column_AName der ersten Tabellenspalte. column_BName der zweiten Tabellenspalte. . . .Nachfolgende Tabellenspalten. -
Antwort
Antwort-Schemafeld/-Knoten Hinweise statusBoolesches Flag, das angibt, ob das Einfügen des Datensatzes erfolgreich war. errorMessageAussagekräftige Fehlermeldung bei einem Fehler beim Einfügen. recordsInsertedAnzahl der eingefügten Datensätze bei erfolgreichem Einfügen.
Amazon S3 Stage File-Ansatz
Wenn der Ansatz Amazon S3 Stage File ist, werden die Spezifikationen für das Staging und Einfügen einer CSV-Datei im Datenschema angezeigt, damit sie in einer Transformation zugeordnet werden können. Das verwendete Muster entspricht nur einer Datei. Wenn das Muster mehr als einer Datei entspricht, wird die Aktivität mit einer aussagekräftigen Meldung fehlschlagen.
-
Anfrage
Anfrage-Schemafeld/-Knoten Hinweise accessKeyAmazon S3 Access Key ID. secretAccessKeyAmazon S3 Secret Access Key. storageintegrationNameName der Snowflake-Speicherintegration, die für die Authentifizierung der Snowflake-Speicherintegration verwendet werden soll. bucketNameGültiger Bucket-Name für einen vorhandenen Bucket auf dem Amazon S3-Server. filePathSpeicherort der Stage-Datei im Amazon S3-Bucket. patternRegulärer Ausdrucksmuster, das zum Suchen der Datei auf der Stage verwendet wird; wenn compressionGZIPist, wird[.]gzan das Muster angehängt.onErrorAusgewählte On Error-Option. encryptionKnoten, der die Verschlüsselung darstellt. encryptionType[Amazon S3-Verschlüsselungstyp][aws-encryption] (entweder serverseitige Verschlüsselung oder clientseitige Verschlüsselung). masterKeyAmazon S3 Master Key. kmsKeyId[Amazon Key Management Service][amazon-kms] Master-ID. fileFormatKnoten, der das Dateiformat darstellt. nullIfEine Zeichenkette, die in SQL NULLkonvertiert werden soll; standardmäßig ist es eine leere Zeichenkette. Siehe die [NULL_IF-Option][null-if] der Snowflake-Dokumentation [COPY INTO<location>][copy-into-location].enclosingCharZeichen, das zum Einschließen von Datenfeldern verwendet wird; siehe die [ FIELD_OPTIONALLY_ENCLOSED_BY-Option][field-option] der Snowflake-Dokumentation [COPY INTO<location>][copy-into-location].Hinweis
Das
enclosingCharkann entweder ein einfaches Anführungszeichen'oder ein doppeltes Anführungszeichen"sein. Um das einfache Anführungszeichen zu verwenden, verwenden Sie entweder die Oktal-Darstellung'oder die Hex-Darstellung0x27oder verwenden Sie ein doppeltes einfaches Anführungszeichen-Escape''. Wenn ein Feld dieses Zeichen enthält, müssen Sie es mit demselben Zeichen escapen.compressionDer Komprimierungsalgorithmus, der für die Datendateien verwendet wird. GZIPoderNONEwerden unterstützt. Siehe die [Komprimierungsoption][compression] der Snowflake-Dokumentation [COPY INTO<location>][copy-into-location].skipHeaderAnzahl der Zeilen am Anfang der Quelldatei, die übersprungen werden sollen. errorOnColumnCountMismatchBoolesches Flag, um einen Fehler zu melden, wenn die Quell- und Zielanzahl des Antwortschemas nicht übereinstimmen. fieldDelimiterDas Trennzeichen, das zum Trennen von Datenfeldern verwendet wird; siehe die [ FIELD_DELIMITER-Option][del-type-csv] der Snowflake-Dokumentation [COPY INTO<table>][copy-into-table].recordDelimiterDas Trennzeichen, das zum Trennen von Feldgruppen verwendet wird; siehe die [ RECORD_DELIMITER-Option][del-type-csv] der Snowflake-Dokumentation [COPY INTO<table>][copy-into-table].
[aws-encryption]: https://docs.aws.amazon.com/kms/latest/developerguide/services-s3.html
[amazon-kms]:https://docs.aws.amazon.com/kms/index.html
- **Antwort**
| Antwortschema-Feld/Knoten | Hinweise |
| ------------------------- | ------------------------------------------------------------------------------------------- |
| `status` | Zurückgegebener Status. |
| `file` | Name der bereitgestellten CSV-Datei, die beim Einfügen von Daten in die Snowflake-Tabelle verarbeitet wird. |
| `rows_parsed` | Anzahl der aus der CSV-Datei analysierten Zeilen. |
| `rows_loaded` | Anzahl der aus der CSV-Datei ohne Fehler in die Snowflake-Tabelle geladenen Zeilen. |
| **`error`** | Knoten, der die Fehlermeldungen darstellt. |
| `error_limit` | Anzahl der Fehler, die dazu führen, dass die Datei wie in *Skip_File_\<num\>* festgelegt übersprungen wird. |
| `errors_seen` | Anzahl der aufgetretenen Fehler. |
| `first_error` | Der erste Fehler in der Quelldatei. |
| `first_error_line` | Die erste Zeilennummer des ersten Fehlers. |
| `first_error_character` | Das erste Zeichen des ersten Fehlers. |
| `first_error_column_name` | Der Spaltenname der ersten Fehlerposition. |
#### <a id="step-3-google-cloud-storage-stage-file-approach"></a>Google Cloud Storage Stage File-Ansatz {: #a-idstep-3-google-cloud-storage-stage-file-approachagoogle-cloud-storage-stage-file-approach }
Bei Verwendung des **Google Cloud Storage Stage File**-Ansatzes werden die Spezifikationen für das Bereitstellen und Einfügen einer CSV-Datei im Datenschema angezeigt, damit diese in einer Transformation zugeordnet werden können. Das verwendete Muster entspricht nur einer Datei. Wenn das Muster mehr als einer Datei entspricht, wird die Aktivität mit einer aussagekräftigen Meldung fehlgeschlagen.
- **Anfrage**
| Anfrageschema-Feld/Knoten | Hinweise |
| ----------------------------- | ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- |
| `storageintegrationName` | Name der Snowflake-Speicherintegration, die für die Authentifizierung der Snowflake-Speicherintegration verwendet werden soll. |
| `bucketName` | Gültiger Bucket-Name für einen vorhandenen Bucket in Google Cloud Storage. |
| `filePath` | Speicherort der Stage-Datei im Google Cloud Storage-Bucket. |
| `pattern` | Regulärer Ausdrucksmuster zum Auffinden der Datei auf der Stage; wenn **`compressData`** wahr ist, wird `[.]gz` an das Muster angehängt. |
| `onError` | Ausgewählte **On Error**-Option. |
| **`fileFormat`** | Knoten, der das Dateiformat darstellt. |
| `nullIf` | Eine Zeichenkette, die in SQL `NULL` konvertiert werden soll; standardmäßig ist sie eine leere Zeichenkette. Siehe die [`NULL_IF`-Option][null-if] der Snowflake-Dokumentation [`COPY INTO` _`<location>`_][copy-into-location]. |
| `enclosingChar` | Zeichen zum Einschließen von Datenfeldern; siehe die [`FIELD_OPTIONALLY_ENCLOSED_BY`-Option][field-option] der Snowflake-Dokumentation [`COPY INTO` _`<location>`_][copy-into-location]. <div class="admonition note"> <p class="admonition-title">Hinweis</p> <p>Das **`enclosingChar`** kann entweder ein einfaches Anführungszeichen `'` oder ein doppeltes Anführungszeichen `"` sein. Um das einfache Anführungszeichen zu verwenden, nutze entweder die Oktaldarstellung `'` oder die Hexadezimaldarstellung `0x27` oder verwende ein doppeltes einfaches Anführungszeichen als Escape `''`. Wenn ein Feld dieses Zeichen enthält, escape es mit demselben Zeichen.</p> </div> |
| `compression` | Der für die Datendateien verwendete Komprimierungsalgorithmus. `GZIP` oder `NONE` werden unterstützt. Siehe die [Komprimierungsoption][compression] der Snowflake-Dokumentation [`COPY INTO` _`<location>`_][copy-into-location]. |
| `skipHeader` | Anzahl der Zeilen am Anfang der Quelldatei, die übersprungen werden sollen. |
| `errorOnColumnCountMismatch` | Boolesches Flag zum Melden eines Fehlers, wenn die Anzahl der Antwortschema-Quelle und des Ziels nicht übereinstimmen. |
| `fieldDelimiter` | Das Trennzeichen zum Trennen von Datenfeldern; siehe die [`FIELD_DELIMITER`-Option][del-type-csv] der Snowflake-Dokumentation [`COPY INTO` _`<table>`_][copy-into-table]. |
| `recordDelimiter` | Das Trennzeichen zum Trennen von Feldgruppen; siehe die [`RECORD_DELIMITER`-Option][del-type-csv] der Snowflake-Dokumentation [`COPY INTO` _`<table>`_][copy-into-table]. |
-
Antwort
Antwortschema-Feld/Knoten Hinweise statusZurückgegebener Status. fileName der bereitgestellten CSV-Datei, die beim Einfügen von Daten in die Snowflake-Tabelle verarbeitet wird. rows_parsedAnzahl der aus der CSV-Datei analysierten Zeilen. rows_loadedAnzahl der aus der CSV-Datei ohne Fehler in die Snowflake-Tabelle geladenen Zeilen. errorKnoten, der die Fehlermeldungen darstellt. error_limitAnzahl der Fehler, die dazu führen, dass die Datei wie in Skip_File_\<num> festgelegt übersprungen wird. errors_seenAnzahl der angetroffenen Fehler. first_errorDer erste Fehler in der Quelldatei. first_error_lineDie erste Zeilennummer des ersten Fehlers. first_error_characterDas erste Zeichen des ersten Fehlers. first_error_column_nameDer Spaltenname der ersten Fehlerposition.
Ansatz mit interner Staging-Datei
Bei Verwendung des Ansatzes Internal Stage File werden die Spezifikationen für das Staging und Einfügen einer CSV-Datei im Datenschema angezeigt, damit diese in einer Transformation zugeordnet werden können. Das verwendete Muster entspricht nur einer Datei. Wenn das Muster mehr als einer Datei entspricht, wird die Aktivität mit einer aussagekräftigen Meldung fehlschlagen.
-
Anfrage
Anfrageschema-Feld/Knoten Hinweise stageNameInterne Snowflake-Stage, Tabellenname oder Pfad. destinationPrefixPfad oder Präfix, unter dem die Daten auf der Snowflake-Stage hochgeladen werden. fileContentDateiinhalt im CSV-Format, der für den Upload in die Snowflake-Tabelle bereitgestellt werden soll. destinationFileNameZieldateiname, der auf der Snowflake-Stage verwendet werden soll. compressDataBoolesches Flag, das angibt, ob die Daten vor dem Upload in die interne Snowflake-Stage komprimiert werden sollen. patternRegulärer-Ausdruck-Muster zum Auffinden der Datei auf der Stage; wenn compressDatawahr ist, wird[.]gzan das Muster angehängt.onErrorAusgewählte Option On Error. fileFormatKnoten, der das Dateiformat darstellt. nullIfEine Zeichenkette, die in SQL NULLkonvertiert werden soll; standardmäßig ist dies eine leere Zeichenkette. Siehe die [NULL_IF-Option][null-if] der Snowflake-Dokumentation [COPY INTO<location>][copy-into-location].enclosingCharZeichen zum Einschließen von Datenfeldern; siehe die [ FIELD_OPTIONALLY_ENCLOSED_BY-Option][field-option] der Snowflake-Dokumentation [COPY INTO<location>][copy-into-location].Hinweis
Das
enclosingCharkann entweder ein einfaches Anführungszeichen'oder ein doppeltes Anführungszeichen"sein. Um das einfache Anführungszeichen zu verwenden, nutzen Sie entweder die Oktaldarstellung'oder die Hexadezimaldarstellung0x27oder verwenden Sie ein doppeltes einfaches Anführungszeichen als Escape''. Wenn ein Feld dieses Zeichen enthält, escapen Sie es mit demselben Zeichen.errorOnColumnCountMismatchBoolesches Flag zum Melden eines Fehlers, wenn die Anzahl der Antwortschema-Quelle und des Ziels nicht übereinstimmen. fieldDelimiterDas Trennzeichen zum Trennen von Datenfeldern; siehe die [ FIELD_DELIMITER-Option][del-type-csv] der Snowflake-Dokumentation [COPY INTO<table>][copy-into-table].recordDelimiterDas Trennzeichen zum Trennen von Feldgruppen; siehe die [ RECORD_DELIMITER-Option][del-type-csv] der Snowflake-Dokumentation [COPY INTO<table>][copy-into-table]. -
Antwort
Antwortschema-Feld/Knoten Hinweise fileName der bereitgestellten CSV-Datei, die beim Einfügen von Daten in die Snowflake-Tabelle verarbeitet wird. statusZurückgegebener Status. rowsParsedAnzahl der aus der CSV-Datei analysierten Zeilen. rowsLoadedAnzahl der aus der CSV-Datei ohne Fehler in die Snowflake-Tabelle geladenen Zeilen. errorKnoten, der die Fehlermeldungen darstellt. errorDie Fehlermeldung. codeDer zurückgegebene Fehlercode. sqlStateDer zurückgegebene SQL-Status-Numerischer Fehlercode des Datenbankaufrufs. fileKnoten, der die Fehlermeldungen darstellt. columnNameName und Reihenfolge der Spalte, die den Fehler enthielt. rowNumberDie Nummer der Zeile in der Quelldatei, in der der Fehler aufgetreten ist. rowStartLineDie Nummer der ersten Zeile der Zeile, in der der Fehler aufgetreten ist.
Microsoft Azure Stage File-Ansatz
Bei Verwendung des Microsoft Azure Stage File-Ansatzes werden die Spezifikationen für das Staging und Einfügen einer CSV-Datei im Datenschema angezeigt, damit diese in einer Transformation zugeordnet werden können. Das verwendete Muster entspricht nur einer Datei. Wenn das Muster mehr als einer Datei entspricht, wird die Aktivität mit einer aussagekräftigen Meldung fehlschlagen.
-
Anfrage
Anfrageschema-Feld/Knoten Hinweise azureSasToken[Microsoft Azure Shared Access Signature (SAS) Token][sas-token]. azureStorageAccountNameMicrosoft Azure Storage Account Name. azureStorageintegrationNameName der Snowflake-Speicherintegration, die für die Snowflake-Speicherintegrations-Authentifizierung verwendet werden soll. containerNameGültiger Containername für einen vorhandenen Speichercontainer in Microsoft Azure. filePathSpeicherort der bereitgestellten Datei im Microsoft Azure-Speichercontainer. patternRegulärer Ausdrucksmuster, das zum Suchen der Datei auf der Bereitstellung verwendet wird; wenn compressionGZIPist, wird[.]gzan das Muster angehängt.onErrorAusgewählte On Error-Option. encryptionKnoten, der die Verschlüsselung darstellt. encryptionType[Microsoft Azure-Verschlüsselungstyp][azure-encryption] (nur clientseitige Verschlüsselung). azureMasterKeyMicrosoft Azure Master Key. fileFormatKnoten, der das Dateiformat darstellt. nullIfEine Zeichenkette, die in SQL NULLkonvertiert werden soll; standardmäßig ist es eine leere Zeichenkette. Siehe die [NULL_IF-Option][null-if] der Snowflake-[COPY INTO<location>-Dokumentation][copy-into-location].enclosingCharZeichen, das zum Einschließen von Datenfeldern verwendet wird; siehe die [ FIELD_OPTIONALLY_ENCLOSED_BY-Option][field-option] der Snowflake-[COPY INTO<location>-Dokumentation][copy-into-location].Hinweis
Das
enclosingCharkann entweder ein einfaches Anführungszeichen'oder ein doppeltes Anführungszeichen"sein. Um das einfache Anführungszeichen zu verwenden, verwende entweder die Oktaldarstellung'oder die Hexadezimaldarstellung0x27oder verwende ein doppeltes einfaches Anführungszeichen-Escape''. Wenn ein Feld dieses Zeichen enthält, escape es mit demselben Zeichen.compressionDer für die Datendateien verwendete Komprimierungsalgorithmus. GZIPoderNONEwerden unterstützt. Siehe die [Komprimierungsoption][compression] der Snowflake-[COPY INTO<location>-Dokumentation][copy-into-location].skipHeaderAnzahl der Zeilen am Anfang der Quelldatei, die übersprungen werden sollen. errorOnColumnCountMismatchBoolesches Flag, um einen Fehler zu melden, wenn die Anzahl der Antwortschema-Quelle und des Ziels nicht übereinstimmen. fieldDelimiterDas Trennzeichen, das zum Trennen von Datenfeldern verwendet wird; siehe die [ FIELD_DELIMITER-Option][del-type-csv] der Snowflake-[COPY INTO<table>-Dokumentation][copy-into-table].recordDelimiterDas Trennzeichen, das zum Trennen von Feldgruppen verwendet wird; siehe die [ RECORD_DELIMITER-Option][del-type-csv] der Snowflake-[COPY INTO<table>-Dokumentation][copy-into-table].
[sas-token]: https://learn.microsoft.com/en-us/azure/cognitive-services/translator/document-translation/create-sas-tokens
[azure-encryption]: https://learn.microsoft.com/en-us/azure/storage/common/storage-service-encryption
- **Antwort**
| Antwortschema-Feld/Knoten | Hinweise |
| ------------------------- | ------------------------------------------------------------------------------------------- |
| `status` | Zurückgegebener Status. |
| `file` | Name der bereitgestellten CSV-Datei, die beim Einfügen von Daten in die Snowflake-Tabelle verarbeitet wird. |
| `rows_parsed` | Anzahl der aus der CSV-Datei analysierten Zeilen. |
| `rows_loaded` | Anzahl der aus der CSV-Datei ohne Fehler in die Snowflake-Tabelle geladenen Zeilen. |
| **`error`** | Knoten, der die Fehlermeldungen darstellt. |
| `error_limit` | Anzahl der Fehler, die dazu führen, dass die Datei wie in *Skip_File_\<num\>* festgelegt übersprungen wird. |
| `errors_seen` | Anzahl der angetroffenen Fehler. |
| `first_error` | Der erste Fehler in der Quelldatei. |
| `first_error_line` | Die erste Zeilennummer des ersten Fehlers. |
| `first_error_character` | Das erste Zeichen des ersten Fehlers. |
| `first_error_column_name` | Der Spaltenname der Position des ersten Fehlers. |
## Nächste Schritte {: #next-steps }
Nach der Konfiguration einer Snowflake-Aktivität **Einfügen** wird die Konfiguration des Vorgangs durch Hinzufügen und Konfigurieren weiterer Aktivitäten oder [Tools](/de/integration-studio/design/tools/) als Vorgangsschritte abgeschlossen. Es ist auch möglich, die Vorgangseinstellungen zu konfigurieren, die die Möglichkeit bieten, Vorgänge zu verketten, die sich in denselben oder verschiedenen Workflows befinden.
Menüaktionen für eine Aktivität sind über den Projektbereich und die Design-Canvas zugänglich. Weitere Informationen finden Sie unter [Menü „Aktivitätsaktionen"](/de/integration-studio/design/connectors/connector-basics#connectorbasics-actions-menu) in [Connector-Grundlagen](/de/integration-studio/design/connectors/connector-basics#connectorbasics).
Snowflake-Aktivitäten **Einfügen** können als Ziel mit diesen [Vorgangsmustern](/de/integration-studio/design/operations/validity#operationvalidity-valid-operation-patterns) verwendet werden:
- [Transformationsmuster](/de/integration-studio/design/operations/validity#operationvalidity-transformation-pattern)
- [Zwei-Transformations-Muster](/de/integration-studio/design/operations/validity#operationvalidity-two-transformation-pattern) (als erstes oder zweites Ziel)
Um die Aktivität mit Scripting-Funktionen zu verwenden, werden die Daten an einen temporären Speicherort geschrieben und dieser temporäre Speicherort dann in der Scripting-Funktion verwendet.
Wenn alles bereit ist, wird der Vorgang [bereitgestellt und ausgeführt](/de/integration-studio/design/operations/deployment-and-execution) und das Verhalten durch Überprüfung der [Vorgangsprotokolle](/de/integration-studio/design/operations/logs) validiert.
[null-if]: https://docs.snowflake.com/en/sql-reference/sql/copy-into-location.html#format-type-options-formattypeoptions
[copy-into-location]: https://docs.snowflake.com/en/sql-reference/sql/copy-into-location.html
[field-option]: https://docs.snowflake.com/en/sql-reference/sql/copy-into-location.html#format-type-options-formattypeoptions
[compression]: https://docs.snowflake.com/en/sql-reference/sql/copy-into-table.html#type-csv
[del-type-csv]: https://docs.snowflake.com/en/sql-reference/sql/copy-into-table.html#format-type-options-formattypeoptions
[copy-into-table]: https://docs.snowflake.com/en/sql-reference/sql/copy-into-table.html