UpdateSnowflakeDatabase 2025.5.31.15¶

Bundle¶

com.snowflake.openflow.runtime | runtime-snowflake-processors-nar

Beschreibung¶

Aktualisiert die Definition einer Snowflake-Tabelle auf der Grundlage des im eingehenden FlowFile angegebenen Schemas. Das Schema wird in JSON in folgendem Format erwartet, unabhängig davon, ob es über FlowFile-Inhalt bereitgestellt oder als Eigenschaft angegeben wird:{ „columns“: [ { „name“: „<column name>“, „type“: „<column type>“, „nullable“: <true/false>, „precision“: <precision, only for numeric type>, „scale“: <scale, only for numeric type> }, … ], „primaryKeys“: [„<name of first primary key column>“, „<name of second primary key column>“, …]}

Tags¶

Eingabeanforderung¶

REQUIRED

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

Eigenschaft	Beschreibung
Strategie zum Hinzufügen von Spalten	Die Strategie, die verwendet wird, wenn das eingehende Schema eine Spalte enthält, die in der vorhandenen Tabelle nicht vorhanden ist
Strategie zum Hinzufügen von „NOT NULL“-Bedingungen	Die Strategie, die verwendet wird, wenn das eingehende Schema eine Nicht-Null-Einschränkung enthält, die in der vorhandenen Tabelle nicht vorhanden ist
Column Name Transformation	Eine optionale Transformation, die auf die Namen der im Schema definierten Spalten angewendet werden kann. Diese Umwandlung wird auf die Spaltennamen angewendet, bevor sie mit den vorhandenen Spalten in der Tabelle verglichen werden. Diese Eigenschaft kann zusätzlich zu den Attributen über die Expression Language auf die folgenden Variablen verweisen: `column.name`, `column.type`, `column.nullable`, `column.precision`, `column.scale`, `column.primaryKey`.
Strategie zur Entfernung von Spalten	Die Strategie, die verwendet werden soll, wenn die vorhandene Tabelle eine Spalte hat, die im eingehenden Schema nicht vorhanden ist
Connection Pool	Der Verbindungspool, der für die Verbindung mit Snowflake verwendet wird
Stream erstellen	Ob ein Snowflake-Stream für die Tabelle erstellt werden soll oder nicht
Erstellungsparameter	Zusätzliche Parameter, die in die CREATE TABLE-Anweisung aufzunehmen sind. Zum Beispiel „CLUSTER BY (spalte_name)“
Gewünschtes Schema	Die gewünschte Schema-/Tabellendefinition
Strategie für das Löschen von Spalten	Die Strategie, die verwendet werden soll, wenn die vorhandene Tabelle eine Spalte hat, die im eingehenden Schema nicht vorhanden ist
Strategie zum Entfernen von „NOT NULL“-Bedingungen	Die Strategie, die verwendet werden soll, wenn die vorhandene Tabelle eine Nicht-Null-Einschränkung hat, die im neuen Schema nicht vorhanden ist
Include Not Null Constraints	Ob NOT NULL-Einschränkungen in CREATE TABLE- oder ALTER TABLE ADD COLUMN-Anweisungen enthalten sein sollen oder nicht
Primärschlüsseleinschränkungen einbeziehen	Ob Primärschlüsseleinschränkungen in die Erstellungsanweisung einbezogen werden sollen oder nicht
Max Batch Size	Die maximale Anzahl von FlowFiles, die in einer einzigen Ausführung für eine bestimmte Tabelle verarbeitet werden kann.
Primärschlüsselstrategie ändern	Die Strategie, die verwendet werden soll, wenn das eingehende Schema einen Primärschlüssel hat, der sich von dem vorhandenen Primärschlüssel unterscheidet. Wenn Sie den Primärschlüssel ändern möchten, müssen Sie den vorhandenen Schlüssel löschen und einen neuen hinzufügen, falls vorhanden.
Record Reader	Record Reader zum Abrufen des gewünschten Schemas
Entferntes Spaltennamensuffix	Das Suffix, das an eine entfernte Spalte angehängt werden soll. Um zum Beispiel die Spalte „foo“ in „foo__deleted“ umzubenennen, kann die Eigenschaft auf `__deleted gesetzt werden`
Schema Name	Der Name des zu aktualisierenden Schemas
Parameter für die Stream-Erstellung	Zusätzliche Parameter, die in die CREATE STREAM-Anweisung aufzunehmen sind. Zum Beispiel: „APPEND_ONLY=TRUE“
Stream-Name	Der Name des Streams
Table Metadata Cache Expiration Time	Die Zeit in Sekunden, nach der der Cache-Eintrag entfernt werden soll
Tabellenname	Der Name der Tabelle, die aktualisiert oder als Stream erstellt werden soll
Tabellenschemastrategie	Gibt an, wie Sie die gewünschte Schema-/Tabellendefinition erhalten
Parameter für die Erstellung von Tabellen-Streams	Parameter, die in die CREATE STREAM-Anweisung aufzunehmen sind. Zum Beispiel: „APPEND_ONLY=TRUE“. Der Stream wird zusammen mit der Tabelle als Quelle erstellt.
Tabellen-Stream-Name	Der Name des Streams, der zusammen mit der Tabelle erstellt wurde. Die Stream-Quelle ist die erstellte Tabelle.
Aktualisierungstyp	Die Art der Aktualisierung, die durchgeführt werden soll
Use Table Metadata Cache	Ob die Metadaten der Tabelle zwischengespeichert werden sollen, anstatt sie direkt aus Snowflake zu lesen. Gilt für [Create Table If Not Exists, Alter Table]

Beziehungen¶

Name	Beschreibung
failure	Das eingehende FlowFile wird an diese Beziehung weitergeleitet, wenn die Tabelle nicht aktualisiert werden kann.
success	Das eingehende FlowFile wird an diese Beziehung weitergeleitet, nachdem die Tabelle erfolgreich aktualisiert wurde.