ListTableNames 2025.10.2.19

Bundle

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

Description

Récupère tous les noms de table source et les associe à l’une des configurations possibles : - expression regexp, par exemple « (?i)customer.(orders|payments) » - elle correspond aux noms de manière insensible à la casse. Elle correspondrait à la fois aux noms de table source « CUSTOMER.ORDERS » et « customer.orders » . - liste de noms de table source séparés par des virgules, par exemple « customer.orders, customer.payments ». Elle fait correspondre les noms de table source en tenant compte de la casse, c’est-à-dire que la table source « customer.orders » sera transmise à la relation MATCH mais « customer. ORDERS » ne correspondra pas. Les tables sources correspondantes qui ne peuvent pas être répliquées seront routées vers la relation FAILURE, chaque table dans un FlowFile distinct, avec un motif dans attributs. La configuration est transmise en tant qu’attribut FlowFile. Le nom de la table source est représenté par <schema_name>.<table_name>, les deux entrées doivent donc en tenir compte. Les noms de tables sources correspondants sont transférés vers la relation MATCHED. Le processeur génère un FlowFile unique avec les tables correspondantes. Non-responsabilité - Postgresql permet de définir les noms des objets de base de données de manière sensible à la casse ou non. Lorsque l’utilisateur crée une table à l’aide de la requête suivante “CREATE TABLE ORDERS(id int non null)” alors, Postgresql la stocke en interne en utilisant des lettres minuscules, c’est-à-dire des commandes. Pour appliquer la sensibilité à la casse, l’utilisateur doit mettre le nom de la table entre guillemets doubles, c’est-à-dire “CREATE TABLE « ORDERS »(id int non null)”. Il s’agit de l’aspect important de la configuration d’une table que nous souhaitons répliquer.

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

Connection Pool

Le composant Controller Service qui est utilisé pour obtenir une connexion à la base de données.

Noms de tables sources inclus, séparés par des virgules

La liste de tables à répliquer, séparées par des virgules. Une seule table doit être formatée comme suit <schema_name>.<table_name>, par exemple customer.orders, customer.payments. Celle-ci est combinée à l’expression régulière pour inclure toute table correspondante.

Modèle de table source inclus

Expression régulière pour spécifier les noms de tables à répliquer, par exemple customer.(orders|payments). Celle-ci est combinée à la liste séparée par des virgules pour inclure toute table correspondante.

Relations

Nom

Description

failure

Si un attribut FlowFile ne peut pas être lu ou est incorrect, il sera routé vers cette relation.

matched

Création réussie de FlowFile, avec une liste de tables correspondantes trouvées dans la base de données source.

Écrit les attributs

Nom

Description

source.schema.name

Nom du schéma de la table d’où provient un événement

source.table.name

Nom de la table d’où provient un événement

source.entry

L’entrée d’origine qui a été tentée d’être analysée lors du traitement des noms de table

Motif

Motif pour lequel la table ne peut pas être répliquée

base.de.données.version.majeure

La version majeure de la base de données source.

mime.type

Le type MIME du contenu de FlowFile.