ListTableNames 2025.5.31.15¶
Bundle¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
Beschreibung¶
Ruft alle Quelltabellennamen ab und gleicht sie mit einer der möglichen Konfigurationen ab: – Regex-Ausdruck, z. B. „(?i)customer.(orders |payments)“ – gleicht Namen ohne Berücksichtigung der Groß-/Kleinschreibung ab. Es würde sowohl mit „CUSTOMER.ORDERS“ als auch mit „customer.orders“ als Quelltabellennamen übereinstimmen. Der MicrosoftSQL-Server akzeptiert FQN mit dem Datenbanknamen, z. B. (?i)prod.customer.(orders| payments) – durch Kommas getrennte Liste der Quelltabellennamen, z. B. „customer.orders, customer.payments”. Die Namen der Quelltabellen werden unter Berücksichtigung der Groß- und Kleinschreibung abgeglichen, d. h. die Quelltabelle „customer.orders“ wird an die Beziehung MATCH weitergeleitet, aber „customer.ORDERS“ wird nicht abgeglichen. Der Microsoft SQL-Server akzeptiert FQN mit dem Namen der Datenbank, z. B. „prod1.customer.orders, prod1.customer.payments“. Die Konfiguration wird als FlowFile-Attribut übergeben. Der Name der Quelltabelle wird als <schema_name>.<table_name> dargestellt, sodass beide Eingaben dies berücksichtigen sollten. Übereinstimmende Quelltabellennamen werden an die Beziehung MATCHED weitergeleitet. Der Prozessor generiert ein einziges FlowFile mit den passenden Tabellen. Hinweis: Postgresql erlaubt es, die Namen von Datenbankobjekten unter Berücksichtigung der Groß- und Kleinschreibung zu definieren. Wenn der Benutzer eine Tabelle mit der folgenden Abfrage erstellt „CREATE TABLE ORDERS(id int not null)“, dann speichert Postgresql diese Tabelle in Kleinbuchstaben, z. B. orders. Um die Groß- und Kleinschreibung zu berücksichtigen, muss der Benutzer den Tabellennamen in doppelte Anführungszeichen setzen, d. h. „CREATE TABLE „ORDERS“(id int notnull)“. Dies ist ein wichtiger Aspekt bei der Konfiguration der Tabelle, die wir replizieren möchten.
Eingabeanforderung¶
REQUIRED
Unterstützt sensible dynamische Eigenschaften¶
false
Eigenschaften¶
Eigenschaft |
Beschreibung |
---|---|
Connection Pool |
Der Controller Service, der verwendet wird, um eine Verbindung zur Datenbank herzustellen. |
Included Comma Separated Source Table Names |
Die durch Kommas getrennte Liste der zu replizierenden Tabellen. Eine einzelne Tabelle sollte wie folgt formatiert werden: <schema_name>.<table_name> z. B. customer.orders, customer.payments. Dies wird mit dem regulären Ausdruck kombiniert, um jede passende Tabelle einzuschließen. |
Included Source Table Pattern |
Regulärer Ausdruck für die Angabe von Tabellennamen, die repliziert werden sollen (z. B. customer.(orders|payments). Dies wird mit der durch Kommas getrennten Liste kombiniert, um jede passende Tabelle einzuschließen. |
Beziehungen¶
Name |
Beschreibung |
---|---|
failure |
Wenn ein FlowFile-Attribut nicht gelesen werden kann oder falsch ist, wird es an diese Beziehung weitergeleitet. |
matched |
FlowFile erfolgreich erstellt, mit einer Liste der in der Quelldatenbank gefundenen übereinstimmenden Tabellen. |
Schreibt Attribute¶
Name |
Beschreibung |
---|---|
source.database.version.major |
Die Hauptversion der Quelldatenbank. |