FetchAzureDataLakeStorage 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-azure-nar
描述¶
从 Azure Data Lake Storage 中提取指定文件
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
adls-credentials-service |
用于获取 Azure 凭据的控制器服务。 |
directory-name |
Azure Storage Directory 的名称。目录名称不能包含前导的“/”。根目录可以由空字符串值指定。对于 PutAzureDataLakeStorage 处理器，如果该目录不存在，则将创建该目录。 |
file-name |
文件名 |
filesystem-name |
Azure Storage File System（也称为 Container）的名称。假定它已经存在。 |
number-of-retries |
下载失败时要执行的自动重试次数。 |
proxy-configuration-service |
指定代理配置控制器服务来代理网络请求。在 SOCKS 的情况下，无法保证处理器会使用所选 SOCKS 版本。 |
range-length |
要从对象下载的字节数，从 Range Start 开始。空值或超出对象末端的值将读取到对象的末尾。 |
range-start |
读取对象的起始字节位置。空值或零值将从对象的开头开始读取。 |
关系¶
名称 |
描述 |
|---|---|
failure |
由于某种原因无法写入 Azure Storage 的文件将转移到此关系中 |
success |
已成功写入 Azure Storage 的文件将传输到此关系中 |
写入属性¶
名称 |
描述 |
|---|---|
azure.datalake.storage.statusCode |
失败操作的 HTTP 错误代码（如果有） |
azure.datalake.storage.errorCode |
失败操作的 Azure Data Lake Storage 标识符 |
azure.datalake.storage.errorMessage |
失败操作的 Azure Data Lake Storage 错误消息 |
涉及其他组件的用例¶
检索 Azure DataLake Storage Directory 中的所有文件 |