Write Chunk File

通过指定通道,向数据源写入块文件。

前提条件

已创建数据写入通道,且通道已启动。

请求格式

POST https://{apigw-address}/data-federation/v2.0/channels/write/{channelId}/chunk-file

请求参数(URI)

名称 位置(Path/Query) 必需/可选 数据类型 描述
orgId Query 必需 String 用户所属的组织ID。如何获取orgId信息>>
channelId Path 必需 String 通道ID。
dataSourceName Query 必需 String 数据源别名,目前仅支持HDFS数据源。

请求参数(Body)

名称 必需/可选 数据类型 描述
fileName 必需 String 待写入的文件名。
totalSize 必需 Integer 文件大小。
chunkOffset 必需 Integer 当前块在文件中的偏移。
chunkSize 必需 Integer 当前块大小(base64编码之前的大小)。
chunkData 必需 String 块数据,需要进行Base64编码。

示例

请求示例

url: https://{apigw-address}/data-federation/v2.0/channels/write/{channelId}/chunk-file?orgId={}&dataSourceName={}

method: POST

requestBody:
{
  "fileName": "ttt",
  "totalSize": "13",
  "chunkData": "dGVzdHRlc3R0dGVzdA==",
  "chunkSize": "13",
  "chunkOffset": "0"
}

返回示例

{
  "msg": "OK",
  "code": 0,
  "submsg": ""
}

SDK 示例


你可以在 Github 上获取数据联邦的 SDK 示例: