ListTableNames 2025.10.2.19¶
Bundle¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
Beschreibung¶
Ruft alle Namen der Quelltabellen ab und gleicht sie mit einer der möglichen Konfigurationen ab: - Regexp-Ausdruck z. B. „(?i)customer.(orders|payments)“ - Vergleicht Namen ohne Berücksichtigung der Groß-/Kleinschreibung. Es würde die Namen der Quelltabellen „CUSTOMER.ORDERS“ und „customer.orders“ als übereinstimmend bezeichnen. - Kommagetrennte Liste der Namen der Quelltabellen, z. B. „customer.orders, customer.payments“. Die Namen der Quelltabellen werden unter Berücksichtigung der Groß-/Kleinschreibung abgeglichen, d. h. die Quelltabelle „customer.orders“ wird an die MATCH-Beziehung weitergeleitet, aber „customer.ORDERS“ stimmt nicht überein. Übereinstimmende Quelltabellen, die nicht repliziert werden können, werden an die FAILURE-Beziehung weitergeleitet, jede Tabelle in einem separaten FlowFile mit einer Begründung in den Attributen. Die Konfiguration wird als FlowFile-Attribut übergeben. Der Name der Quelltabelle wird als <schema_name>.<table_name> dargestellt. Daher sollten beide Eingaben dies berücksichtigen. Übereinstimmende Quelltabellennamen werden an eine MATCHED-Beziehung weitergeleitet. Der Prozessor generiert ein einzelnes FlowFile mit übereinstimmenden Tabellen. Haftungsausschlüsse - Postgresql ermöglicht es, Datenbankobjektnamen mit oder ohne Unterscheidung zu definieren. Wenn der Benutzer eine Tabelle mit der folgenden Abfrage erstellt: CREATE TABLE ORDERS(id int nicht null) ‚, dann speichert Postgresql sie intern mit Kleinbuchstaben, d. h. „orders“. Um die Groß-/Kleinschreibung zu erzwingen, muss der Benutzer den Tabellennamen in doppelte Anführungszeichen setzen, d. h.CREATE TABLE „ORDERS“(id int not null)‘. 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 |
Kommagetrennte Liste der zu replizierenden Tabellen. Eine einzelne Tabelle sollte als <schema_name>.<table_name> formatiert sein, z. B. customer.orders, customer.payments. Dies wird mit dem regulären Ausdruck kombiniert, um alle übereinstimmenden Tabellen einzuschließen. |
Included Source Table Pattern |
Regulärer Ausdruck zum Angeben von Tabellennamen, die repliziert werden sollen, z. B. customer.(orders|payments). Dies wird mit der kommagetrennten Liste kombiniert, um alle übereinstimmenden Tabellen 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.schema.name |
Name des Schemas der Tabelle, aus der ein Ereignis stammt |
source.table.name |
Name der Tabelle, aus der ein Ereignis stammt |
source.entry |
Der ursprüngliche Eintrag, der bei der Verarbeitung von Tabellennamen zu parsen versucht wurde |
reason |
Grund, warum die Tabelle nicht repliziert werden kann |
source.database.version.major |
Die Hauptversion der Quelldatenbank. |
mime.type |
Der MIME-Typ des FlowFile-Inhalts. |