Technische Referenzen

Arbeiten mit Snowflake-Aktivitäten

Tipp:

Auf dieser Seite finden Sie einige Tipps, die bei der Arbeit mit Snowflake-Aktivitäten nützlich sein können.

• Wenn Sie erwarten, dass Ihre Abfrage zu einer großen Anzahl von Zeilen führt, verwenden Sie immer LIMIT und OFFSET um Ihre Ergebnisse zu paginieren. Abfragebeispiele für diesen Anwendungsfall finden Sie in der Snowflake-Dokumentation.
• Die Erstellung des Ausgabeschemas funktioniert nur für Abfrageanweisungen, die keine Workflow-Variablen enthalten. Sobald das Ausgabeschema generiert wurde, können Sie die Abfrage durch Variablen ersetzen. Wir empfehlen die Verwendung einer Abfrage, die Sie direkt in Snowflake erfolgreich ausführen können.
• Verwenden Sie Beliebige Abfrage asynchron ausführen für alle Abfragen, deren Ausführung länger als 30 Sekunden dauert.
• Sie können Nicht-Auswahlbefehle (z. B. Einfügen, Aktualisieren, gespeicherte Prozeduren usw.) nur mit der Aktivität Beliebige Abfrage asynchron ausführen ausführen.
• Verwenden Sie Get Asynchronus Query Ausführungsstatus mit der Abfrage-ID, die aus der Ausgabe von Execute Beliebige Abfrage asynchron erhalten wurde.
• Sie können den Trigger Status geänderter asynchroner Abfrage verwenden, um einen Prozess zu initiieren, wenn eine Abfrage erfolgreich ausgeführt wurde oder ein Fehler aufgetreten ist.
• Um die Ergebnisse einer asynchronen Abfrage abzurufen, verwenden Sie Get Asynchronus Query Execution Status. Verwenden Sie die Abfrage-ID aus der Ausgabe von Beliebige Abfrage asynchron ausführen, um das Ausgabeschema zu generieren. Sobald das Schema generiert wurde, können Sie eine variable Abfrage-ID verwenden. Das Ändern der Eingabe in eine Variable wirkt sich nicht auf die Ausgabeeigenschaften aus, die gleich bleiben. Das bedeutet, dass die generierte Ausgabe nur geändert werden kann, wenn Sie sie manuell neu generieren. Wir empfehlen, bei Bedarf verschiedene Workflow-Prozesse einzurichten. Wenn Sie Studio Desktop verwenden, können Sie die Aktivität Native Search aus Snowflake-Paketversion 5.0.1 verwenden.
• Damit die Trigger Datensatz erstellt und Datensatz aktualisiert erfolgreich ausgeführt werden, müssen Sie die folgende Abfrage für die Tabellen ausführen, die Sie auf Ereignisse überwachen: ALTER TABLE [TABLE_NAME] SET CHANGE_TRACKING = TRUE;. Stellen Sie außerdem sicher, dass Sie über die erforderlichen Berechtigungen verfügen, die in Snowflake konfiguriert sind.

Identifizieren der Primärschlüsselausgabe beim Einfügen einer Zeile in Snowflake

Wenn Sie eine Tabelle mit einer automatisch inkrementierenden ID-Spalte haben, wird häufig eine Zeile in diese Tabelle eingefügt und die ID der erstellten Zeile ausgegeben.

Die einfachste Problemumgehung für dieses Problem besteht darin, eine Fremdschlüsselbeziehung in der Tabelle beizubehalten, in die Sie Ihre Daten auslagern möchten. Im folgenden Beispiel stellen Sie möglicherweise fest, dass bei der Aktivität Snowflake: Insert Record zwar eine Ausgabe SNOWFLAKE_ID vorhanden ist, es aber keine echte Ausgabe während der Ausführung gibt, wenn die Zeile hinzugefügt wird. Dies ist eine Einschränkung von Snowflake. Daher behalten wir eine Fremdschlüsselspalte (SFDC_OPPORTUNITY_ID) für diese Tabelle bei.

Sobald die Zeile hinzugefügt wurde, können wir die Aktivität Native-Suche von Snowflake verwenden, um den Primärschlüssel (SNOWFLAKE_ID) im Austausch für den Fremdschlüssel (SFDC_OPPORTUNITY_ID) abzufragen und eine nachfolgende Systemaktivität Get Row Item zu verwenden.

Das zurückgegebene SNOWFLAKE_ID (Primärschlüssel) kann auch in der Upstream-Anwendung in einem benutzerdefinierten Feld gespeichert werden (in diesem Fall Salesforce), sodass die ID nicht jedes Mal, wenn eine Aktualisierung in Folge durchgeführt werden muss, abgefragt werden muss mit Fremdschlüssel.