FetchSourceTableSchema 2025.5.31.15¶

Bundle¶

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

Beschreibung¶

Ruft das Tabellenschema (d. h. Spaltennamen, Datentypen usw.) für eine bestimmte Tabelle in einer Datenbank ab und konvertiert die Datentypen in Snowflake-kompatible Typen. Das Schema wird als JSON-Objekt in den Inhalt des FlowFile geschrieben, in einer Form wie:{ „columns“: [ { „name“: „<columnName>“, „type“: „<snowflakeType>“, „nullable“: <true|false>, „scale“: <scale>, „precision“: <precision> }, … ], „primaryKeys“: [„<primaryKey1>“, „<primaryKey2>“, …]}

Tags¶

Eingabeanforderung¶

REQUIRED

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

Eigenschaft	Beschreibung
Column Filter Service	Gibt den „Column Filter Service“ an, der zum Herausfiltern unerwünschter Spalten verwendet werden soll
Connection Pool	Der Verbindungspool, der zum Abrufen des Quelltabellenschemas verwendet wird
Schema Name	Der Name des Schemas, in dem die Quelltabelle gespeichert ist
Tabellenname	Der Name der Quelltabelle

Beziehungen¶

Name	Beschreibung
failure	FlowFiles werden an diese Beziehung weitergeleitet, falls das Schema der Quelltabelle nicht abgerufen werden kann.
success	FlowFiles werden an diese Beziehung weitergeleitet, wenn das Schema der Quelltabelle erfolgreich abgerufen wurde.
table not found	FlowFiles werden an diese Beziehung weitergeleitet, wenn die Quelltabelle nicht existiert.

Schreibt Attribute¶

Name	Beschreibung
mime.type	application/json
dbms.type	Der Typ des Datenbankmanagementsystems (DBMS), in dem die Quelltabelle gespeichert ist. Beispiel: `POSTGRESQL`
primary.key.count	Die Anzahl der Primärschlüssel in der Quelltabelle
column.count	Die Anzahl der Spalten in der Quelltabelle