Mysql同步
Mysql同步
SDK类名:/active/Mysql
-------同步规则---
示例接口描述
URL
/mysql同步规则
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
mysql规则管理-新建
SDK 方法名:createMysqlRule
URL
/stream/rule
Method
POST
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
mysql_name | Boolean | 否 | @name | ||
tgt_db_uuid | Array | 否 | 备端数据库(分发时为多选) | D42BF707-C971-EEA9-521F-BB0F3F7A92FC | |
tgt_type | String | 否 | 备库类型 mysql , oracle,kfaka,postgres,vertica,greenplum | oracle | |
start_rule_now | Number | 否 | 0 | ||
dbmap_topic | String | 否 | kafka类型,整库映射 | ||
map_type | String | 否 | 映射方式 库映射database 表映射:table 整库映射 all | table | |
tab_map | Array | 否 | 表映射 | ||
src_table | String | 否 | src_table | ||
dst_table | String | 否 | dst_table | ||
src_db | String | 否 | 111 | ||
dst_db | String | 否 | 222 | ||
topic | String | kafka 时库映射存在此参数 | |||
full_sync | Number | 否 | 全量同步 当备端类型不是mysql时 全量同步不用选择同步方式 默认 否 | 0 | |
incre_sync | Number | 否 | 增量同步 | 1 | |
model_type | String | 否 | 模式 汇聚n:1, 分发:1:n,主-主:1:1 主-从:1:0 | 1:0 | |
full_sync_mode | String | 否 | 全同步方式,逻辑:logic 物理 physics 自动 auto(汇聚只有逻辑一种) | auto | |
db_set | Object | 否 | 高级设置->数据库设置 | ||
binlog_row_image | String | 否 | full | full | |
default_storage_engine | String | 否 | innoDB | innoDB | |
sync_binlog | String | 否 | 1 | 1 | |
innodb_flush_log | String | 否 | 2 | ||
innodb_flush_method | String | 否 | O_DIRECT | O_DIRECT | |
binlog_format | String | 否 | row | row | |
open_files_limit | String | 否 | 65535 | 65535 | |
server_id | String | 否 | 随机值 | 123456 | |
expire_logs_days | String | 否 | 7 | 7 | |
nat_mode | Number | 否 | 否:0 是 1,默认为否,如果选择是,则显示出如下内容 | 0 | |
ip | String | 否 | 外网 ip | ||
max_allowed_packet | String | 否 | 52m | 52 | |
src_db_uuid | Array | 否 | 汇聚可一次传多个已逗号隔开 | 1B1153F6-DAD9-BC39-888A-A743FCC208E5 | |
primary_db_one | String | 否 | (主-主 有值其他情况空)主数据库1 | ||
primary_map_type_one | String | 否 | 映射方式 库,表,整库 映射(主主 其他为空) | ||
primary_map_one | String | 否 | 主-主 有值其他情况空) 映射下传的值 {111:222, 111:333} | ||
primary_db_two | String | 否 | 主-主 有值其他情况空)主数据库2 | ||
primary_map_type_two | String | 否 | 主-主 有值其他情况空)映射方式 | ||
primary_map_two | String | 否 | 主-主 有值其他情况空)传递值 | ||
db_map | Array | 否 | 库映射 | ||
dst_table | String | 否 | |||
src_table | String | 否 | |||
modify | Boolean | 否 | false | ||
start_src_db_set | Number | 否 | 开启源端配置 | 0 | |
start_dst_db_set | Number | 否 | 0 | ||
dst_db_set | Object | 否 | 备端数据库设置 | ||
binlog_format | String | 否 | |||
binlog_row_image | String | 否 | |||
default_storage_engine | String | 否 | |||
sync_binlog | String | 否 | |||
innodb_flush_log | String | 否 | |||
innodb_flush_method | String | 否 | |||
max_allowed_packet | String | 否 | |||
open_files_limit | String | 否 | |||
server_id | String | 否 | |||
expire_logs_days | String | 否 | |||
nat_mode | Number | 否 | |||
ip | String | 否 | |||
dst_full_sync_set | Object | 否 | |||
support_ddl | Number | 否 | |||
change_tf_path | String | 否 | |||
tf_file_save_time | String | 否 | |||
nat_mode | String | 否 | |||
foreign_ip | String | 否 | |||
extraction | Number | 否 | 0 | ||
start_lsn | Number | 否 | |||
full_sync_set | Object | 否 | 同步程序设置 | ||
support_ddl | Number | 否 | 否:0 是 1,是否支持ddl 当备端为mysql时,缺省为支持DDL,当备端非mysql时,缺省为不支持DDL | 1 | |
change_tf_path | String | 否 | 更改TF文件路径 | ||
tf_file_save_time | Number | 否 | 传数字 | 7 | |
nat_mode | Number | 否 | 默认为否,如果选择是,则显示出如下内容 | 0 | |
foreign_ip | String | 否 | 外网ip | ||
extraction | Number | 否 | 是否支持远程抽取 | 0 | |
start_lsn | Number | 否 | |||
config | Object | ||||
dml_track | Object | DML操作追踪设置 | |||
delcol | String | 删除标记字段名称 | |||
drp | Number | 删除 | |||
enable | Number | 0不启用 1启用 | 1 | ||
tmcol | String | 操作时间字段名称 | |||
urp | Number | 更新 | |||
src_connect_user | String | ||||
dst_connect_user | String | ||||
bw_settings | Object | 带宽设置 | |||
bw_limit | String | "1200:00-13:0040M,300:00-13:0040M" | |||
full_sync_settings | Object | 全量设置 | |||
clean_user_before_dum | Number | 0 | |||
concurrent_table | Array | ||||
dump_thd | Number | ||||
load_thd | Number | ||||
existing_table | String | drop_to_recycle | |||
try_split_part_table | Number | ||||
table_msg_uuid | String | 表元信息库 | |||
end_target_type | String | 最终数据库类型 | |||
end_target_db | String | 最终目标库 | |||
end_db_map | String | 最终库映射 | |||
end_tab_map | String | 最终表映射 | |||
full_sync_custom_cfg | Array | 全局自定义配置 | |||
key | String | ||||
value | String | ||||
start_lsn | String | 起始lsn | |||
etl_settings | Object | etl 表设置 | |||
etl_table | Array | ||||
deal_Type | String | 处理方式 IRP :插入 URP:更新 DRP:删除 ALLDML:全部 | IRP | ||
table | String | 表名 | |||
user | String | 用户名 | |||
obj_fix_type | String | 操作类型 SKIP 忽略 DRP 删除 | SKIP | ||
field_condition | String | 字段或条件 | |||
inc_sync_ddl_filter | Object | 增量ddl 过滤设置 | |||
inc_sync_ddl_data | Array | 0: "CREATE TABLE" 1: "DROP TABLE" 2: "ALTER TABLE ADD" 3: "ALTER TABLE DROP" 4: "ALTER TABLE RENAME" 5: "ALTER TABLE MODIFY" 6: "ALTER TABLE CHANGE" 7: "ALTER TABLE ALTER" 8: "TRUNCATE TABLE" | [ CREATE TABLE ] | ||
table_change_info | Number | 表结构变更通知 | |||
message_format | String | protobuf json | |||
json_format | String | json canaljson message_format为json时,可传json , canaljson, 其他值传空串 | |||
binary_code | String | 取值 hex , base64 | hex | ||
run_time | String | 运行时间 | "1200:00-13:0040M,300:00-13:0040M" | ||
jointing | Object | 字段拼接 | |||
table | String | ||||
op | String | 操作 op类型定义 前辍 prefix 后辍 append 常量 const 拼接 join 加 add 减 sub 乘 multiply 除 divide | append | ||
content | Array | 目标列+其他两行 | |||
part_load_balance | String | 分区均衡策略 主键哈希: by_key 表名哈希: by_table | |||
kafka_time_out | String | producer 超时时间 | |||
save_json_text | String | 【目标类型:Kafka】另存文本文件 | |||
exclude_dbs | Array | 排除库列表 | |||
exclude_dbs_switch | Number | 排除库开关,0:关,1:开 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
code | Number | 否 | 0 | ||
message | String | 否 | success | ||
uuid | String | @uuid |
mysql规则管理-修改
SDK方法名:modifyMysqlRule
URL
/stream/rule
Method
PUT
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
mysql_name | String | 否 | mysql | ||
src_db_uuid | Array | 否 | 1B1153F6-DAD9-BC39-888A-A743FCC208E5 | ||
tgt_db_uuid | Array | 否 | 备端数据库(分发时为多选) | D42BF707-C971-EEA9-521F-BB0F3F7A92FC | |
tgt_type | String | 否 | 备库类型 mysql , oracle,kfaka,postgres,vertica,greenplum | kafka | |
start_rule_now | Number | 否 | 0 | ||
node_uuid | String | 否 | 6B1153F6-DAD9-BC39-888A-A743FCC208E6 | ||
dbmap_topic | String | 否 | kafka类型,整库映射 | ||
map_type | String | 否 | 映射方式 库映射database 表映射:table 整库映射 all | table | |
tab_map | Array | 否 | 表映射 | ||
src_table | String | 否 | src_table | ||
topic | String | 否 | kafka 时库映射存在此参数 | topic | |
dst_table | String | ||||
src_db | String | ||||
dst_db | String | ||||
full_sync | Number | 否 | 全量同步 当备端类型不是mysql时 全量同步不用选择同步方式 默认 否 | 0 | |
incre_sync | Number | 否 | 增量同步 | 1 | |
model_type | String | 否 | 模式 汇聚n:1, 分发:1:n,主-主:1:1 主-从:1:0 | 1:0 | |
full_sync_mode | String | 否 | 全同步方式,逻辑:logic 物理 physics 自动 auto(汇聚只有逻辑一种) | auto | |
db_set | Object | 否 | 高级设置->数据库设置 | ||
db_node | String | 否 | 1B1153F6-DAD9-BC39-888A-A743FCC208E5 | ||
binlog_format | String | 否 | row | ||
binlog_row_image | String | 否 | full | ||
default_storage_engine | String | 否 | innoDB | ||
sync_binlog | String | 否 | 1 | ||
innodb_flush_log | String | 否 | 2 | ||
innodb_flush_method | String | 否 | O_DIRECT | ||
max_allowed_packet | String | 否 | 52 | ||
open_files_limit | String | 否 | 65535 | ||
server_id | String | 否 | 123456 | ||
expire_logs_days | String | 否 | 7 | ||
nat_mode | Number | 否 | 0 | ||
ip | String | 否 | |||
full_sync_set | Object | 否 | 同步程序设置 | ||
support_ddl | Number | 否 | 1 | ||
node | String | 否 | 6B1153F6-DAD9-BC39-888A-A743FCC208E6 | ||
change_tf_path | String | 否 | |||
tf_file_save_time | Number | 否 | 7 | ||
nat_mode | Number | 否 | 0 | ||
foreign_ip | String | 否 | |||
primary_node_one | String | 否 | |||
primary_node_two | String | 否 | |||
primary_db_one | String | 否 | |||
primary_map_type_one | String | 否 | |||
primary_map_one | Array | 否 | |||
primary_db_two | String | 否 | |||
primary_map_type_two | String | 否 | |||
primary_map_two | Array | 否 | |||
db_map | Array | 否 | 库映射 | ||
src_db | String | 否 | src_db | ||
dst_db | String | 否 | dst_db | ||
mysql_uuid | String | 否 | 5349E2CF-7DBO-OAF2-13CB-BB7DFD8A9D86 | ||
config | Object | ||||
dml_track | Object | DML操作追踪设置 | |||
bw_settings | Object | 带宽设置 | |||
full_sync_settings | Object | 全量设置 | |||
etl_settings | Object | etl 表设置 | |||
inc_sync_ddl_filter | Object | 增量ddl 过滤设置 | |||
table_change_info | String | 表结构变更通知 | |||
message_format | String | protobuf json | |||
json_format | String | json canaljson message_format为json时,可传json , canaljson, 其他值传空串 | |||
binary_code | String | 取值 hex , base64 | |||
run_time | String | 运行时间 | "1200:00-13:0040M,300:00-13:0040M" | ||
part_load_balance | String | 分区均衡策略 主键哈希: by_key 表名哈希: by_table | by_table | ||
kafka_time_out | String | producer 超时时间 | |||
save_json_text | Boolean | 【目标类型:Kafka】另存文本文件 | false |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
code | Number | 否 | 0 | ||
message | String | 否 | success |
mysql规则管理-删除
SDK方法名:deleteMysqlRule
URL
/stream/rule
Method
DELETE
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
mysql_uuids | Array | 否 | |||
0 | String | @guid | |||
force | Boolean | true |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | ||||
code | Number | 0 | |||
message | String | [0] success | |||
success_list | Array | ||||
code | Number | 0 | |||
message | String | [0] success | |||
mysql_uuid | String | 16CB63E1-13FA-FB32-EB49-D790682C9648 | |||
mysql_name | String | task1 | |||
fail_list | Array | ||||
code | Number | -1 | |||
message | String | [-1] 找不到节点 | |||
mysql_uuid | String | 16CB63E1-13FA-FB32-EB49-D790682C9647 | |||
mysql_name | String | task2 |
mysql规则管理-获取单个信息
SDK方法名:describeMysqlRule
URL
/stream/rule/:uuid([A-F0-9-]+)
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
mysql_uuid | String | 否 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 | ||
info_list | Object | 否 | |||
mysql_name | String | 否 | mysql | ||
src_db_uuid | String | 否 | ['1111','2222'] | ||
tgt_db_uuid | Array | 否 | 2222 | ||
tgt_type | String | 否 | kafka | ||
start_rule_now | Number | 否 | 0 | ||
node_uuid | String | 否 | 6B1153F6-DAD9-BC39-888A-A743FCC208E6 | ||
dbmap_topic | String | 否 | db_topic | ||
map_type | String | 否 | database | table | |
tab_map | Array | 否 | 2 | ||
src_table | String | 否 | @name | ||
dst_table | String | 否 | @name | ||
src_db | String | 否 | 111 | ||
dst_db | String | 否 | 222 | ||
full_sync | Number | 否 | 0 | ||
incre_sync | Number | 否 | 1 | ||
model_type | String | 否 | n:1 | ||
full_sync_mode | String | 否 | auto | ||
db_set | Object | 否 | |||
db_node | String | 否 | 1B1153F6-DAD9-BC39-888A-A743FCC208E5 | ||
binlog_format | String | 否 | row | ||
binlog_row_image | String | 否 | full | ||
default_storage_engine | String | 否 | innoDB | ||
sync_binlog | String | 否 | 777 | ||
innodb_flush_log | String | 否 | 777 | ||
innodb_flush_method | String | 否 | O_DIRECT | ||
max_allowed_packet | String | 否 | 777 | ||
open_files_limit | String | 否 | 777 | ||
server_id | String | 否 | 777 | ||
expire_logs_days | String | 否 | 777 | ||
nat_mode | Number | 否 | 0 | ||
ip | String | 否 | 192.168.1.1 | ||
full_sync_set | Object | 否 | |||
support_ddl | Number | 否 | 1 | ||
node | String | 否 | 6B1153F6-DAD9-BC39-888A-A743FCC208E6 | ||
change_tf_path | String | 否 | |||
tf_file_save_time | Number | 否 | 777 | ||
nat_mode | Number | 否 | 0 | ||
foreign_ip | String | 否 | 192.168.1.1 | ||
start_lsn | String | 否 | 9 | ||
primary_node_one | String | 否 | 1111 | ||
primary_node_two | String | 否 | 2222 | ||
primary_db_one | String | 否 | EC9D7dcC-55BC-849b-ABd1-F7AbADC7f936 | ||
primary_map_type_one | String | 否 | table | ||
primary_map_one | String | 否 | {"123":"123"} | ||
primary_db_two | String | 否 | b254e0c8-f91d-b4Ac-4ab3-C8A2bCbdB86c | ||
primary_map_type_two | String | 否 | database | ||
primary_map_two | String | 否 | {"44":"44","555":"555"} | ||
db_map | Array | 否 | 2 | ||
src_table | String | 否 | 555 | ||
dst_table | String | 否 | 666 | ||
dst_full_sync_set | Object | 否 | |||
support_ddl | Number | 否 | 1 | ||
change_tf_path | String | 否 | |||
tf_file_save_time | Number | 否 | 7 | ||
nat_mode | Number | 否 | 0 | ||
foreign_ip | Number | 否 | |||
extraction | Number | 否 | 0 | ||
start_lsn | String | 否 | 0 | ||
config | Object | ||||
dml_track | Object | ||||
enable | Number | 0 | |||
urp | Number | 0 | |||
drp | Number | 0 | |||
tmcol | String | ||||
delcol | String |
mysql规则管理-操作
SDK方法名:
继续:resumeMysqlRule;
停止:stopMysqlRule;
修改:modifyMysqlRule;
重启:restartMysqlRule;
开始解析:startParsingMysqlRule;
停止解析:stopParsingMysqlRule;
重新解析:resetParsingMysqlRule;
开始加载:startLoadMysqlRule;
停止加载:stopLoadMysqlRule;
重新加载:resetLoadMysqlRule;
移除:removeMysqlRule;
URL
/stream/rule/operate
Method
POST
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
operate | String | 否 | resume 继续 stop 停止 restart 重启 (下面的暂时都弃用) start_parsing(暂时隐藏) stop_parsing(暂时隐藏) reset_parsing(暂时隐藏) start_load stop_load reset_load remove stop_schedule 停止调度 start_schedule 启动调度 stop_analysis:停止解析 start_analysis:开始解析 reset_analysis: 重置解析 | restart | |
mysql_uuid | String | 否 | @guid | ||
scn | String | 否 | |||
all | Number | 否 | 只有在重置装载时才有此值 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 |
mysql规则管理-规则列表
SDK方法名:listStreamRules
URL
/stream/rule
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
page | Number | 否 | 1 | ||
limit | Number | 否 | 10 | ||
search_field | String | 否 | |||
search_value | String | 否 | |||
where_args | Object | 否 | |||
mysql_uuid | String | 否 | @guid |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
code | Number | 否 | 0 | ||
total | Number | 否 | 12 | ||
info_list | Array | 否 | |||
mysql_uuid | Array | 否 | 规则uuid | ['3D7dFcd9-C176-d9ee-4FFB-f22bbd554929', '3D7dFcd9-C176-d9ee-4FFB-f22bbd554928'] | +1 |
src_db_uuid | Array | 否 | 源端uuid | ['3D7dFcd9-C176-d9ee-4FFB-f22bbd554926'] | |
tgt_db_uuid | Array | 否 | 备端uuid | ['3D7dFcd9-C176-d9ee-4FFB-f22bbd554927'] | |
tgt_type | Array | 否 | 备端类型 | [ "kafka", "sqlserver", "hbase", "postgres", "oracle" ] | +1 |
user_uuid | String | 否 | 1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC | ||
mysql_name | String | 否 | 规则名称 | @name | |
tgt_db_name | Array | 否 | 备端数据库名称 | ['bei'] | |
model_type | String | 否 | n:1, 1:0 | n:1 | |
can_op | Number | 否 | 1 | ||
can_up | Number | 否 | 1 | ||
can_del | Number | 否 | 1 | ||
src_db_name | Array | 否 | ['111', 'hello'] | ['hello'] | |
is_biz_admin | Number | 否 | 1 | ||
map_type | String | 否 | table, database | database | |
tab_map | Array | 否 | 表映射 | ||
src_table | String | 否 | @name | ||
dst_table | String | 否 | @name | ||
src_db | String | 否 | 111 | ||
dst_db | String | 否 | 222 | ||
db_map | Array | 否 | 库映射 | ||
src_table | String | 否 | @name | ||
dst_table | String | 否 | @name | ||
message | String | 否 |
mysql规则管理-状态
SDK方法名:listStreamStatus
URL
/stream/rule/status
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
uuids | Array | 否 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | 3333 | ||
data | Object | 否 | |||
code | Number | 否 | 0 | ||
message | String | 否 | 44444 | ||
info_list | Array | 否 | 2 | ||
wSt | Array | 否 | 2 导出 | ||
status | String | 否 | ACTIVE_RULE_TRACK | ACTIVE_RULE_DUMP | |
progress | Number | 否 | 55 | ||
bSt | Array | 否 | 2 装载 | ||
status | String | 否 | ACTIVE_RULE_DUMP | ACTIVE_RULE_TRACK | |
progress | String | 否 | 66 | ||
mysql_uuid | Array | 否 | ['3D7dFcd9-C176-d9ee-4FFB-f22bbd554929', '3D7dFcd9-C176-d9ee-4FFB-f22bbd554928'] | +1 | |
stage | String | pause: 停止 dump: 全量 track:增量 done:完成 offline:离线 | done | ||
state | String | 0:正常 非0:错误 | 0 | ||
progress | String | 进度 | 100 | ||
scheduleState | String | ACTIVE_RULE_SCHEDULING:调度中 ACTIVE_RULE_STOP_SCHEDUL:停止调度 | ACTIVE_RULE_SCHEDULING |
mysql规则管理-日志
SDK方法名:listStreamLog;mysql日志管理
URL
/stream/rule/log
Method
POST
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
offset | Number | 否 | 1 | ||
limit | Number | 否 | 10 | ||
date_start | String | 否 | 1624876176 | ||
date_end | String | 否 | 1624876118 | ||
type | Number | 否 | 1 | ||
module_type | Number | 否 | -1 | ||
query_type | Number | 否 | 1 | ||
mysql_uuid | String | 否 | @guid | ||
rule_uuid | String | @guid |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
msg | String | 否 | |||
data | Object | 否 | |||
code | Number | 否 | 0 | ||
message | String | 否 | Delete success | ||
info_list | Array | 否 | |||
create_time | String | 否 | 2019-08-09 17:29:43 | ||
detail | String | 否 | Full Sync done, elapsed time: 24 sec' | ||
flag | Number | 否 | 1 | ||
log_level | String | 否 | 2 | ||
log_type | String | 否 | 装载 | ||
uuid | String | 否 | @uuid | ||
ret | Number | 否 | 200 |
mysql规则管理-同步状态(暂时废弃)
SDK方法名:listStreamSyncStatus
URL
/stream/rule/sync_status
Method
POST
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
node_uuid | String | 否 | 节点 uuid | @guid | |
mysql_uuid | String | 否 | 规则 uuid | @guid |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
code | Number | 否 | 0 | ||
message | String | 否 | success | ||
info_list | Array | 否 | |||
host_name | String | 否 | 主机名称 | @name | |
work | String | 否 | 事务 | 111 | |
after_work | String | 否 | 前事务 | 222 | |
load_number | String | 否 | 333 | ||
load_time | String | 否 | 装载延时 | 444 | |
load | String | 否 | 555 | ||
status | String | 否 | 666 |
mysql规则管理-历史信息(暂时废弃)
SDK方法名:describeHistory
URL
/stream/rule/history
Method
POST
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
mysql_uuid | String | 否 | @guid | ||
start_time | String | 否 | 开始时间 | 2019-10-11 14:23:13 | |
end_time | String | 否 | 2019-10-11 15:23:13 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
code | Number | 否 | 0 | ||
message | String | 否 | success | ||
info_list | Array | 否 | |||
host_name | String | 否 | @name | ||
work | String | 否 | 111 | ||
serial_num | String | 否 | 序号 | 222 | |
delay | String | 否 | 延时 | 333 | |
extract_delay | String | 否 | 抽取延时 | 444 |
mysql规则管理-资源占用(暂时废弃)
SDK方法名:describeResource
URL
/stream/rule/resouce
Method
POST
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
set_time | Number | 否 | 1 | ||
type | String | 否 | |||
interval | String | 否 | 时间间隔 | 1 | |
set_time_init | String | 否 | |||
rule_uuid | String | 否 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
code | Number | 否 | 0 | ||
message | String | 否 | |||
info_list | Array | 否 | |||
start_time | String | 否 | 2018/11/08 10:40:06 | ||
traffic | Number | 否 | 1 | ||
info_list_max | Array | 否 | |||
start_time | String | 否 | 2018/11/08 10:40:06 | ||
traffic | Number | 否 | 1 | ||
interval | Number | 否 | 5 | ||
uuid | String | 否 | |||
max | String | 否 | |||
min | String | 否 | |||
lastdate | String | 否 |
-----mysql表比较-----
URL
/stream/mysql
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
mysql-表比较-获取单个
SDK方法名:describeStreamCmp
URL
/stream/tb_cmp/:uuid([A-F0-9-]+)
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
uuid | String | 否 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
code | Number | 否 | 0 | ||
message | String | 否 | |||
stream_tb_cmp | Object | 否 | |||
table_cmp_name | String | 否 | ctt->ctt | ||
src_db_uuid | String | 否 | 4CA773F4-36E3-A091-122C-ACDFB2112C21 | ||
tgt_db_uuid | String | 否 | 40405FD3-DB86-DC8A-81C9-C137B6FDECE5 | ||
cmp_type | String | 否 | table, database | table | |
filter_table_settings | String | 否 | ["333.444"] | ||
tdb_tb_map | Array | 否 | |||
src_table | String | 否 | @name | ||
dst_table | String | 否 | @name | ||
src_db | String | 否 | @name | ||
dst_db | String | 否 | @name | ||
dump_thd | Number | 否 | 1 | ||
rule_uuid | String | 否 | 3D7dFcd9-C176-d9ee-4FFB-f22bbd554929 | ||
policies | String | 否 | 1|00:09 | 1,2,3*1 | |
policy_type | String | 否 | periodic | ||
one_time | String | 否 | 2019-05-27 16:07:08 | ||
db_user_map | Array | 否 | |||
src_table | String | 否 | @name | ||
dst_table | String | 否 | @name | ||
concurrentTab | Array | ||||
try_split_part_table | Number |
mysql-表比较-新建
SDK 方法名:createStreamCmp
URL
/stream/tb_cmp
Method
POST
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
tb_cmp_name | String | 否 | 表比较的名称 | ctt->ctt | |
src_db_uuid | String | 否 | 4CA773F4-36E3-A091-122C-ACDFB2112C21 | ||
tgt_db_uuid | String | 否 | 40405FD3-DB86-DC8A-81C9-C137B6FDECE5 | ||
cmp_type | String | 否 | 映射类型 | table, database, user | |
db_user_map | Array | 否 | 用户映射 | {"CTT":"CTT"} | |
src_table | String | 否 | |||
dst_table | String | 否 | |||
filter_table | String | 否 | ["用户.表名"] | ||
db_tb_map | Array | 否 | 表映射 | 表映射 | |
src_table | String | 否 | |||
dst_table | String | 否 | |||
src_db | String | 否 | |||
dst_db | String | 否 | |||
dump_thd | Number | 否 | 抽取线程数 | 1 | |
rule_uuid | String | 否 | 规则uuid | @guid | |
polices | String | 否 | 运行策略 | "0|00:00 | |
policy_type | String | 否 | 策略类型 | one_time | |
try_split_part_table | Number | 否 | 0 | ||
concurrent_table | Array | 并发表 | |||
one_time | String | ||||
repair | Number | ||||
fix_related | Number |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 | ||
uuid | String | @uuid |
mysql-表比较-删除
SDK方法名:deleteStreamRules
URL
/stream/tb_cmp
Method
DELETE
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
uuids | Array | 否 | @guid | 1 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 |
mysql-表比较-获取规则列表
SDK方法名:listStreamCmps
URL
/stream/tb_cmp
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
page | Number | 否 | 1 | ||
limit | Number | 否 | 10 | ||
search_field | String | 否 | |||
search_value | String | 否 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
code | Number | 否 | 0 | ||
total | Number | 否 | 5 | ||
info_list | Array | 否 | |||
create_time | String | 否 | 2019-06-21 14:33:24 | ||
tb_cmp_name | String | 否 | @name | ||
src_db_uuid | String | 否 | 4CA773F4-36E3-A091-122C-ACDFB2112C21 | ||
tgt_db_uuid | String | 否 | 40405FD3-DB86-DC8A-81C9-C137B6FDECE5 | ||
user_uuid | String | 否 | 1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC | ||
tb_cmp_uuid | String | 否 | C038DE5A-CDB2-F26D-FA5F-93E3FF266A87 | ||
tgt_db_name | String | 否 | bei | ||
tgt_type | String | 否 | 目标类型123 | ||
is_biz_admin | Number | 否 | 1 | ||
can_op | Number | 否 | 1 | ||
can_up | Number | 否 | 1 | ||
can_del | Number | 否 | 1 | ||
src_db_name | String | 否 | yuan | ||
policy_type | String | ||||
message | String | 否 |
mysql-表比较-状态接口
SDK方法名:listStreamCmpStatus
URL
/stream/tb_cmp/status
Method
POST
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
uuids | Array | 否 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
code | Number | 否 | 0 | ||
message | String | 否 | |||
info_list | Array | 否 | |||
cmp_uuid | String | 否 | C038DE5A-CDB2-F26D-FA5F-93E3FF266A87 | ||
wSt | Object | 否 | |||
status | String | 否 | ABNORMAL | ||
error_code | String | 否 | 4017 | ||
bSt | Object | 否 | |||
status | String | 否 | DUMP | ||
progress | String | 否 | 80 |
mysql-表比较-操作
SDK方法名:
停止:cmpStopStreamCmp;
重启:cmpRestartStreamCmp;
URL
/stream/tb_cmp/operate
Method
POST
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
tb_cmp_uuids | String | 否 | @guid | ||
operate | String | 否 | cmp_stop | cmp_restart |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 |
mysql-表比较-比较结果的删除
SDK方法名:deleteCmpResult
URL
/stream/tb_cmp/result_time_list
Method
DELETE
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
time_list | String | 否 | @guid | ||
uuid | String | 否 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 |
mysql-表比较-比较结果的查看
SDK方法名:listCmpResult
URL
/stream/tb_cmp/result_time_list
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
uuid | String | 否 | |||
limit | String | 否 | |||
offset | String | 否 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
code | Number | 否 | 0 | ||
message | String | 否 | |||
time_list | Array | 否 | |||
show_time | String | 否 | 2019-07-05 17:35:13 | ||
summary | Object | 否 | |||
total | Number | 否 | 999 | ||
use_time | Number | 否 | 777 | ||
diff | Number | 否 | 444 | ||
time | String | 否 | 2019-07-05_17-35-13 |
mysql表比较-比较任务结果
SDK方法名:describeTbCmpResult
URL
/stream/tb_cmp/result
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
page | Number | 否 | 1 | ||
limit | Number | 否 | 10 | ||
search_field | String | 否 | |||
search_value | String | 否 | |||
uuid | String | 否 | @guid | ||
start_time | String | 否 | 对应的时间 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 | ||
head_info | Object | 否 | |||
total | Number | 否 | 100 | ||
err | Number | 否 | 10 | ||
end | String | 否 | 2019-10-10 12:00:00 | ||
start | String | 否 | 2019-10-10 10:00:00 | ||
use_time | String | 否 | 3600 | ||
result_info | Object | 否 | |||
rows | Array | 否 | 10 | ||
src_user | String | 否 | user | ||
src_table_name | String | 否 | Anna Martin | ||
src | String | 否 | Cynthia Gonzalez | ||
dst | String | 否 | Robert Johnson | ||
diif_msg | String | 差异描述 | |||
total | Number | 否 | 30 |
mysql-表比较-查看单条
SDK方法名:describeStreamCmp
URL
/stream/result_fix_list
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
time_list | String | 否 | @guid | ||
uuid | String | 否 | |||
page | Number | 否 | 1 | ||
limit | Number | 否 | 10 | ||
search_field | String | 否 | |||
search_value | String | 否 | |||
uuid | String | 否 | @guid | ||
start_time | String | 否 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 | ||
time_list | Array | 否 | |||
db_name | String | 否 | 数据库名称 | @name | |
table_name | String | 否 | @name | ||
col_cmp | String | 否 | 列比较 | 111 | |
line_num | Number | 否 | 行数 | 222 | |
content | String | 否 | 内容 | 333 | |
status | String | 否 | done:已修复,not_repaired:未修复 | not_repaired | |
total | Number | 否 | 15 | ||
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 | ||
head_info | Object | 否 | |||
total | Number | 否 | 100 | ||
err | Number | 否 | 10 | ||
end | String | 否 | 2019-10-10 12:00:00 | ||
start | String | 否 | 2019-10-10 10:00:00 | ||
use_time | String | 否 | 3600 | ||
result_info | Object | 否 | |||
rows | Array | 否 | |||
db_name | String | 否 | Donald Miller | ||
table_name | String | 否 | Joseph Walker | ||
col_cmp | String | 否 | 111 | ||
line_num | Number | 否 | 222 | ||
content | String | 否 | 333 | ||
status | String | 否 | not_repaired | ||
total | Number | 否 | 10 |
mysql-表比较-单条错误信息
SDK方法名:describeCmpErrorMsg
URL
/stream/tb_cmp/error_msg
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
offset | Number | 否 | 1 | ||
limit | Number | 否 | 10 | ||
search_field | String | 否 | |||
search_value | String | 否 | |||
uuid | String | 否 | @guid | ||
start_time | String | 否 | |||
name | String | 否 | |||
owner | String | 否 | admin |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 | ||
result_info | Object | 否 | |||
rows | Array | 否 | |||
src_row | String | 否 | @name | ||
dst_row | String | 否 | @name | ||
total | Number | 否 | 10 |
比较结果列表的修复
SDK方法名:listFixResult
URL
/stream/result_fix_list
Method
POST
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
uuid | String | 否 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 |
比较结果列表的导出
SDK方法名:exportCmpResult
URL
/stream/export
Method
POST
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
uuid | String | 否 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 |
历史结果中的修复
SDK方法名:listCmpDiffMap
URL
/stream/tb_cmp/diff_map
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
uuid | String | 否 | |||
time | String | 否 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 | ||
result_info | Array | 否 | ['LIU.YI','LIU.ER'] |
======分割线=========
分割下所有的接口都暂时弃用
URL
/分割下所有的接口都暂时弃用
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
备机接管-新建
SDK方法名:createBkTakeover
URL
/stream/bk_takeover
Method
POST
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
mysql_uuid | String | 否 | @guid | ||
start_val | Number | 否 | 1000 | ||
scan_ip | Array | 否 | ["c01D7F86-A631-b79f-E2AA-7ccb7f2bE851","c01D7F86-A631-b79f-E2AA-7ccb7f2bE851","c01D7F86-A631-b79f-E2AA-7ccb7f2bE851"] | ||
hosts | Array | 否 | |||
ip | String | 否 | 192.168.12.200 | ||
password | String | 否 | |||
use_ip_sw | Number | 否 | 1 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 |
备机接管-查看
SDK方法名:describeBkTakeover
URL
/stream/bk_takeover/:uuid([A-F0-9-]+)
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
code | Number | 否 | 0 | ||
message | String | 否 | [0] success | ||
active_bk_takeover | Object | 否 | |||
id | String | 否 | 2 | ||
user_uuid | String | 否 | 1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC | ||
random_str | String | 否 | CDA58D92-C0F9-32C8-3BFA-065F0BA17CB4 | ||
create_time | String | 否 | 1564385400 | ||
bk_takeover_uuid | String | 否 | 0A20B300-8B41-2573-E5CA-A1CB57C0CADF | ||
mysql_uuid | String | 否 | E2Dd563c-cD1e-2dd2-8B8B-68beFFEc49cC | ||
start_val | String | 否 | 1000 | ||
scan_ip | Array | 否 | |||
hosts | Array | 否 | |||
use_ip_sw | String | 否 | 0 |
备机接管-删除
SDK方法名:deleteBkTakeover
URL
/stream/bk_takeover
Method
DELETE
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
uuids | Array | 否 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 1 |
备机接管-接管结果
SDK方法名:listTakeoverResult
URL
/stream/bk_takeover/result
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
bk_takeover_uuid | String | 否 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 | ||
result_info | Object | 否 | |||
seq_err | Array | 否 | |||
username | String | 否 | @name | ||
seq_name | String | 否 | @name | ||
tri_err | Array | 否 | |||
username | String | 否 | @name | ||
tri_name | String | 否 | @name | ||
takeover_obj | Array | 否 | |||
username | String | 否 | @name | ||
seq_num | Number | 否 | 10 | ||
seq_err_num | Number | 否 | 11 | ||
tri_num | String | 否 | @name | ||
tri_err_num | Number | 否 | 10 |
备机接管-操作
SDK方法名:{operate}Takeover
URL
/stream/bk_takeover/operate
Method
POST
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
bk_takeover_uuids | String | 否 | @guid | ||
operate | String | 否 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 1 |
备机接管-获取状态
SDK方法名:listTakeoverStatus
URL
/stream/bk_takeover/status
Method
POST
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
uuids | Array | 否 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
code | Number | 否 | 0 | ||
message | String | 否 | [0] success | ||
info_list | Array | 否 | |||
bk_takeover_uuid | String | 否 | 3211BF7E-D9B2-1259-5C2A-264DAC3E26DC | ||
wSt | Object | 否 | |||
progress | String | 否 | ABNORMAL | ||
status | String | 否 | ABNORMAL | ||
bSt | Object | 否 | |||
progress | String | 否 | DONE | ||
status | String | 否 | DONE |
备机接管列表
SDK方法名:listTakeoverList
URL
/stream/bk_takeover
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 | ||
total | Number | 否 | 20 | ||
info_list | Array | 否 | |||
create_time | String | 否 | 2019-10-10 10:10:10 | ||
rule_name | String | 否 | @name | ||
bk_takeover_uuid | String | 否 | 3211BF7E-D9B2-1259-5C2A-264DAC3E26DC | ||
can_op | Number | 否 | 1 | ||
can_up | Number | 否 | 1 | ||
can_del | Number | 否 | 1 | ||
is_biz_admin | Number | 否 | 1 |
--------对象修复------
URL
/mysql对象修复
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
mysql-对象修复-新建
SDK方法名:createObjFix
URL
/stream/obj_fix
Method
POST
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
obj_fix_name | String | 否 | test | ||
src_db_uuid | String | 否 | 4CA773F4-36E3-A091-122C-ACDFB2112C21 | ||
tgt_db_uuid | String | 否 | 40405FD3-DB86-DC8A-81C9-C137B6FDECE5 | ||
rule_uuid | String | 否 | 751A03F5-C97D-645B-82B2-316A5D198528 | ||
obj_map | String | 否 | type对应类型值如下:INDEX->索引,VIEW->视图,FUNCTION->函数,PROCEDURE->存储过程,PACKAGE->包头 PACKAGE BODY->包体,SYNONYM->同义词,TRIGGER->触发器, SEQUENCE->序列,JAVA SOURCE->JAVA源,JAVA CLASS->JAVA类,JAVA RESOURCE->JAVA资源,TYPE->类型,TYPE BODY->类型体,QUEUE->队列,MATERIALIZED VIEW->物化视图,DATABASE LINK->DBLINK,OLD JOB->JOB,JOB->SCH JOB,PRIVS->权限,CONSTRAINT->约束. owner和name 用逗号连接并且 均加密 | [{"type":"owner.name"}] | 2 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 |
对象修复 - 获取单个
SDK方法名:describeObjFix
URL
/stream/obj_fix/:uuid([A-F0-9-]+)
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
uuid | String | 否 | 规则uuid | @guid |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 | ||
active_obj_fix | Object | 否 | |||
obj_fix_name | String | 否 | test | ||
src_db_uuid | String | 否 | 4CA773F4-36E3-A091-122C-ACDFB2112C21 | ||
tgt_db_uuid | String | 否 | 40405FD3-DB86-DC8A-81C9-C137B6FDECE5 | ||
obj_fix_uuid | String | 否 | 751A03F5-C97D-645B-82B2-316A5D198528 | ||
obj_map | String | 否 | json 字符串 | [{"INDEX":"owner.name"}] |
mysql-对象修复 -删除
SDK方法名:deleteObjFix
URL
/stream/obj_fix
Method
DELETE
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
uuids | Array | 否 | 数组 | @guid |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 | ||
obj_fix_uuid | String | @uuid |
mysql-对象修复 - 列表
SDK方法名:listObjFix
URL
/stream/obj_fix
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
page | Number | 否 | 1 | ||
limit | Number | 否 | 10 | ||
search_field | String | 否 | |||
search_value | String | 否 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
code | Number | 否 | 0 | ||
total | Number | 否 | 20 | ||
info_list | Array | 否 | 6 | ||
create_time | String | 否 | 1593511163 | ||
obj_fix_uuid | String | 否 | C038DE5A-CDB2-F26D-FA5F-93E3FF266A87 | ||
obj_fix_name | String | 否 | test | ||
src_db_uuid | String | 否 | 4CA773F4-36E3-A091-122C-ACDFB2112C21 | ||
tgt_db_uuid | String | 否 | 40405FD3-DB86-DC8A-81C9-C137B6FDECE5 | ||
user_uuid | String | 否 | 1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC | ||
src_db_name | String | 否 | yuan | ||
tgt_db_name | String | 否 | bei | ||
username | String | 否 | admin | ||
policy_type | String | immediate; one_time;periodic | immediate | ||
message | String | 否 |
mysql对象修复-操作
SDK方法名:{operate}ObjFix;重新修复
URL
/stream/obj_fix/operate
Method
POST
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
obj_fix_uuids | Array | 否 | 规则uuid | @guid | |
operate | String | 否 | restart | stop |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 |
对象修复 - 修复结果
SDK方法名:describeObjFixResult
URL
/stream/obj_fix/result
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
uuid | String | 否 | @guid |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 | ||
info_list | Array | 否 | |||
obj_fix_type | String | 否 | 索引 | ||
status | String | 否 | 修复状态 | on | |
owner | String | 否 | 所有者 | @name | |
name | String | 否 | 名称 | @name | |
head_info | Object | 否 | |||
obj_fix_name | String | 否 | @name |
mysql对象修复--获取状态
SDK方法名:listObjFixStatus
URL
/stream/obj_fix/status
Method
POST
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
uuids | Array | 否 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
code | Number | 否 | 0 | ||
message | String | 否 | |||
info_list | Array | 否 | |||
wSt | Object | 否 | |||
status | String | 否 | TRACK | ||
progress | Number | 否 | 1 | ||
bSt | Object | 否 | |||
status | String | 否 | DUMP | ||
progress | String | 否 | 80 | ||
obj_fix_uuid | String | 否 | C038DE5A-CDB2-F26D-FA5F-93E3FF266A87 |
-----对象比较-----
URL
/mysql对象比较
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
mysql对象比较 - 新建
SDK方法名:createObjCmp
URL
/stream/obj_cmp
Method
POST
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
obj_cmp_name | String | 否 | 对象比较名称 | test | |
src_db_uuid | String | 否 | 源端数据库uuid | 4CA773F4-36E3-A091-122C-ACDFB2112C21 | |
tgt_db_uuid | String | 否 | 备端数据库uuid | 40405FD3-DB86-DC8A-81C9-C137B6FDECE5 | |
cal_table_recoders | Number | 否 | 是否对比表的记录数 | 1 | |
rule_uuid | String | 否 | 同步规则uuid | 751A03F5-C97D-645B-82B2-316A5D198528 | |
cmp_type | String | 否 | 类型 | user | |
db_user_map | String | 否 | 用户映射 | {'src_user':'dst_user'} | |
policies | String | 否 | |||
policy_type | String | 否 | periodic | ||
one_time | String | 否 | 2019-05-27 16:07:08 | ||
repair | Number | 否 | 1 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 | ||
obj_cmp_uuid | String | @uuid |
mysql对象比较 - 列表
SDK方法名:listObjCmp
URL
/stream/obj_cmp
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
page | Number | 否 | 1 | ||
limit | Number | 否 | 10 | ||
search_field | String | 否 | |||
search_value | String | 否 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
code | Number | 否 | 0 | ||
total | Number | 否 | 20 | ||
info_list | Array | 否 | 16 | ||
create_time | String | 否 | 1593511163 | ||
obj_cmp_uuid | String | 否 | C038DE5A-CDB2-F26D-FA5F-93E3FF266A87 | ||
obj_cmp_name | String | 否 | test | ||
src_db_uuid | String | 否 | 3D7dFcd9-C176-d9ee-4FFB-f22bbd554926 | ||
tgt_db_uuid | String | 否 | 3D7dFcd9-C176-d9ee-4FFB-f22bbd554925 | ||
cmp_type | String | 否 | user | ||
user_uuid | String | 否 | 1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC | ||
src_db_name | String | 否 | yuan | ||
tgt_db_name | String | 否 | bei | ||
username | String | 否 | admin | ||
can_op | Number | 否 | 1 | ||
can_up | Number | 否 | 1 | ||
can_del | Number | 否 | 1 | ||
message | String | 否 |
mysql对象比较-比较结果的删除
SDK方法名:describeObjCmpResultTimeList
URL
/stream/obj_cmp/result_time_list
Method
DELETE
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
uuid | String | 否 | @guid | ||
time_list | Array | 否 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 |
mysql对象比较 - 获取单个
SDK方法名:describeObjCmp
URL
/stream/obj_cmp/:uuid([A-F0-9-]+)
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
active_obj_cmp | Object | 否 | |||
obj_cmp_uuid | String | 否 | |||
obj_cmp_name | String | 否 | test | ||
src_db_uuid | String | 否 | 4CA773F4-36E3-A091-122C-ACDFB2112C21 | ||
tgt_db_uuid | String | 否 | 40405FD3-DB86-DC8A-81C9-C137B6FDECE5 | ||
rule_uuid | String | 否 | 751A03F5-C97D-645B-82B2-316A5D198528 | ||
cmp_type | String | 否 | user | ||
cal_table_recoders | Number | 否 | 1 | ||
db_user_map | String | 否 | {"user1":"user1"} | ||
policies | String | 否 | 1|00:09 | 1,2,3*1 | |
policy_type | String | 否 | periodic | ||
one_time | String | 否 | 2019-05-27 16:07:08 | ||
repair | Number | 否 | 1 | ||
message | String | 否 | |||
code | Number | 否 | 0 |
mysql对象比较-比较结果时间列表
SDK方法名:listObjCmpResultTimeList
URL
/stream/obj_cmp/result_time_list
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
uuid | String | 否 | @guid |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
code | Number | 否 | 0 | ||
message | String | 否 | |||
time_list | Array | 否 | 16 | ||
show_time | String | 否 | 2019-07-05 17:35:13 | ||
summary | Object | 否 | |||
diff | Number | 否 | 1-100 | ||
time | String | 否 | 2019-07-05_17-35-13 | ||
total | Number | 否 | 20 |
mysql对象比较 - 删除
SDK方法名:deleteObjCmp
URL
/stream/obj_cmp
Method
DELETE
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
uuids | Array | 否 | ["11111111-1111-1111-1111-111111111111"] |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 |
mysql对象比较 - 操作
SDK方法名:{operate}ObjCmp
URL
/stream/obj_cmp/operate
Method
POST
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
mysql获取对象比较状态
SDK方法名:listObjCmpStatus
URL
/stream/obj_cmp/status
Method
POST
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
uuids | Array | 否 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
code | Number | 否 | 0 | ||
message | String | 否 | |||
info_list | Array | 否 | |||
cmp_uuid | String | 否 | C038DE5A-CDB2-F26D-FA5F-93E3FF266A87 | ||
wSt | Object | 否 | |||
status | String | 否 | TRACK | ||
progress | Number | 否 | |||
bSt | Object | 否 | |||
status | String | 否 | DUMP | ||
progress | String | 否 | 80 |
mysql对象比较-比较结果详细信息
SDK方法名:listObjCmpCmpInfo
URL
/stream/obj_cmp/cmp_info
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
offset | Number | 否 | 1 | ||
limit | Number | 否 | 10 | ||
search_value | String | 否 | |||
usr | String | 否 | I2 | ||
filed | String | 否 | |||
uuid | String | 否 | |||
start_time | String | 否 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 | ||
info_list | Object | 否 | |||
total | Number | 否 | 2000 | ||
rows | Array | 否 | |||
src | String | 否 | 1111 | ||
dst | String | 否 | 2222 | ||
cal_table_recoders | Boolean | 否 | 是否比较表的记录 | false |
mysql对象比较-比较任务结果
SDK方法名:describeObjCmpResult
URL
/stream/obj_cmp/result
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
uuid | String | 否 | @guid | ||
start_time | String | 否 | |||
limit | Number | 否 | |||
offset | String | 否 | |||
search_value | String | 否 | |||
BackLackOnly | Number | 否 | 0 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
code | Number | 否 | 0 | ||
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 | ||
result_info | Object | 否 | |||
total | Number | 否 | 20 | ||
rows | Array | 否 | |||
CONSTRAINT | String | 否 | 1/1__1 | ||
DATABASE LINK | String | 否 | 0/0__1 | ||
FUNCTION | String | 否 | 0/0__1 | ||
INDEX | String | 否 | 4/5__0 | ||
JAVA CLASS | String | 否 | 0/0__1 | ||
JAVA RESOURCE | String | 否 | 0/0__1 | ||
JAVA SOURCE | String | 否 | 0/0__1 | ||
JOB | String | 否 | 0/0__1 | ||
MATERIALIZED VIEW | String | 否 | 0/0__1 | ||
OLD JOB | String | 否 | 0/0__1 | ||
PACKAGE | String | 否 | 0/0__1 | ||
PACKAGE BODY | String | 否 | 0/0__1 | ||
PRIVS | String | 否 | 9/8__0 | ||
PROCEDURE | String | 否 | 0/0__1 | ||
QUEUE | String | 否 | 0/0__1 | ||
SEQUENCE | String | 否 | 0/0__1 | ||
SYNONYM | String | 否 | 0/0__1 | ||
TABLE | String | 否 | 18/19__0 | ||
TABLE PARTITION | String | 否 | 0/0__1 | ||
TRIGGER | String | 否 | 0/0__1 | ||
TYPE | String | 否 | 0/0__1 | ||
TYPE BODY | String | 否 | 0/0__1 | ||
VIEW | String | 否 | 2/2__1 | ||
usr | String | 否 | I2/I2 | ||
head_info | Object | 否 | |||
obj_cmp_name | String | 否 | Michelle Lewis |
-----mysql 表修复------
URL
/mysql 表修复
Method
GET
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
mysql-表修复-新建
SDK方法名:createStreamTableFix
URL
/stream/tb_cmp/table_fix
Method
POST
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
rule_uuid | String | 否 | @guid | ||
tab | Array | 否 | |||
fix_relation | Number | 否 | 0 |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|---|---|---|---|---|
ret | Number | 否 | 200 | ||
msg | String | 否 | |||
data | Object | 否 | |||
message | String | 否 | |||
code | Number | 否 | 0 |