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 |
源数据库的主要版本。 |