Snowflake Query-Aktivität in Jitterbit Studio
Einführung
Eine Snowflake Query-Aktivität verwendet ihre Snowflake-Verbindung und ruft eine CSV-Datei mit Tabellen- oder Ansichtsdaten aus Snowflake ab. Sie ist als Quelle vorgesehen, um Daten in einem Vorgang bereitzustellen.
Hinweis
Je nach Ihren Snowflake-Berechtigungen gibt die Query-Aktivität nur Daten zurück, auf die Sie Zugriff haben. Wenn Sie beispielsweise nur Berechtigungen für Ansichtsdaten haben, gibt die Query-Aktivität nur Ansichtsdaten zurück und gibt keine Tabellendaten zurück.
Um über das Standard-Snowflake-Schema PUBLIC hinaus abzufragen, verwenden Sie die Query v2-Aktivität.
Erstellen einer Snowflake Query-Aktivität
Eine Instanz einer Snowflake Query-Aktivität wird aus einer Snowflake-Verbindung mit ihrem Query-Aktivitätstyp erstellt.
Um eine Instanz einer Aktivität 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 Query-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 Projektbereich-Registerkarte Komponenten).
Konfigurieren einer Snowflake Query-Aktivität
Führen Sie diese Schritte aus, um eine Snowflake Query-Aktivität zu konfigurieren:
-
Schritt 1: Geben Sie einen Namen ein und wählen Sie ein Objekt aus
Geben Sie einen Namen für die Aktivität ein und wählen Sie ein Objekt aus. -
Schritt 2: Erstellen Sie Ihre Abfrage
Legen Sie Bedingungen für eine Abfrage mit den Objektfeldern fest und wenden Sie Paging auf eine Abfrage an. -
Schritt 3: Überprüfen Sie die Datenschemas
Alle vom Endpunkt generierten Request- oder Response-Schemas werden angezeigt.
Schritt 1: Geben Sie einen Namen ein und wählen Sie ein Objekt aus
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 der Ansichten). Jedes Benutzeroberflächenelement dieses Schritts wird nachfolgend beschrieben.
-
Endpunkt-Menü: Wenn Sie mehrere Endpunkte desselben Connector-Typs konfiguriert haben, wird oben auf dem Bildschirm ein Menü mit dem aktuellen Endpunktnamen angezeigt. Klicken Sie auf das Menü, um zu einem anderen Endpunkt zu wechseln. Weitere Informationen finden Sie unter Ändern Sie den zugewiesenen Endpunkt 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 Query-Aktivität eindeutig sein und darf keine Schrägstriche
/oder Doppelpunkte:enthalten. -
Wählen Sie ein Objekt aus: Dieser Abschnitt zeigt Objekte an, die im Snowflake-Endpunkt verfügbar sind. Wenn Sie eine vorhandene Aktivitätskonfiguration erneut öffnen, 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 den Wert einer beliebigen Spalte in das Suchfeld ein, um die Objektliste zu filtern. Bei der Suche wird die Groß- und 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 unten 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: 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: Abfrage erstellen
Erstellen Sie in diesem Schritt eine Abfrageanweisung, indem Sie Bedingungen für Objektfelder festlegen und Paging entweder über den Abfrage-Generator oder durch manuelles Eingeben einer Abfrageanweisung anwenden. Jedes Benutzeroberflächenelement dieses Schritts wird nachfolgend beschrieben.
Hinweis
Sie können den Abfrage-Generator umgehen und eine Abfrageanweisung in das Feld Abfragezeichenfolge eingeben.
Tipp
Felder mit einem Variablensymbol unterstützen die Verwendung von globalen Variablen, Projektvariablen und Jitterbit-Variablen. Beginnen Sie, indem Sie eine öffnende eckige Klammer [ in das Feld eingeben oder auf das Variablensymbol klicken, um ein Menü mit vorhandenen Variablen anzuzeigen.
-
Suchen: Geben Sie einen beliebigen Teil eines Feldnamens in das Suchfeld ein, um die Feldliste für das ausgewählte Objekt zu filtern. Bei der Suche wird die Groß-/Kleinschreibung nicht beachtet. Die aufgelisteten Ergebnisse werden bei jedem Tastendruck in Echtzeit gefiltert.
-
Aktualisieren: Klicken Sie auf das Aktualisierungssymbol oder auf das Wort Aktualisieren, um Felder des Objekts vom Snowflake-Endpunkt neu zu laden.
-
Alle auswählen: Wenn Sie das Suchfeld zum Filtern verwenden, können Sie dieses Kontrollkästchen verwenden, um alle sichtbaren Felder auf einmal auszuwählen.
-
Felder auswählen: Aktivieren Sie die Kontrollkästchen der Felder, die Sie in die Abfrage einbeziehen möchten, damit diese automatisch zur Abfrageanweisung im Feld Abfragezeichenfolge hinzugefügt werden. Sie können auch alle Felder auf einmal mit dem Kontrollkästchen Alle auswählen.
-
Paging: Um eine Paging-Klausel (eine Begrenzung der Anzahl der Datensätze mit optionalem Datensatzoffset) hinzuzufügen, können Sie das Dropdown-Menü verwenden, um das Paging-Limit festzulegen und das Feld zum Eingeben eines Offsets verwenden. Wenn kein Offset angegeben ist, wird standardmäßig 0 verwendet. Eine einzelne Paging-Klausel wird unterstützt. Wenn keine Paging-Klausel enthalten ist, werden alle Datensätze zurückgegeben.
-
Anwenden: Klicken Sie, um die Klausel automatisch basierend auf den Dropdown-Auswahlen und dem eingegebenen Wert zu erstellen. Die automatisch erstellte Paging-Klausel wird im Textfeld Abfragezeichenfolge angezeigt.
-
Entfernen: Klicken Sie, um eine angewendete Paging-Klausel zu entfernen.
-
-
Bedingungen: Um bedingte Klauseln hinzuzufügen, verwenden Sie die folgenden Felder als Eingabe, um die Klauseln zu erstellen, die dann im Textfeld Abfragezeichenfolge angezeigt werden.
-
Feld: Verwenden Sie das Dropdown-Menü, um ein Feld aus dem ausgewählten Objekt auszuwählen.
-
Operator: Verwenden Sie das Dropdown-Menü, um einen Operator auszuwählen, der für den Felddatentyp geeignet ist:
Operator Bezeichnung Beschreibung = Gleich != Nicht gleich IN (value1, value2) In In Liste von Werten. LIKE 'string' Wie Wie string. LIKE 'string%' Beginnt mit Beginnt mit string. LIKE '%string' Endet mit Endet mit string. LIKE '%string%' Enthält Enthält string. < Kleiner als <= Kleiner oder gleich > Größer als >= Größer oder gleich
-
-
Wert: Geben Sie den gewünschten Wert ein, der mit den Dropdown-Auswahlmöglichkeiten verwendet werden soll.
-
Hinzufügen: Klicken Sie, um die Klausel automatisch basierend auf den Dropdown-Auswahlmöglichkeiten und dem eingegebenen Wert zu erstellen. Die bedingte Klausel wird zum Textfeld Abfragezeichenfolge hinzugefügt.
-
Alle entfernen: Klicken Sie, um alle eingegebenen bedingten Klauseln zu entfernen.
-
Abfragezeichenfolge: Wenn Sie Felder auswählen, Bedingungen festlegen und Paging konfigurieren, wird die Abfrageanweisung in diesem Textfeld automatisch mit den ausgewählten Feldern, Bedingungen und Paging-Limits gefüllt. Dieses Feld ist bearbeitbar, sodass Sie eine Abfrageanweisung manuell eingeben oder die automatisch gefüllte Anweisung bearbeiten können.
Hinweis
Die Werte aller globalen Variablen, die in der Abfragezeichenfolge verwendet werden, werden beim Verwenden der Schaltfläche Abfrage testen nicht gefüllt, auch wenn ein Standardwert angegeben ist. Globale Variablenwerte werden zur Laufzeit abgerufen, wenn die Abfrage ausgeführt wird. Um die Abfrage mit einem Standardvariablenwert zu testen, verwenden Sie stattdessen eine Projektvariable.
Wichtig
Um eine Abfrageanweisung zu verwenden, die Elemente enthält, die nicht über diese Schnittstelle ausgewählt wurden, müssen Sie auch das Kontrollkästchen Statisches Schema verwenden aktivieren.
-
Statisches Schema verwenden: Aktivieren Sie diese Option, um das Antwortschema auf ein statisches Schema festzulegen, das unabhängig von der Abfrageanweisung ist. Dies ermöglicht die Verwendung von benutzerdefinierten Abfrageanweisungen, die im Textfeld Abfragezeichenfolge eingegeben werden.
-
Abfrage testen: Klicken Sie, um die Abfrage zu validieren. Wenn die Abfrage gültig ist, werden maximal 50 Datensätze aus der Abfrage in einer Tabelle angezeigt. Wenn die Abfrage nicht gültig ist, werden relevante Fehlermeldungen angezeigt.
Hinweis
Während der Laufzeit wird das Limit von 50 Datensätzen nicht erzwungen, es sei denn, es ist im Feld Paging angegeben (siehe oben). Wenn Sie die Abfragezeichenfolge manuell bearbeiten, muss die Abfrage gültig sein und durch diese Schaltfläche validiert werden, um die Schaltfläche Weiter zu aktivieren.
-
Zurück: Klicken Sie, um die Konfiguration für diesen Schritt vorübergehend zu speichern und zum vorherigen Schritt zurückzukehren.
-
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 die in einem Schritt vorgenommenen Änderungen zu speichern. Eine Meldung fordert Sie auf zu bestätigen, dass Sie die Änderungen verwerfen möchten.
Schritt 3: Überprüfen Sie die Datenschemas
Alle aus dem Endpunkt generierten Request- oder Response-Schemas werden angezeigt. Jedes Benutzeroberflächenelement dieses Schritts wird nachfolgend beschrieben.
-
Datenschemas: 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.
Die Standard-Request- und Response-Datenschemas bestehen aus diesen Knoten und Feldern:
-
Request
Request-Schemafeld/-knoten Hinweise queryRequestKnoten der Abfrageanforderung. whereClauseKnoten der WHERE-Klauselanfrage. columnNameSpaltenname der WHERE-Klausel. conditionBedingung der WHERE-Klausel. valueWert der WHERE-Klausel. -
Response
Response-Schemafeld/-knoten Hinweise tableKnoten mit dem Tabellennamen NAME. EntityKnoten der Entität. column_AWert für die erste Spalte, COLOR. column_BWert für die zweite Spalte, FLOWER. . . .Werte für die nachfolgenden Tabellenspalten.
-
Wenn Statische Schemas verwenden ausgewählt ist, besteht das Datenschema der Antwort aus diesen Knoten und Feldern:
-
Antwort
Feld/Knoten des Antwortschemas Hinweise queryResponseKnoten der Abfrageantwort. rowKnoten der Antwortzeile. itemKnoten des Antwortelements. columnNameSpaltenname des Antwortelements. columnValueSpaltenwert des Antwortelements. Weitere Informationen finden Sie unter Snowflake SQL-Befehle und Snowflake API-Referenz.
-
Aktualisieren: Klicken Sie auf das Aktualisierungssymbol oder 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.
Nächste Schritte
Nach der Konfiguration einer Snowflake-Aktivität Abfrage schließen Sie die Konfiguration des Vorgangs ab, indem Sie andere Aktivitäten oder Tools als Vorgangsschritte hinzufügen und konfigurieren. Sie können auch die Vorgangseinstellungen 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 Designoberfläche zugänglich. Weitere Informationen finden Sie unter Menü „Aktivitätsaktionen" in Connector-Grundlagen.
Snowflake-Aktivitäten Abfrage können als Quelle mit diesen Operationsmustern verwendet werden:
- Transformationsmuster
- Muster für zwei Ziele mit Archivierung (nur als erste Quelle)
- Muster für zwei Ziele mit HTTP-Archivierung (nur als erste Quelle)
- Muster für zwei Transformationen (als erste oder zweite Quelle)
Um die Aktivität mit Skriptfunktionen zu verwenden, schreiben Sie die Daten an einen temporären Speicherort und verwenden Sie diesen temporären Speicherort dann in der Skriptfunktion.
Wenn Sie bereit sind, stellen Sie den Vorgang bereit und führen ihn aus, und überprüfen Sie das Verhalten, indem Sie die Vorgangsprotokolle prüfen.