hdfs同步
November 18, 2022About 4 min
hdfs同步
SDK类名:/hdfs/Hdfs
hdfs同步 - 新建
SDK方法名:createHdfs;
URL
/hdfs
Method
POST
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
rule_name | String | 规则名称 | |||
rule_type | Number | 规则类型: 0:hdfs; 1:hive; | |||
src_uuid | String | 源平台uuid | |||
tgt_uuid | String | 目标平台uuid | |||
src_path | Array | 源平台路径; hdfs必传 | |||
dest_path | Array | 目标平台路径; hdfs必传 | |||
filters | Array | 过滤路径; 正则表达式; hdfs传 | |||
src_db | Array | 源平台库; hive必填 | |||
dest_db | Array | 目标平台库; hive必填 | |||
filter_tables | Array | 过滤表; 正则表达式; hive传; | |||
sync_type | Number | 同步类型: 0:(全备+增量) 目前固定只有一种; | 0 | ||
overwrite | Number | 覆盖类型: 0:跳过; 1:覆盖; | 0 | ||
band_width | String | 带宽控制,格式:303:00-14:002m,202:00-15:0080m(block也有) |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 200 | |||
msg | String | ||||
data | Object | ||||
code | Number | 0 | |||
message | String |
hdfs同步 - 列表
SDK方法名:listHdfs;
URL
/hdfs
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
page | Number | 1 | |||
limit | Number | 15 | |||
search_field | String | '' | |||
search_value | String | '' |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
msg | String | ||||
ret | Number | 200 | |||
data | Object | ||||
count | Number | 10 | |||
info_list | Array | ||||
rule_uuid | String | 规则uuid | @uuid | ||
rule_name | String | 规则名称 | |||
rule_type | Number | 规则类型 | 0 | ||
src_uuid | String | 源平台uuid | |||
src_name | String | 源平台名称 | |||
tgt_uuid | String | 目标平台uuid | |||
tgt_name | String | 目标平台名称 | |||
src_path | Array | 源路径 | |||
dest_path | Array | 目标路径 | |||
filters | Array | 排除路径(正则表达式) | |||
src_db | Array | 源库 | |||
dest_db | Array | 目标库 | |||
filter_tables | Array | 排除表(正则表达式) | |||
sync_type | Number | 同步类型: 0:(全备+增量) 目前固定只有一种; | 0 | ||
overwrite | Number | 覆盖类型: 0:跳过; 1:覆盖; | 0 | ||
total | Number | 100 | |||
code | Number | 0 | |||
message | String |
hdfs同步 - 获取单个
SDK方法名:describeHdfs;
URL
/hdfs/:uuid([A-F0-9-]+)
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 200 | |||
msg | String | ||||
data | Object | ||||
message | String | ||||
hdfs | Object | ||||
rule_uuid | String | 规则uuid | |||
rule_name | String | 规则名称 | |||
rule_type | Number | 规则类型 | 0 | ||
src_uuid | String | 源平台uuid | |||
tgt_uuid | String | 目标平台uuid | |||
src_path | Array | 源路径 | |||
dest_path | Array | 目标路径 | |||
filters | Array | 排除路径 | |||
src_db | Array | 源库 | |||
dest_db | Array | 目标库 | |||
filter_tables | Array | 排除表 | |||
random_str | String | 随机字符串 | |||
sync_type | Number | 同步类型: 0:(全备+增量) 目前固定只有一种; | 0 | ||
overwrite | Number | 覆盖类型: 0:跳过; 1:覆盖; | 0 | ||
code | Number | 0 |
hdfs同步 - 删除
SDK方法名:deleteHdfs;
URL
/hdfs
Method
DELETE
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
uuids | Array | ||||
force | Number | 强制删除 | 0 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
msg | String | ||||
ret | Number | 200 | |||
data | Object | ||||
code | Number | 11110001 | |||
message | String | ||||
fail_list | Array | ||||
code | Number | 11110001 | |||
message | String | [-1] 找不到节点 | |||
rule_uuid | String | @uuid | |||
rule_name | String | @name | |||
success_list | Array | ||||
code | Number | 11110001 | |||
message | String | [0] success | |||
rule_uuid | String | @uuid | |||
rule_name | String | @name |
hdfs同步 - 操作
SDK方法名:{operate}Hdfs
URL
/hdfs/operate
Method
POST
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
rule_uuids | Array | 规则uuids | |||
operate | String | 操作: start:启动; stop:停止; |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 200 | |||
msg | String | ||||
data | Object | ||||
message | String | ||||
code | Number | 0 | |||
success_list | Array | ||||
code | String | 0 | |||
message | String | dsaf | |||
rule_uuid | String | aaa | |||
rule_name | String | adsf | |||
fail_list | Array | ||||
code | String | fasfd | |||
message | String | asfda | |||
rule_uuid | String | fads | |||
rule_name | String | fssa |
hdfs同步 - 获取状态
SDK方法名:listHdfsStatus;
URL
/hdfs/status
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
rule_uuids | Array | ||||
force_refresh | Number | 点击操作栏刷新按钮必传,下发1,表示从rpc获取;其他情况不传 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
msg | String | ||||
ret | Number | 200 | |||
data | Object | ||||
count | String | 1 | |||
message | String | ||||
code | Number | 0 | |||
status | Array | ||||
rule_uuid | String | @guid | |||
status | String | SCAN:扫描; SYNC:同步; MIRROR:镜像; UNKNOWN:未知; START:开始; STOP:停止; PAUSE:暂停; ERROR:错误; | |||
source_scan_count | String | 源端读取文件总数 | |||
source_scan_size | String | 源端读取文件总字节 | |||
dest_write_count | String | 目标端写入文件总数 | |||
dest_write_size | String | 目标端写入文件总字节 | |||
skip_count | String | 相同文件总数 | |||
skip_size | String | 相同文件总字节 | |||
transferred_count | String | 已传输文件数 | |||
transferred_size | String | 已传输文件字节 |