PutGoogleDrive

文档中心 › 组件索引 › PutGoogleDrive

PutGoogleDrive Processor

类型全限定名:cn.org.acal.lynxus.processors.gcp.drive.PutGoogleDrive

所属 Bundle:cn.org.acal.lynxus:lynxus-gcp-nar:2.11.8

描述

将 FlowFile 的内容作为文件写入 Google Drive 中。

标签

googledrivestorageput

属性

下表中,加粗的属性为必填项;其余为可选项。表格同时标注默认值、是否支持表达式语言,以及是否为敏感属性(值会被加密)。

名称默认值可选值描述
GCP Credentials Provider Service控制器服务 API:
GCPCredentialsService
cn.org.acal.lynxus-lynxus-gcp-services-api-nar-2.11.8
用于获取 Google Cloud Platform 凭据的Controller Service。
Folder ID共享文件夹的 ID。请参阅其他详细信息以设置对 Google 云端硬盘的访问并获取文件夹 ID。
支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值)
Filename${filename}要上传到指定 Google 云端硬盘文件夹的文件的名称。
支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值)
Conflict Resolution Strategyfail
  • fail — 将文件冲突作为失败处理。
  • ignore — 忽略冲突,不更改原始文件。
  • replace — 如果发生冲突,请替换现有文件。
指示当指定的 Google 云端硬盘文件夹中已存在同名文件时会发生什么情况。
Chunked Upload Threshold100 MB一次上传内容的最大大小。 大于此阈值的 FlowFile 会分块上传。
Chunked Upload Size10 MB定义分块大小。当 FlowFile 的大小超过 'Chunked Upload Threshold' 时,内容将以较小的分块上传。允许的最小分块大小为 256 KB,最大分块大小为 1 GB。
Google Drive API ScopeDRIVE_SCOPES
  • Drive Scopes — 使用 Drive 专用范围。推荐用于大多数设置,包括具有全域委派(domain-wide delegation)的服务账号。
  • Cloud Platform — 使用更广泛的云平台范围。 将工作负载联合身份验证与服务帐户模拟结合使用时是必需的。
指定访问 Google Drive 时请求的 OAuth2 范围。'Drive Scopes' 使用特定于 Drive 的范围,推荐用于大多数设置,包括具有域范围委派的服务账户。'Cloud Platform' 使用更广泛的 cloud-platform 范围,在使用具有服务账户模拟的工作负载身份联合时需要此范围。
Proxy Configuration Service控制器服务 API:
ProxyConfigurationService
cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8
指定代理配置 Controller Service 来代理网络请求。
Connect Timeout20 sec连接 Google 云端硬盘服务的最长等待时间。
支持表达式语言:是(仅使用环境/系统变量求值)
Read Timeout60 secGoogle 云端硬盘服务响应的最长等待时间。
支持表达式语言:是(仅使用环境/系统变量求值)

关系 (Relationships)

名称描述自动终止
failure由于某种原因无法写入 Google 云端硬盘的文件将传输到此关系。否
success已成功写入 Google 云端硬盘的文件将传输至此关系。否

读取的 FlowFile 属性

名称描述
filename使用 FlowFile 的文件名作为 Google Drive 对象的文件名。

写入的 FlowFile 属性

名称描述
drive.id文件的 ID
filename文件的名称
mime.type文件的 MIME 类型
drive.size文件的大小。当文件大小不可用时设置为 0(例如外部存储的文件)。
drive.size.available指示文件大小是否已知/可用
drive.timestamp文件的最后修改时间或创建时间(取较大者)。这是因为文件上传到 Google Drive 时会保留原始修改日期。'创建时间'取上传发生的时间。但上传的文件之后仍可被修改。
drive.created.time文件的创建时间
drive.modified.time文件的最后修改时间
error.codeGoogle Drive 返回的错误代码
error.messageGoogle Drive 返回的错误消息

状态管理

该组件不存储状态。

受限 (Restricted)

该组件不受限。

输入要求

该组件要求有传入连接。

详细说明

PutGoogleDrive

从 Lynxus 访问 Google Drive

该 Processor 使用 Google Cloud 凭据进行认证,以访问 Google Drive。 为这些 Processor 准备 Google Cloud 和 Google Drive 账户需要以下步骤:

  1. 在 Google Cloud 中启用 Google Drive API
  2. 授予 Google Drive 文件夹的访问权限
    • 在 Google Cloud Console 中,进入 IAM & Admin -> Service Accounts。
    • 记下将要使用的服务账号的邮箱。
    • 在 Google Drive 中找到将作为基础文件夹使用的文件夹。
    • 右键点击文件夹 -> Share。
    • 输入服务账号的邮箱。
  3. 找到 Folder ID
    • 在 Google Drive 中找到要列出的文件夹并进入。浏览器中的 URL 末尾会包含 ID。例如,如果 URL 是 https://drive.google.com/drive/folders/1trTraPVCnX5_TNwO8d9P_bz278xWOmGm, 那么 Folder ID 就是 1trTraPVCnX5_TNwO8d9P_bz278xWOmGm
  4. 在 'Folder ID' 属性中设置 Folder ID