PutAzureDataLakeStorage Processor
描述
将 FlowFile 的内容写入 Azure Data Lake Storage Gen 2 上的文件
标签
属性
| 名称 | 默认值 | 可选值 | 描述 |
|---|---|---|---|
| ADLS Credentials | | 控制器服务 API：ADLSCredentialsServicecn.org.acal.lynxus-lynxus-azure-services-api-nar-2.11.8 | 用于获取 Azure 凭据的Controller Service。 |
| Filesystem Name | | Azure 存储文件系统（也称为容器）的名称。 假设它已经存在。 支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值） | |
| Directory Name | | Azure 存储目录的名称。目录名称不能包含前导 '/'。根目录可以用空字符串值表示。对于 PutAzureDataLakeStorage 处理器，目录是文件系统路径。 支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值） | |
| File Name | ${azure.filename} | 文件名 支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值） | |
| Writing Strategy | WRITE_AND_RENAME |
| 定义写入 Azure 文件的方法。 |
| Base Temporary Path | | 创建临时目录的路径。路径名不能包含前导 '/'。根目录可以用空字符串值表示。不存在的目录将被创建。临时文件目录名为 _lynxustempdirectory 支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值） | |
| Conflict Resolution Strategy | fail |
| 指定当输出目录中已存在同名文件时应如何处理 |
| Resource Transfer Source | FLOWFILE_CONTENT |
| 待传输内容的来源 |
| File Resource Service | | 控制器服务 API：FileResourceServicecn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8 | 文件资源服务提供对要传输的本地资源的访问 |
| Proxy Configuration Service | | 控制器服务 API：ProxyConfigurationServicecn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8 | 指定代理配置 Controller Service 来代理网络请求。 对于 SOCKS，不保证处理器一定会使用所选的 SOCKS 版本。 |
关系 (Relationships)
| 名称 | 描述 | 自动终止 |
|---|---|---|
failure | 由于某种原因无法写入 Azure 存储的文件将传输到此关系 | 否 |
success | 已成功写入 Azure 存储的文件将传输到此关系 | 否 |
写入的 FlowFile 属性
| 名称 | 描述 |
|---|---|
azure.filesystem | Azure 文件系统的名称 |
azure.directory | Azure 目录的名称 |
azure.filename | Azure 文件的名称 |
azure.primaryUri | 文件内容的主要位置 |
azure.length | Azure 文件的长度 |
状态管理
该组件不存储状态。
受限 (Restricted)
该组件不受限。
输入要求
该组件要求有传入连接。
详细说明
PutAzureDataLakeStorage
该 Processor 负责把文件上传到 Azure Data Lake Storage Gen2。
"Write and Rename" 策略下的文件上传与清理过程
上传新文件
- 在 '_lynxustempdirectory' 中的给定路径下创建带随机前缀的临时文件。
- 内容被追加到临时文件。
- 临时文件被移动到最终目标目录，并重命名为原始文件名。
- 追加或重命名失败时，临时文件会被删除。
- 临时文件删除失败时，临时文件会保留在服务器上。
上传已存在的文件
- 冲突解决策略为 "fail" 的 Processor 会把 FlowFile 定向到 "Failure" Relationship。
- 冲突解决策略为 "ignore" 的 Processor 会把 FlowFile 定向到 "Success" Relationship。
- 冲突解决策略为 "replace" 的 Processor：
- 在 '_lynxustempdirectory' 中的给定路径下创建带随机前缀的临时文件。
- 内容被追加到临时文件。
- 临时文件被移动到最终目标目录，并重命名为原始文件名，原文件被覆盖。
- 追加或重命名失败时，临时文件会被删除，原文件保持完好。
- 临时文件删除失败时，临时文件和原文件都会保留在服务器上。
"Simple Write" 策略下的文件上传与清理过程
上传新文件
- 在最终目标位置创建空文件。
- 内容被追加到文件。
- 追加失败时，文件会被删除。
- 文件删除失败时，文件会保留在服务器上。
上传已存在的文件
- 冲突解决策略为 "fail" 的 Processor 会把 FlowFile 定向到 "Failure" Relationship。
- 冲突解决策略为 "ignore" 的 Processor 会把 FlowFile 定向到 "Success" Relationship。
- 冲突解决策略为 "replace" 的 Processor：
- 在最终目标位置创建空文件，原文件被覆盖。
- 内容被追加到文件。
- 追加失败时，文件会被删除，且原文件不会恢复。
- 文件删除失败时，文件会保留在服务器上。