ListTableNames 2025.10.2.19

捆绑包

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

描述

Fetches all source table names and matches them with one of the possible configurations: - regexp expression e.g. "(?i)customer.(orders|payments)" - it matches names in case insensitive way. It would match both "CUSTOMER.ORDERS" and "customer.orders" source table names. - comma separated list of source table names. e.g. "customer.orders, customer.payments". It matches source table names in case sensitive way i.e. "customer.orders" source table will be forwarded to MATCH relationship but "customer. ORDERS" won 't match. Matched source tables that cannot be replicated will be routed to FAILURE relationship, each table in a separate FlowFile, with a reason in attributes. Configuration is passed as a FlowFile attribute. Source table name is represented as <schema_name>.<table_name> so both inputs should take that into consideration. Matched source table names are forwarded to MATCHED relationship. Processor generates a single FlowFile with matching tables. Disclaimers - Postgresql allows to define database object names in case sensitive or case insensitive way. When user creates a table using following query'CREATE TABLE ORDERS(id int not null) 'then internally Postgresql stores it using lower case letters i.e. orders. To enforce case sensitivity user has to wrap the table name with double quotes i.e.'CREATE TABLE "ORDERS"(id int not null)'. This is important aspect when configuring table that we would like to replicate.

标签

输入要求

REQUIRED

支持敏感的动态属性

false

属性

属性

描述

连接池

用于获取数据库连接的控制器服务。

包含以逗号分隔的源表名称

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.

包含源表模式

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.

关系

名称

描述

failure

如果某个 FlowFile 属性无法读取或不正确,则会将路由到此关系。

matched

成功创建的 FlowFile,包含在源数据库中找到的匹配表的列表。

写入属性

名称

描述

source.schema.name

Name of the schema of the table from which an event originated

source.table.name

Name of the table from which an event originated

source.entry

The original entry that was attempted to parse when processing table names

reason

Reason why table cannot be replicated

source.database.version.major

源数据库的主要版本。

mime.type

The MIME type of the FlowFile content.

语言: 中文