FetchSourceTableSchema 2025.5.31.15¶

Bundle¶

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

Description¶

Récupère le schéma de la table (c’est-à-dire les noms de colonnes, les types de données, etc.) pour une table donnée dans une base de données, en convertissant les types de données en types compatibles avec Snowflake. Le schéma est écrit dans le contenu du FlowFile en tant qu’objet JSON, sous une forme telle que :{ « columns »: [ { « name »: « <columnName> », « type »: « <snowflakeType> », « nullable »: <true|false>, « scale »: <scale>, « precision »: <precision> }, …. ], « primaryKeys » : [« <primaryKey1> », « <primaryKey2> », …]}

Balises¶

Exigences en matière d’entrées¶

REQUIRED

Prend en charge les propriétés dynamiques sensibles¶

false

Propriétés¶

Propriété	Description
Service de filtre de colonne	Spécifie le service de filtrage des colonnes à utiliser pour filtrer les colonnes indésirables
Connection Pool	Le pooling de connexions à utiliser pour récupérer le schéma de la table source
Nom de schéma	Le nom du schéma dans lequel la table source est stockée
Nom de la table	Le nom de la table source

Relations¶

Nom	Description
failure	Les FlowFiles sont routés vers cette relation dans l’événement où le schéma de la table source ne peut pas être récupéré
success	Les FlowFiles sont routés vers cette relation lorsque le schéma de la table source est récupéré avec succès
table non trouvée	Les FlowFiles sont routés vers cette relation lorsque la table source n’existe pas

Écrit les attributs¶

Nom	Description
mime.type	application/json
dbms.type	Le type de système de gestion de base de données (DBMS) dans lequel la table source est stockée. Par exemple `POSTGRESQL`
primary.key.count	Le nombre de clés primaires dans la table source
column.count	Le nombre de colonnes dans la table source