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.
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 |
The list of comma separated list of tables to replicate. A single table should be formatted as <schema_name>.<table_name> e.g. customer.orders, customer.payments. This is combined with the regular expression to include any matching table. |
Modèle de table source inclus |
Regular Expression for specifying table names to replicate e.g. customer.(orders|payments). This is combined with the comma-separated list to include any matching table. |
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. |