ListTableNames 2025.5.31.15

捆绑包

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

描述

提取所有源表名称并将其与可能配置之一进行匹配:- regexp expression,例如“(?i)customer.(orders|payments)" - it matches names in case insensitive way. It would match both "CUSTOMER.ORDERS" and "customer.orders" source table names. The MicrosoftSQL Server accepts FQN containing database name e.g. (?i)prod.customer.(orders|payments)- 以逗号分隔的源表名称列表。例如“customer.orders, customer.payments”。它以区分大小写的方式匹配源表名称,即“customer.orders”源表将转发到 MATCH 关系中,但“customer.ORDERS”不匹配。Microsoft SQL Server 接受包含数据库名称的 FQN,例如“prod1.customer.orders、prod1.customer.payments”。配置作为 FlowFile 属性传递。源表名称表示为 <schema_name>.<table_name>,因此,两个输入都应考虑到这一点。匹配的源表名将转发到 MATCHED 关系中。处理器生成带有匹配表格的单个 FlowFile。Disclaimers- Postgresql 允许以区分大小写或不区分大小写的方式定义数据库对象名称。当用户使用以下查询“CREATE TABLE ORDERS(id int not null)”创建表时,Postgresql 在内部使用小写字母(即 orders)来存储它。要强制区分大小写,用户必须将表名放在双引号内,即‘CREATE TABLE“ORDERS”(id int notnull)’。在配置我们要复制的表时,这一点很重要。

标签

输入要求

REQUIRED

支持敏感的动态属性

false

属性

属性

描述

连接池

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

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

要复制的以逗号分隔的表列表的列表。单个表的格式应为 <schema_name>.<table_name>,例如,customer.orders、customer.payments。它与正则表达式结合,以包括任何匹配的表。

包含源表模式

用于指定要复制的表名称的正则表达式,例如 customer.(orders|payments)。它与逗号分隔的列表相结合,以包括任何匹配的表。

关系

名称

描述

failure

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

matched

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

写入属性

名称

描述

source.database.version.major

源数据库的主要版本。

语言: 中文