ListDatabaseTables 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-standard-nar
描述¶
生成一组 FlowFile,每个文件都包含与数据库连接中表的元数据相对应的属性。提取有关表的元数据后,除非刷新间隔(若已设置)已过或状态被手动清除,否则不会再次提取该元数据。
输入要求¶
FORBIDDEN
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
---|---|
list-db-include-count |
是否将表的行数作为 FlowFile 属性包括在内。这会影响性能,因为将为检索到的列表中的每个表生成数据库查询。 |
list-db-refresh-interval |
重置处理器状态从而列出所有当前表之前需要经过的时间。在此间隔内,处理器可以继续运行,但不会重新列出已列出的表。但是,处理器运行时将列出新增/添加的表。值为零表示该状态永远不会自动重置,用户必须手动清除状态。 |
list-db-tables-catalog |
用于列出数据库表的目录的名称。该名称必须与存储在数据库中的目录名称相匹配。如果未设置该属性,则不会使用目录名称来缩小表的搜索范围。如果将该属性设置为空字符串,则将列出没有目录的表。 |
list-db-tables-db-connection |
用于获取数据库连接的控制器服务 |
list-db-tables-name-pattern |
一种用于匹配数据库中表的模式。在此模式中,“%”表示匹配任何包含 0 个或更多字符的子字符串,“_”表示匹配任何一个字符。此模式必须与存储在数据库中的表名相匹配。如果未设置该属性,则将检索所有表。 |
list-db-tables-schema-pattern |
一种用于匹配数据库中架构的模式。在此模式中,“%”表示匹配任何包含 0 个或更多字符的子字符串,“_”表示匹配任何一个字符。此模式必须与存储在数据库中的架构名称相匹配。如果未设置该属性,则不会使用架构名称来缩小表的搜索范围。如果将该属性设置为空字符串,则将列出没有架构的表。 |
list-db-tables-types |
要包含的表类型列表,以逗号分隔。例如,某些数据库支持 TABLE 和 VIEW 类型。如果未设置该属性,则将返回所有类型的表。 |
record-writer |
指定用于创建列表的记录写入器。如果未指定,则将为列出的每个实体创建一个 FlowFile。如果指定了记录写入器,则所有实体都将写入单个 FlowFile,而不是向单个 FlowFiles 添加属性。 |
状态管理¶
范围 |
描述 |
---|---|
CLUSTER |
执行表列表后,系统将存储查询的时间戳。这允许处理器在下次运行时不必重新列出表。在处理器属性中指定刷新间隔将表明,当处理器检测到间隔已过时,状态将被重置,且表将因此重新列出。该处理器只能在主节点上运行。 |
关系¶
名称 |
描述 |
---|---|
success |
所有收到的 FlowFiles 都将路由至“success” |
写入属性¶
名称 |
描述 |
---|---|
db.table.name |
包含连接中数据库表的名称 |
db.table.catalog |
包含该表所属目录的名称(可能为 Null) |
db.table.schema |
包含该表所属架构的名称(可能为 Null) |
db.table.fullname |
包含完全限定的表名(可能包括目录、架构等) |
db.table.type |
包含连接中数据库表的类型。典型的类型有“TABLE”、“VIEW”、“SYSTEM TABLE”、“GLOBAL TEMPORARY”、“LOCAL TEMPORARY”、“ALIAS”、“SYNONYM” |
db.table.remarks |
包含连接中数据库表的名称 |
db.table.count |
包含表中的行数 |
涉及其他组件的用例¶
对数据库进行全面加载,检索所有表或特定表集中的所有记录。 |