UpdateSnowflakeTable 2025.10.2.19¶

Bundle¶

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

Beschreibung¶

Aktualisiert die Definition einer Snowflake-Tabelle auf der Grundlage des Schemas, das in der eingehenden FlowFile angegeben ist. Es wird erwartet, dass sich das Schema in JSON mit dem folgenden Format befindet, unabhängig davon, ob es über FlowFile-Inhalt oder als Eigenschaft bereitgestellt wird: { „columns“: [ { „name“: „<column name>“, „type“: „<column type>“, „nullable“: <true/false>, „precision“: <only for numeric type>, „scale“: <only for numeric type> }, … ], „primaryKeys“: [„<name of first primary key column>“, „<name of second primary key column>“, …] } Dieser Prozessor unterstützt nur Tabellenvorgänge: Erstellen, Ändern und Löschen von Tabellen.

Tags¶

ändern, spalten, erstellen, ddl, entfernen, vorschau, snowflake, tabelle, aktualisieren

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
Strategie zum Ändern des Spaltentyps	Die Strategie, die verwendet werden soll, wenn die bestehende Tabelle eine Spalte mit einem anderen Typ hat als das eingehende Schema.
Column Name Transformation	Eine optionale Transformation, die auf die Namen der im Schema definierten Spalten angewendet werden kann. Diese Transformation wird auf die Spaltennamen angewendet, bevor diese mit den vorhandenen Spalten in der Tabelle verglichen werden. Diese Eigenschaft kann zusätzlich zu Attributen auch über Ausdruckssprache auf die folgenden Variablen verweisen: `column.name`, `column.type`, `column.nullable`, `column.precision`, `column.scale`, column.primaryKey`Das Ergebnis der Anwendung von Transformationen, die auf dieser Eigenschaft basieren, wird entsprechend der Einstellung der Eigenschaft zur `Behandlung von Objektnamen behandelt.
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
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
Standardwerte einschließen	Ob DEFAULT-Werte in CREATE TABLE- oder ALTER TABLE ADD COLUMN-Anweisungen eingefügt werden sollen oder nicht
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.
Auflösung des Objektbezeichners	Steuert, wie die Bezeichner der Quellobjekte (Schemas, Tabellen, Spalten) in Snowflake gespeichert und abgefragt werden. Diese Einstellung bestimmt, ob Sie in Ihren SQL-Abfragen doppelte Anführungszeichen verwenden müssen.
Record Reader	Record Reader zum Abrufen des gewünschten Schemas
Entferntes Spaltennamensuffix	Das Suffix, das an eine entfernte Spalte angehängt werden soll. Um beispielsweise die Spalte „foo“ in „foo__deleted“ umzubenennen, kann die Eigenschaft auf `__deleted` gesetzt werden. Dieser Eigenschaftswert verhält sich je nach Wert der Eigenschaft `Behandlung von Objektnamen` unterschiedlich, d. h. wenn `Behandlung von Objektnamen` auf `Zwischen Groß- und Kleinschreibung wird unterschieden` gesetzt ist, dann wird das Suffix unverändert angehängt. Wenn `Behandlung von Objektnamen` auf `SQL-Bezeichner`gesetzt ist, dann dürfen Suffix und Wert nur aus Buchstaben, Zahlen, Dollarzeichen ($) und Unterstrichen (_) bestehen. Außerdem wird er ggf. unter Berücksichtigung von Groß-/Kleinschreibung angehängt, je nachdem, ob der Spaltenname, an den angehängt wird, Groß-/Kleinschreibung nicht berücksichtigt (nicht in doppelte Anführungszeichen gesetzt) oder Groß-/Kleinschreibung unterscheidet (in doppelte Anführungszeichen gesetzt).
Schema Name	Name des Schemas, das die Tabelle enthält.
Table Metadata Cache Expiration Time	Die Zeit in Sekunden, nach der der Cache-Eintrag entfernt werden soll
Tabellenname	Der Name der zu aktualisierenden Tabelle
Tabellenschemastrategie	Gibt an, wie Sie die gewünschte Schema-/Tabellendefinition erhalten
Aktualisierungstyp	Die Art der Tabellenaktualisierung, die ausgefü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.

Schreibt Attribute¶

Name	Beschreibung
schema.hash	Ein SHA-256 Hash des endgültigen Tabellenschemas, nachdem alle Aktualisierungen abgeschlossen wurden. Kann zur Änderungserkennung und zum Caching verwendet werden.