Snowflake Select
Das Transferobjekt Snowflake Select fragt einen oder mehrere Datensätze aus einer Tabelle oder Datenbankansicht (View) der Snowflake AI Data Cloud ab. Das Transferobjekt dient damit als Datenquelle.
Dialogübersicht

Allgemeine Eigenschaften
| Eigenschaft | Beschreibung |
|---|---|
| Datenquelle | Hier stehen alle im Bereich Plug-ins erstellten Snowflake-Anbindungen zur Auswahl. Sollte die gewünschte Anbindung noch nicht vorhanden sein, können Sie diese im Plug-ins-Bereich als „Snowflake AI Data Cloud”-Plug-in bereitstellen. |
| Tabelle | Tabelle oder Datenbankansicht (View), aus der gelesen wird. |
| Verfügbare Spalten | In der Tabelle vorhandene, noch nicht verwendete Spalten. |
| Verwendete Spalten | Spalten, die als Elemente des Transferobjekts angezeigt werden und damit für die Abfrage zur Verfügung stehen. |
Verschieben Sie Spalten durch Doppelklick auf den Spaltennamen oder über die Schaltflächen <, >, << und >>. Mit den Schaltflächen Auf und Ab sortieren Sie die verwendeten Spalten.
Filter
Der Filter grenzt ein, welche Datensätze gelesen werden. Aufbau und Bedienung des Filter-Reiters sind zentral unter Filter und Filtergruppen beschrieben.
Abfrage

| Eigenschaft | Beschreibung |
|---|---|
| Sortierreihenfolge | Auf- oder absteigend. |
| Sortierung nach Spalte | Spalte, nach der das Abfrageergebnis sortiert wird. |
| Datensätze nicht verändern | Nur bei Abfragen aus Tabellen möglich. Es erfolgt keine Änderung der übertragenen Datensätze. |
| Datensätze nach durchgeführtem Transfer markieren | Nur bei Abfragen aus Tabellen möglich. In einer entsprechenden Spalte der Quelltabelle wird für jeden erfolgreich transferierten Datensatz 1 und für einen fehlerhaften Transfer 2 eingetragen. |
| Spalte zum Markieren | Nur bei Abfragen aus Tabellen möglich. Spalte, in der der Marker für den erfolgten oder fehlerhaften Datentransfer eingetragen wird. |
| Markierungswerte | Werte, die in die Markierungsspalte eingetragen werden. Die Markierungswerte müssen eindeutig sein. |
| Zähle fehlgeschlagene Transfers | Zählt die fehlgeschlagenen Transfers. |
| Datensätze nach erfolgreichem Transfer löschen | Nur bei Abfragen aus Tabellen möglich. Transferierte Datensätze können auch aus der Tabelle gelöscht werden. |
| Transfer abbrechen (bei leerem Abfrageergebnis) | Bricht den Datentransfer bei leerem Abfrageergebnis ab. |
| Lesefehler auslösen (bei leerem Abfrageergebnis) | Bricht den Datentransfer bei leerem Abfrageergebnis ab und löst die Fehleraufzeichnung aus (im Router-Status und in der Logdatei). |
| Leeren Datensatz zurückgeben | Gibt bei einem leeren Abfrageergebnis einen leeren Datensatz zurück. |
| Anzahl Datensätze begrenzen auf | Transferiert nur die hier angegebene Anzahl der Datensätze. Die Sortierung muss entsprechend eingestellt sein. |
Für Datensätze nach durchgeführtem Transfer markieren wird in der betreffenden Tabelle ein einfacher Primärschlüssel auf die numerische Spalte ID benötigt.
Wenn Sie Zähle fehlgeschlagene Transfers verwenden, wählen Sie bei Fehlerspalte die Spalte aus, in der die Anzahl der fehlgeschlagenen Transfers hochgezählt werden soll.
Wenn Sie Datensätze nach erfolgreichem Transfer löschen aktivieren, werden die Datensätze in der Quelltabelle unwiderruflich gelöscht.
Hinweise
Verwenden Sie Snowflake Select möglichst mit Filtern, damit nicht die gesamte Tabelle geladen wird. In Verbindung mit Transfermarkierungen filtern Sie zum Beispiel nach Transferflag <> 1.
Halten Sie zum Markieren transferierter Datensätze eine eigene Transferflag-Spalte vor (nicht übertragen, übertragen, Transferfehler). Die Spalte sollte den Standardwert 0 haben und nicht NULL annehmen dürfen. Sortieren Sie das Ergebnis aufsteigend nach dem Transferflag, damit zuerst die noch nicht transferierten Datensätze übertragen werden.
Beispiel
Der OPC Router liest die von der Snowflake AI Data Cloud erkannten Anomalien aus PROCESS_ANOMALIES, um an der Maschine darauf zu reagieren. Der Filter beschränkt die Abfrage auf als Anomalie erkannte Datensätze; über den Reiter „Abfrage" werden die gelesenen Datensätze markiert, damit jeder nur einmal verarbeitet wird. Das oben gezeigte Transferobjekt ist für dieses Beispiel konfiguriert.
| Einstellung | Wert |
|---|---|
| Tabelle | PROCESS_ANOMALIES |
| Verwendete Spalten | IS_ANOMALY, DISTANCE, PRODUCT_ID, CURRENT_AMOUNT, SCRAP_COUNT |
| Filter | IS_ANOMALY = TRUE |
| Abfrage | „Datensätze nach durchgeführtem Transfer markieren" über die Spalte TRANSFER_STATE |
Der OPC Router erzeugt daraus sinngemäß:
SELECT IS_ANOMALY, DISTANCE, PRODUCT_ID, CURRENT_AMOUNT, SCRAP_COUNT FROM PROCESS_ANOMALIES WHERE IS_ANOMALY = TRUE