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.

Tags

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.