ListUnityCatalogDirectory 2025.5.31.15¶
捆绑包¶
com.snowflake.openflow.runtime | runtime-databricks-processors-nar
描述¶
列出 Unity Catalog 目录中的文件名，并输出一个带有文件名的新 FlowFile。
输入要求¶
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
Databricks 客户端 |
Databricks 客户端服务。 |
包含目录 |
在生成的 FlowFiles 中包含目录。 |
递归目录列表 |
以递归方式列出子目录中的文件。 |
Unity Catalog 目录路径 |
Unity Catalog 目录路径，例如 /Volumes/catalog/schema/volume_name/directory |
关系¶
名称 |
描述 |
|---|---|
failure |
Databricks failure 关系 |
original |
处理成功后，原始 FlowFile 将路由到此关系。 |
success |
Databricks success 关系 |
写入属性¶
名称 |
描述 |
|---|---|
filename |
Unity Catalog 文件或目录的基本文件名。 |
path |
包含 Unity Catalog 文件或目录的父目录路径。 |
absolute.path |
Unity Catalog 文件或目录的完整路径。 |
uc.resourceType |
Unity Catalog 资源的资源类型，可能是“file”或“directory”。 |
uc.size |
Unity Catalog 文件的大小。 |
uc.lastModifiedTime |
自 UTC 时间纪元以来 Unity Catalog 文件的最后修改时间（以毫秒为单位） |
error.code |
发生错误时 SQL 语句的错误代码。 |
error.message |
发生错误时 SQL 语句的错误消息。 |