Zum Inhalt springen

Snowflake Insert-Aktivität

Einführung

Eine Snowflake Insert-Aktivität, die ihre Snowflake-Verbindung nutzt, fügt Tabellendaten (entweder als CSV-Datei oder direkt auf Spalten einer Tabelle abgebildet) in Snowflake ein und ist als Ziel gedacht, um Daten in einem Vorgang zu konsumieren.

Erstellen einer Snowflake Insert-Aktivität

Eine Instanz einer Snowflake Insert-Aktivität wird aus einer Snowflake-Verbindung unter Verwendung des Aktivitätstyps Insert erstellt.

Um eine Instanz einer Aktivität zu erstellen, ziehen Sie den Aktivitätstyp auf die Entwurfsfläche oder kopieren Sie den Aktivitätstyp und fügen Sie ihn auf der Entwurfsfläche ein. Weitere Einzelheiten finden Sie unter Erstellen einer Aktivitäts- oder Toolinstanz in Komponentenwiederverwendung.

Eine vorhandene Snowflake Insert-Aktivität kann an diesen Orten bearbeitet werden:

Konfigurieren einer Snowflake Insert-Aktivität

Befolgen Sie diese Schritte, um eine Snowflake Insert-Aktivität zu konfigurieren:

Schritt 1: Geben Sie einen Namen ein und wählen Sie ein Objekt aus

In diesem Schritt geben Sie einen Namen für die Aktivität ein und wählen eine Tabelle oder Ansicht aus (siehe Snowflakes Übersicht über Ansichten). Jedes Benutzeroberflächenelement dieses Schrittes wird im Folgenden beschrieben.

  • Endpunktmenü: Wenn Sie mehrere Endpunkte des gleichen Verbindungstyps konfiguriert haben, wird ein Menü oben auf dem Bildschirm angezeigt, das den aktuellen Endpunktnamen anzeigt. Klicken Sie auf das Menü, um zu einem anderen Endpunkt zu wechseln. Weitere Informationen finden Sie unter Ändern des zugewiesenen Endpunkts in Konfigurationsbildschirmen.

    • Endpunkt bearbeiten: Wird angezeigt, wenn Sie über den aktuellen Endpunktnamen fahren. Klicken Sie, um die Verbindungsconfiguration 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 Abschnitt zeigt die in dem Snowflake-Endpunkt verfügbaren Objekte an. Beim Wiederöffnen einer vorhandenen Aktivitätskonfiguration wird nur das ausgewählte Objekt angezeigt, anstatt die gesamte Objektliste neu zu laden.

    • Ausgewähltes Snowflake-Objekt: Nachdem ein Objekt ausgewählt wurde, wird es hier aufgelistet.

    • Suche: Geben Sie den Wert einer beliebigen Spalte in das Suchfeld ein, um die Liste der Objekte zu filtern. Die Suche ist nicht groß-/kleinschreibungsempfindlich. Wenn Objekte bereits in der Tabelle angezeigt werden, werden die Tabellenergebnisse in Echtzeit mit jedem Tastendruck gefiltert. Um Objekte vom Endpunkt beim Suchen neu zu laden, geben Sie Suchkriterien ein und aktualisieren Sie dann, wie unten beschrieben.

    • Aktualisieren: Klicken Sie auf das Aktualisierungssymbol oder 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 in der Konfiguration angezeigten Objekttabelle verwendet werden.

  • Objekt auswählen: Klicken Sie innerhalb der Tabelle auf eine Zeile, um ein Objekt auszuwählen. Es kann nur ein Objekt ausgewählt werden. Die Informationen, die für jedes Objekt verfügbar sind, 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, könnte die Snowflake-Verbindung nicht erfolgreich sein. Stellen Sie sicher, dass Sie verbunden sind, indem Sie die Verbindung erneut öffnen und die Anmeldeinformationen erneut testen.

  • Speichern & Beenden: Wenn 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 fortzufahren. Die Konfiguration wird nicht gespeichert, bis Sie die Schaltfläche Fertig im letzten Schritt klicken.

  • Änderungen verwerfen: Nach Änderungen klicken Sie, um die Konfiguration zu schließen, ohne die vorgenommenen Änderungen zu speichern. Eine Nachricht fragt Sie, ob Sie die Änderungen wirklich verwerfen möchten.

Schritt 2: Einen Ansatz auswählen

Für das Einfügen von Daten in Snowflake werden verschiedene Ansätze unterstützt. Wählen Sie entweder SQL Insert oder Stage File. Wenn Sie den Ansatz Stage File verwenden, wählen Sie entweder die Dateitypen Amazon S3 oder Internal.

SQL Insert-Ansatz

Für diesen 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 fortzufahren und die Konfiguration vorübergehend zu speichern. Die Konfiguration wird nicht gespeichert, bis Sie die Schaltfläche Fertig im letzten Schritt klicken.

  • Änderungen verwerfen: Nachdem Sie Änderungen vorgenommen haben, klicken Sie, um die Konfiguration zu schließen, ohne die Änderungen an einem Schritt zu speichern. Eine Nachricht fordert Sie auf, zu bestätigen, dass Sie die Änderungen verwerfen möchten.

Amazon S3 Stage File-Ansatz

Dieser Ansatz ermöglicht es, eine CSV-Datei über eine Amazon S3-Quelle in Snowflake einzufügen. Die Datei wird gestaged und dann gemäß den Spezifikationen des Anforderungsdatenschemas in die Tabelle kopiert.

Für Informationen zum Stellen von Anfragen an Amazon S3 siehe Anfragen stellen 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 entweder Credentials oder Storage Integration. Credentials erfordert die Amazon S3-Zugangs-ID und den geheimen Zugriffsschlüssel. Storage Integration erfordert nur den Namen der Speicherintegration. Diese Authentifizierungstypen werden im Folgenden behandelt.

Authentifizierung mit Credentials

Der Authentifizierungstyp Credentials erfordert die Amazon S3-Zugangs-ID und den geheimen Zugriffsschlüssel (für Informationen zum Stellen von Anfragen an Amazon S3 siehe Anfragen stellen in der Amazon S3-Dokumentation).

  • Authentifizierungstyp: Wählen Sie Credentials.

  • Zugangs-ID: Geben Sie die Amazon S3-Zugangs-ID ein.

  • Geheimer Zugriffsschlüssel: Geben Sie den geheimen Zugriffsschlüssel für Amazon S3 ein.

Authentifizierung mit Storage Integration

Der Authentifizierungstyp Storage Integration erfordert die Erstellung einer Snowflake-Speicherintegration. Für Informationen zur Erstellung einer Snowflake-Speicherintegration siehe Storage Integration erstellen 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 die Authentifizierung sowohl bei Anmeldeinformationen als auch bei Storage Integration gibt es diese zusätzlichen Optionen:

  • Bucket-Name: Geben Sie einen gültigen Bucket-Namen für einen vorhandenen Bucket auf dem Amazon S3-Server ein. Dies wird ignoriert, wenn bucketName im Datenschema InsertAmazonS3Request angegeben ist.

  • Dateipfad: Geben Sie den Dateipfad ein.

  • Bei Fehler: Wählen Sie eine dieser Optionen aus dem Dropdown-Menü Bei Fehler; zusätzliche Optionen erscheinen entsprechend:

    • 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 die in Skip File Number angegebene Zahl erreicht oder überschreitet.

    • Skip_File_\<num>%: Überspringt die Datei, wenn der Prozentsatz der Fehler in der Datei den in Skip File Number Percentage angegebenen Prozentsatz überschreitet.

  • Fehler bei Spaltenanzahl-Mismatch: Wenn ausgewählt, wird ein Fehler im Fehlerknoten des Antwortschemas gemeldet, wenn die Quell- und Zielspaltenanzahl nicht übereinstimmt. Wenn Sie diese Option nicht auswählen, schlägt die Operation nicht fehl und die bereitgestellten Daten werden eingefügt.

  • 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 fortzufahren und die Konfiguration vorübergehend zu speichern. Die Konfiguration wird nicht gespeichert, bis Sie auf die Schaltfläche Fertig im letzten Schritt klicken.

  • Änderungen verwerfen: Klicken Sie nach Änderungen, um die Konfiguration zu schließen, ohne die vorgenommenen Änderungen zu speichern. Eine Nachricht fragt Sie, ob Sie die Änderungen wirklich verwerfen möchten.

Ansatz für interne Stage-Datei

Dieser Ansatz ermöglicht es, eine CSV-Datei in Snowflake einzufügen. Die Datei wird zwischengespeichert und dann gemäß den Spezifikationen des Anfragedaten-Schemas in die Tabelle kopiert.

  • Ansatz: Verwenden Sie das Dropdown-Menü, um Stage File auszuwählen.

  • Staging-Typ: Wählen Sie Internal, um die Daten aus einer internen Quelle abzurufen.

  • Bei Fehler: Wählen Sie eine dieser Optionen aus dem Dropdown-Menü On Error; zusätzliche Optionen erscheinen entsprechend:

    • 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 die in Skip File Number angegebene Zahl erreicht oder überschreitet.

    • Skip_File_\<num>%: Überspringt die Datei, wenn der Prozentsatz der Fehler in der Datei den in Skip File Number Percentage angegebenen Prozentsatz überschreitet.

  • Fehler bei Spaltenanzahl-Mismatch: Wenn ausgewählt, wird ein Fehler im Fehlerknoten des Antwortschemas gemeldet, wenn die Quell- und Zielspaltenanzahl nicht übereinstimmt. Wenn Sie diese Option nicht auswählen, schlägt die Operation nicht fehl und die bereitgestellten Daten werden eingefügt.

  • 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 fortzufahren und die Konfiguration vorübergehend zu speichern. Die Konfiguration wird nicht gespeichert, bis Sie die Schaltfläche Fertig im letzten Schritt klicken.

  • Änderungen verwerfen: Klicken Sie nach Änderungen, um die Konfiguration zu schließen, ohne die vorgenommenen Änderungen zu speichern. Eine Nachricht fragt Sie, ob Sie die Änderungen wirklich verwerfen möchten.

Google Cloud Storage Stage File Ansatz

Dieser Ansatz ermöglicht es, eine CSV-Datei in Google Cloud Storage einzufügen. Die Datei wird zwischengespeichert und dann gemäß den Spezifikationen des Anfragedaten-Schemas in die Tabelle kopiert.

  • Ansatz: Verwenden Sie das Dropdown-Menü, um Stage File auszuwählen.

  • Stage-Typ: Wählen Sie Google Cloud Storage, um die 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 bucketName im Datenschema InsertGoogleCloudRequest angegeben ist.

  • Dateipfad: Geben Sie den Dateipfad ein.

  • Bei Fehler: Wählen Sie eine dieser Optionen aus dem Dropdown-Menü Bei Fehler; zusätzliche Optionen erscheinen je nach Bedarf:

    • 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 die in Skip File Number angegebene Zahl erreicht oder überschreitet.

    • Skip_File_\<num>%: Überspringt die Datei, wenn der Prozentsatz der Fehler in der Datei den in Skip File Number Percentage angegebenen Prozentsatz überschreitet.

  • Fehler bei Spaltenanzahl-Mismatch: Wenn ausgewählt, wird ein Fehler im Fehlerknoten des Antwortschemas gemeldet, wenn die Quell- und Zielspaltenanzahl nicht übereinstimmt. Wenn Sie diese Option nicht auswählen, schlägt die Operation nicht fehl und die bereitgestellten Daten werden eingefügt.

  • 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 fortzufahren und die Konfiguration vorübergehend zu speichern. Die Konfiguration wird nicht gespeichert, bis Sie auf die Schaltfläche Fertig im letzten Schritt klicken.

  • Änderungen verwerfen: Klicken Sie, um die Konfiguration zu schließen, ohne die an einem Schritt vorgenommenen Änderungen zu speichern, nachdem Sie Änderungen vorgenommen haben. Eine Nachricht fragt Sie, ob Sie die Änderungen wirklich verwerfen möchten.

Microsoft Azure Stage File Ansatz

Dieser Ansatz ermöglicht es, eine CSV-Datei über eine Microsoft Azure-Quelle in Snowflake einzufügen. Die Datei wird zwischengespeichert und anschließend gemäß den Spezifikationen des Anforderungsdatenschemas in die Tabelle kopiert.

  • Ansatz: Verwenden Sie das Dropdown-Menü, um Datei zwischenspeichern auszuwählen.

  • Zwischenspeichertyp: Wählen Sie Microsoft Azure, um Daten aus Microsoft Azure-Speicherkonten abzurufen.

  • Authentifizierungstyp: Wählen Sie entweder Anmeldeinformationen oder Speicherintegration. Anmeldeinformationen erfordert ein Microsoft Azure Shared Access Signature (SAS)-Token und einen Speicherkontonamen. Speicherintegration benötigt nur einen Namen für die Speicherintegration. Diese Authentifizierungstypen werden im Folgenden behandelt.

Anmeldeinformationen-Authentifizierung

Der Authentifizierungstyp Anmeldeinformationen erfordert ein Microsoft Azure SAS-Token und einen Speicherkontonamen.

  • Authentifizierungstyp: Wählen Sie Anmeldeinformationen.

  • Azure SAS-Token: Geben Sie das Microsoft Azure SAS-Token ein. Informationen zur Erstellung von SAS-Token für Speicherkonten in Microsoft Azure finden Sie unter SAS-Token für Ihre Speicherkonten erstellen in der Microsoft Azure-Dokumentation.

  • Speicherkontoname: Geben Sie den Namen des Microsoft Azure-Speicherkontos ein.

Speicherintegrations-Authentifizierung

Der Authentifizierungstyp Speicherintegration erfordert die Erstellung einer Snowflake-Speicherintegration. Informationen zur Erstellung einer Snowflake-Speicherintegration finden Sie unter Speicherintegration erstellen in der Snowflake-Dokumentation.

  • Authentifizierungstyp: Wählen Sie Speicherintegration.

  • Name der Speicherintegration: Geben Sie den Namen der Snowflake-Speicherintegration ein.

Zusätzliche Optionen

Für die Authentifizierung mit Anmeldeinformationen und Speicherintegration gibt es diese zusätzlichen Optionen:

  • Master Key: Geben Sie den Master Key ein, der für die clientseitige Verschlüsselung (CSE) in Microsoft Azure verwendet wird. Dies wird ignoriert, wenn azureMasterKey im Datenschema InsertMicrosoftAzureCloudRequest bereitgestellt wird.

    Hinweis

    Für Informationen zur Erstellung von Schlüsseln in Microsoft Azure siehe Schnellstart: Einen Schlüssel im Azure Key Vault über das Azure-Portal festlegen und abrufen in der Microsoft Azure-Dokumentation.

    Für Informationen zur Speicherung von CSE in Microsoft Azure siehe Client-seitige Verschlüsselung für Blobs in der Microsoft Azure-Dokumentation.

  • Containername: Geben Sie einen gültigen Bucket-Namen für einen vorhandenen Speicherkontainer in Microsoft Azure ein. Dies wird ignoriert, wenn containerName im Datenschema InsertMicrosoftAzureCloudRequest angegeben ist.

  • Dateipfad: Geben Sie den Dateipfad ein.

  • Bei Fehler: Wählen Sie eine dieser Optionen aus dem Dropdown-Menü Bei Fehler; zusätzliche Optionen erscheinen je nach Bedarf:

    • 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 die in Überspringen Dateinummer angegebene Zahl erreicht oder überschreitet.

    • Skip_File_\<num>%: Überspringt die Datei, wenn der Prozentsatz der Fehler in der Datei den in Überspringen Dateinummer Prozentsatz angegebenen Prozentsatz überschreitet.

  • Fehler bei Spaltenanzahl-Mismatch: Wenn ausgewählt, wird ein Fehler im Fehlerknoten des Antwortschemas gemeldet, wenn die Quell- und Zielspaltenanzahl nicht übereinstimmt. Wenn Sie diese Option nicht auswählen, schlägt die Operation nicht fehl und die bereitgestellten Daten werden eingefügt.

  • 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 fortzufahren und die Konfiguration vorübergehend zu speichern. Die Konfiguration wird nicht gespeichert, bis Sie die Schaltfläche Fertig im letzten Schritt klicken.

  • Änderungen verwerfen: Klicken Sie nach Änderungen, um die Konfiguration zu schließen, ohne die vorgenommenen Änderungen zu speichern. Eine Nachricht fragt Sie, ob Sie die Änderungen wirklich verwerfen möchten.

Schritt 3: Überprüfen der Datenschemas

Die von dem Endpunkt generierten Anfrage- und Antwortschemas werden angezeigt. Die angezeigten Schemata hängen von dem im vorherigen Schritt angegebenen Ansatz ab.

Diese Unterabschnitte beschreiben die Anfrage- und Antwortstrukturen für jede Kombination aus Ansatz und Stagetyp:

Diese Aktionen sind mit jedem Ansatz verfügbar:

  • Datenschemas: Diese Datenschemas werden von benachbarten Transformationen geerbt und während der Transformationszuordnung erneut angezeigt.

    Hinweis

    Daten, die in einer Transformation bereitgestellt werden, haben Vorrang vor der Aktivitätskonfiguration.

    Tipp

    Wenn ein einzelnes Anführungszeichen (') in einem Anfragepayload vorhanden ist, wird zur Laufzeit ein Syntaxfehler zurückgegeben. Sie können die Einstellung Sonderzeichen escapen in der Verbindung aktivieren, um der Aktivität zu ermöglichen, einzelne Anführungszeichen (') zur Laufzeit automatisch zu escapen.

    Weitere Informationen finden Sie in den Snowflake SQL-Befehlen und im Snowflake API-Referenz.

  • Aktualisieren: Klicken Sie auf das Aktualisierungssymbol oder auf das Wort Aktualisieren, um die Schemata vom Snowflake-Endpunkt neu zu generieren. Diese Aktion regeneriert auch ein Schema an anderen Stellen im Projekt, an denen dasselbe Schema referenziert wird, z. B. in einer benachbarten 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: Nach Änderungen klicken Sie, um die Konfiguration zu schließen, ohne die vorgenommenen Änderungen an einem Schritt zu speichern. Eine Nachricht fragt Sie, ob Sie die Änderungen wirklich verwerfen möchten.

SQL Insert-Ansatz

Wenn der Ansatz SQL Insert ist, werden die Tabellen-Spalten angezeigt, die in einer Transformation zugeordnet werden können.

  • Anfrage

    Anfrage-Schema-Feld/Knoten Hinweise
    table Knoten, der den Tabellennamen anzeigt.
    column_A Name der ersten Tabellenspalte.
    column_B Name der zweiten Tabellenspalte.
    . . . Folgende Tabellenspalten.

  • Antwort

    Antwort-Schema-Feld/Knoten Hinweise
    status Boolean-Flag, das angibt, ob die Datensatz-Einfügung erfolgreich war.
    errorMessage Beschreibende Fehlermeldung, falls ein Fehler bei der Einfügung auftritt.
    recordsInserted Anzahl der eingefügten Datensätze, falls die Einfügung erfolgreich war.

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, sodass sie in einer Transformation zugeordnet werden können. Das verwendete Muster ist so konzipiert, dass nur eine Datei übereinstimmt. Wenn das Muster mit mehr als einer Datei übereinstimmt, tritt ein Fehler mit einer beschreibenden Nachricht auf.

  • Anfrage

    Request Schema Field/Node Notes
    accessKey Amazon S3 Zugangs-Schlüssel-ID.
    secretAccessKey Amazon S3 geheimer Zugangs-Schlüssel.
    storageintegrationName Name der Snowflake-Speicherintegration, die für die Authentifizierung der Snowflake-Speicherintegration verwendet wird.
    bucketName Gültiger Bucket-Name für einen vorhandenen Bucket auf dem Amazon S3-Server.
    filePath Speicherort der Stage-Datei im Amazon S3-Bucket.
    pattern Regulärer Ausdruck, der zum Finden der Datei auf der Stage verwendet wird; wenn compression GZIP ist, wird [.]gz an das Muster angehängt.
    onError Bei Fehler ausgewählte Option.
    encryption Knoten, der die Verschlüsselung darstellt.
    encryptionType Amazon S3 Verschlüsselungstyp (entweder serverseitige Verschlüsselung oder clientseitige Verschlüsselung).
    masterKey Amazon S3 Master-Schlüssel.
    kmsKeyId Amazon Key Management Service Master-ID.
    fileFormat Knoten, der das Dateiformat darstellt.
    nullIf Ein String, der in SQL NULL umgewandelt werden soll; standardmäßig ist es ein leerer String. Siehe die NULL_IF-Option der Snowflake COPY INTO <location> Dokumentation.
    enclosingChar Zeichen, das verwendet wird, um Datenfelder einzuschließen; siehe die FIELD_OPTIONALLY_ENCLOSED_BY-Option der Snowflake COPY INTO <location> Dokumentation.

    Hinweis

    Das enclosingChar kann entweder ein einfaches Anführungszeichen ' oder ein doppeltes Anführungszeichen " sein. Um das einfache Anführungszeichen zu verwenden, verwenden Sie entweder die oktale ' oder die hexadezimale 0x27 Darstellung oder verwenden Sie eine doppelte einfache Anführungszeichen-Escape ''. Wenn ein Feld dieses Zeichen enthält, entkommen Sie ihm mit demselben Zeichen.
    compression Der Komprimierungsalgorithmus, der für die Datendateien verwendet wird. GZIP oder NONE werden unterstützt. Siehe die Komprimierungsoption der Snowflake COPY INTO <location> Dokumentation.
    skipHeader Anzahl der Zeilen am Anfang der Quelldatei, die übersprungen werden sollen.
    errorOnColumnCountMismatch Boolean-Flag, um einen Fehler zu melden, wenn die Quell- und Zielanzahl des Antwortschemas nicht übereinstimmen.
    fieldDelimiter Das Trennzeichen, das verwendet wird, um Datenfelder zu trennen; siehe die FIELD_DELIMITER-Option der Snowflake COPY INTO <table> Dokumentation.
    recordDelimiter Das Trennzeichen, das verwendet wird, um Gruppen von Feldern zu trennen; siehe die RECORD_DELIMITER-Option der Snowflake COPY INTO <table> Dokumentation.

  • Antwort

    Antwort-Schema Feld/Knoten Hinweise
    status Zurückgegebener Status.
    file Name der gestellten CSV-Datei, die beim Einfügen von Daten in die Snowflake-Tabelle verarbeitet wurde.
    rows_parsed Anzahl der aus der CSV-Datei geparsten Zeilen.
    rows_loaded Anzahl der ohne Fehler aus der CSV-Datei in die Snowflake-Tabelle geladenen Zeilen.
    error Knoten, der die Fehlermeldungen darstellt.
    error_limit Anzahl der Fehler, die dazu führen, dass die Datei übersprungen wird, wie in Skip_File_\<num> festgelegt.
    errors_seen Anzahl der gesehenen 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 des ersten Fehlerorts.

Google Cloud Storage Stage File-Ansatz

Wenn der Ansatz Google Cloud Storage 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 ist so gestaltet, dass nur eine Datei übereinstimmt. Wenn das Muster mit mehr als einer Datei übereinstimmt, tritt ein Fehler mit einer beschreibenden Nachricht auf.

  • Anfrage

    Anfrage-Schema 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 Ausdruck, der zum Finden der Datei auf der Stage verwendet wird; wenn compressData wahr ist, wird [.]gz an das Muster angehängt.
    onError Bei Fehler ausgewählte Option.
    fileFormat Knoten, der das Dateiformat darstellt.
    nullIf Ein String, der in SQL NULL umgewandelt werden soll; standardmäßig ist es ein leerer String. Siehe die NULL_IF-Option der Snowflake COPY INTO <location> Dokumentation.
    enclosingChar Zeichen, das verwendet wird, um Datenfelder einzuschließen; siehe die FIELD_OPTIONALLY_ENCLOSED_BY-Option der Snowflake COPY INTO <location> Dokumentation.

    Hinweis

    Das enclosingChar kann entweder ein einfaches Anführungszeichen ' oder ein doppeltes Anführungszeichen " sein. Um das einfache Anführungszeichen zu verwenden, nutzen Sie entweder die oktale ' oder die hexadezimale 0x27 Darstellung oder verwenden Sie eine doppelte einfache Anführungszeichen-Escape ''. Wenn ein Feld dieses Zeichen enthält, escapen Sie es mit demselben Zeichen.
    compression Der Komprimierungsalgorithmus, der für die Datendateien verwendet wird. GZIP oder NONE werden unterstützt. Siehe die Komprimierungsoption der Snowflake COPY INTO <location> Dokumentation.
    skipHeader Anzahl der Zeilen am Anfang der Quelldatei, die übersprungen werden sollen.
    errorOnColumnCountMismatch Boolean-Flag, um einen Fehler zu melden, wenn die Quell- und Zielanzahl des Antwortschemas nicht übereinstimmen.
    fieldDelimiter Das Trennzeichen, das verwendet wird, um Datenfelder zu trennen; siehe die FIELD_DELIMITER-Option der Snowflake COPY INTO <table> Dokumentation.
    recordDelimiter Das Trennzeichen, das verwendet wird, um Gruppen von Feldern zu trennen; siehe die RECORD_DELIMITER-Option der Snowflake COPY INTO <table> Dokumentation.

  • Antwort

    Antwort-Schema Feld/Knoten Hinweise
    status Zurückgegebener Status.
    file Name der gestellten CSV-Datei, die beim Einfügen von Daten in die Snowflake-Tabelle verarbeitet wurde.
    rows_parsed Anzahl der aus der CSV-Datei geparsten Zeilen.
    rows_loaded Anzahl der ohne Fehler aus der CSV-Datei in die Snowflake-Tabelle geladenen Zeilen.
    error Knoten, der die Fehlermeldungen darstellt.
    error_limit Anzahl der Fehler, die dazu führen, dass die Datei übersprungen wird, wie in Skip_File_\<num> festgelegt.
    errors_seen Anzahl der gesehenen 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 des ersten Fehlerorts.

Interner Staging-Dateiansatz

Wenn der Ansatz Interner Staging-Datei 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 ist so konzipiert, dass nur eine Datei übereinstimmt. Wenn das Muster mit mehr als einer Datei übereinstimmt, tritt ein Fehler mit einer beschreibenden Nachricht auf.

  • Anfrage

    Anfrage-Schema Feld/Knoten Hinweise
    stageName Interner Snowflake-Stufe, Tabellenname oder Pfad.
    destinationPrefix Pfad oder Präfix, unter dem die Daten auf der Snowflake-Stufe hochgeladen werden.
    fileContent Dateninhalte der Datei im CSV-Format, die für den Upload in die Snowflake-Tabelle vorbereitet werden sollen.
    destinationFileName Ziel-Dateiname, der auf der Snowflake-Stufe verwendet werden soll.
    compressData Boolean-Flag, ob die Daten vor dem Hochladen in die interne Snowflake-Stufe komprimiert werden sollen.
    pattern Regulärer Ausdruck, der zum Finden der Datei auf der Stufe verwendet wird; wenn compressData wahr ist, wird [.]gz an das Muster angehängt.
    onError Bei Fehler ausgewählte Option.
    fileFormat Knoten, der das Dateiformat darstellt.
    nullIf Ein String, der in SQL NULL umgewandelt werden soll; standardmäßig ist es ein leerer String. Siehe die NULL_IF-Option der Snowflake COPY INTO <location> Dokumentation.
    enclosingChar Zeichen, das verwendet wird, um Datenfelder einzuschließen; siehe die FIELD_OPTIONALLY_ENCLOSED_BY-Option der Snowflake COPY INTO <location> Dokumentation.

    Hinweis

    Das enclosingChar kann entweder ein einfaches Anführungszeichen ' oder ein doppeltes Anführungszeichen " sein. Um das einfache Anführungszeichen zu verwenden, nutzen Sie entweder die oktale ' oder die hexadezimale 0x27 Darstellung oder verwenden Sie eine doppelte einfache Anführungszeichen-Escape ''. Wenn ein Feld dieses Zeichen enthält, escapen Sie es mit demselben Zeichen.
    errorOnColumnCountMismatch Boolean-Flag, um einen Fehler zu melden, wenn die Quell- und Zielanzahl des Antwortschemas nicht übereinstimmen.
    fieldDelimiter Das Trennzeichen, das verwendet wird, um Datenfelder zu trennen; siehe die FIELD_DELIMITER-Option der Snowflake COPY INTO <table> Dokumentation.
    recordDelimiter Das Trennzeichen, das verwendet wird, um Gruppen von Feldern zu trennen; siehe die RECORD_DELIMITER-Option der Snowflake COPY INTO <table> Dokumentation.

  • Antwort

    Antwort-Schema Feld/Knoten Hinweise
    file Name der gestellten CSV-Datei, die verarbeitet wird, wenn Daten in die Snowflake-Tabelle eingefügt werden.
    status Zurückgegebener Status.
    rowsParsed Anzahl der aus der CSV-Datei geparsten Zeilen.
    rowsLoaded Anzahl der ohne Fehler aus der CSV-Datei in die Snowflake-Tabelle geladenen Zeilen.
    error Knoten, der die Fehlermeldungen darstellt.
    error Die Fehlermeldung.
    code Der zurückgegebene Fehlercode.
    sqlState Der zurückgegebene numerische SQL-Zustandsfehlercode des Datenbankaufrufs.
    file Knoten, der die Fehlermeldungen darstellt.
    columnName Name und Reihenfolge der Spalte, die den Fehler enthielt.
    rowNumber Die Nummer der Zeile in der Quelldatei, in der der Fehler aufgetreten ist.
    rowStartLine Die Nummer der ersten Zeile der Zeile, in der der Fehler aufgetreten ist.

Microsoft Azure Stage File-Ansatz

Wenn der Ansatz Microsoft Azure 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 ist so konzipiert, dass nur eine Datei übereinstimmt. Wenn das Muster mit mehr als einer Datei übereinstimmt, tritt ein Fehler mit einer beschreibenden Nachricht auf.

  • Anfrage

    Anfrage-Schema Feld/Knoten Hinweise
    azureSasToken Microsoft Azure Shared Access Signature (SAS) Token.
    azureStorageAccountName Microsoft Azure Storage-Konto-Name.
    azureStorageintegrationName Name der Snowflake-Speicherintegration, die für die Authentifizierung der Snowflake-Speicherintegration verwendet werden soll.
    containerName Gültiger Containername für einen vorhandenen Speichercontainer in Microsoft Azure.
    filePath Speicherort der Stage-Datei im Microsoft Azure-Speichercontainer.
    pattern Regulärer Ausdruck, der zum Finden der Datei auf der Stage verwendet wird; wenn compression GZIP ist, wird [.]gz an das Muster angehängt.
    onError Bei Fehler ausgewählte Option.
    encryption Knoten, der die Verschlüsselung darstellt.
    encryptionType Microsoft Azure-Verschlüsselungstyp (nur clientseitige Verschlüsselung).
    azureMasterKey Microsoft Azure Master Key.
    fileFormat Knoten, der das Dateiformat darstellt.
    nullIf Ein String, der in SQL NULL umgewandelt werden soll; standardmäßig ist es ein leerer String. Siehe die NULL_IF-Option der Snowflake COPY INTO <location> Dokumentation.
    enclosingChar Zeichen, das verwendet wird, um Datenfelder einzuschließen; siehe die FIELD_OPTIONALLY_ENCLOSED_BY-Option der Snowflake COPY INTO <location> Dokumentation.

    Hinweis

    Das enclosingChar kann entweder ein einfaches Anführungszeichen ' oder ein doppeltes Anführungszeichen " sein. Um das einfache Anführungszeichen zu verwenden, verwenden Sie entweder die oktale ' oder die hexadezimale 0x27 Darstellung oder verwenden Sie eine doppelte einfache Anführungszeichen-Escape ''. Wenn ein Feld dieses Zeichen enthält, escapen Sie es mit demselben Zeichen.
    compression Der Komprimierungsalgorithmus, der für die Datendateien verwendet wird. GZIP oder NONE werden unterstützt. Siehe die Komprimierungsoption der Snowflake COPY INTO <location> Dokumentation.
    skipHeader Anzahl der Zeilen am Anfang der Quelldatei, die übersprungen werden sollen.
    errorOnColumnCountMismatch Boolean-Flag, um einen Fehler zu melden, wenn die Quell- und Zielanzahl des Antwortschemas nicht übereinstimmen.
    fieldDelimiter Das Trennzeichen, das verwendet wird, um Datenfelder zu trennen; siehe die FIELD_DELIMITER-Option der Snowflake COPY INTO <table> Dokumentation.
    recordDelimiter Das Trennzeichen, das verwendet wird, um Gruppen von Feldern zu trennen; siehe die RECORD_DELIMITER-Option der Snowflake COPY INTO <table> Dokumentation.

  • Antwort

    Antwort-Schema-Feld/Knoten Hinweise
    status Zurückgegebener Status.
    file Name der gestellten CSV-Datei, die beim Einfügen von Daten in die Snowflake-Tabelle verarbeitet wurde.
    rows_parsed Anzahl der aus der CSV-Datei geparsten Zeilen.
    rows_loaded Anzahl der ohne Fehler aus der CSV-Datei in die Snowflake-Tabelle geladenen Zeilen.
    error Knoten, der die Fehlermeldungen darstellt.
    error_limit Anzahl der Fehler, die dazu führen, dass die Datei übersprungen wird, wie in Skip_File_\<num> festgelegt.
    errors_seen Anzahl der gesehenen 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 des ersten Fehlerorts.

Nächste Schritte

Nachdem Sie eine Snowflake Insert-Aktivität konfiguriert haben, vervollständigen Sie die Konfiguration der Operation, indem Sie andere Aktivitäten oder Werkzeuge als Operation Schritte hinzufügen und konfigurieren. Sie können auch die Betriebseinstellungen konfigurieren, die die Möglichkeit umfassen, Operationen zusammenzuführen, die sich in denselben oder unterschiedlichen Workflows befinden.

Menüaktionen für eine Aktivität sind im Projektbereich und auf der Entwurfsgrafik zugänglich. Für Details siehe Aktionsmenü der Aktivität in Connector-Grundlagen.

Snowflake Insert-Aktivitäten können als Ziel mit diesen Betriebsmustern verwendet werden:

Um die Aktivität mit Skriptfunktionen zu verwenden, schreiben Sie die Daten an einen temporären Ort und verwenden Sie dann diesen temporären Ort in der Skriptfunktion.

Wenn Sie bereit sind, bereitstellen und ausführen Sie den Vorgang und validieren Sie das Verhalten, indem Sie die Betriebsprotokolle überprüfen.