MongoDB同步
SDK类名:/active/MongoDB;
示例接口
示例接口描述
URL
Method
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
foo | String | | 请求属性示例 | @ctitle | |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
string | String | | 字符串属性示例 | ★ | 1-10 |
number | Number | | 数字属性示例 | 1 | 1-100 |
boolean | Boolean | | 布尔属性示例 | true | 1-2 |
regexp | RegExp | | 正则属性示例 | /[a-z][A-Z][0-9]/ | |
function | Function | | 函数属性示例 | () => Math.random() | |
array | Array | | 数组属性示例 | | 1-10 |
foo | Number | | 数组元素示例 | 1 | +1 |
bar | String | | 数组元素示例 | ★ | 1-10 |
items | Array | | 自定义数组元素示例 | [1, true, 'hello', /\w{10}/] | |
object | Object | | 对象属性示例 | | |
foo | Number | | 对象属性示例 | 1 | +1 |
bar | String | | 对象属性示例 | ★ | 1-10 |
placeholder | String | | 占位符示例 | @title | |
新建
SDK方法名:createMongoRule
URL
Method
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
rule_name | String | | | | |
src_db_uuid | String | | | | |
tgt_db_uuid | String | | | | |
tgt_type | String | | | sqlserver | |
map_type | String | | | db | |
config | Object | | | | |
start_rule_now | Number | | | 1 | |
table_map | String | | | | |
full_sync | Number | | | 0 | |
incre_sync | Number | | | 1 | |
kafka | Object | | | | |
binary_code | String | | hex | | |
kafka_time_out | String | | | | |
part_load_balance | String | | | | |
kafka_message_encoding | String | | | | |
dbmap_topic | String | | | | |
db_user_map | String | | | | |
Response
修改
SDK方法名:modifyMongoRule
URL
/mongo/rule/:rule_uuid([A-F0-9-]+)
Method
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
rule_name | String | 否 | | | |
src_db_uuid | String | 否 | | | |
tgt_db_uuid | String | 否 | | | |
tgt_type | String | 否 | | sqlserver | |
map_type | String | 否 | | db | |
config | Object | 否 | | | |
start_rule_now | Number | 否 | | 1 | |
table_map | String | 否 | | | |
full_sync | Number | 否 | | 0 | |
incre_sync | Number | 否 | | | |
kafka | Object | | 二进制数据编码方式 | | |
binary_code | String | | | | |
kafka_time_out | String | | 12000 | | |
part_load_balance | String | | 分区均衡策略 | | |
kafka_message_encoding | String | | utf-8 | | |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
ret | Number | 否 | | 200 | |
msg | String | 否 | | | |
data | Object | 否 | | | |
code | Number | 否 | | 0 | |
message | String | 否 | | success | |
删除
SDK方法名:deleteMongoRule
URL
Method
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
uuids | Array | | | | |
force | String | | | true | |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
ret | Number | | | 200 | |
msg | String | | | | |
data | Object | | | | |
code | Number | | | 0 | |
message | String | | | success | |
ret | Number | | | 200 | |
msg | String | | | | |
data | Object | | | | |
code | Number | | | 1 | |
message | String | | | [0] success | |
success_list | Array | | | | |
code | Number | | | 0 | |
message | String | | | [0] success | |
rule_uuid | String | | | 16CB63E1-13FA-FB32-EB49-D790682C9648 | |
rule_name | String | | | task1 | |
fail_list | Array | | | | |
code | Number | | | -1 | |
message | String | | | [-1] 找不到节点 | |
rule_uuid | String | | | 16CB63E1-13FA-FB32-EB49-D790682C9647 | |
rule_name | String | | | task2 | |
启/停/重新同步/继续
SDK方法名:{operate}MongoRules
URL
Method
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
operate | String | | resume | stop | restart | |
uuids | String | | | | |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
ret | Number | | | 200 | |
msg | String | | | | |
data | Object | | | | |
code | Number | | | 0 | |
message | String | | | success | |
规则-状态
SDK方法名:listMongoStatus
URL
Method
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
uuids | Array | 否 | | | |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
ret | Number | | | 200 | |
msg | String | | | | |
data | Object | | | | |
code | Number | | | 0 | |
message | String | | | [0] 操作成功。 | |
info_list | Array | | | | 2 |
rule_uuid | Array | | | ["6FBC9EB9-A10A-E226-9F2B-A77B3CF1D337","3BF809AF-4A2E-DD28-072E-530D33BAC189"] | +1 |
export_state | Object | | | | |
status | String | | | ACTIVE_RULE_DUMP | |
progress | String | | | 66 | |
load_state | Object | | | | |
status | String | | | ACTIVE_RULE_ABNORMAL | |
error_code | Number | | | -4014 | |
track_state | Object | | | | |
status | String | | | ACTIVE_RULE_STOP | |
error_code | Number | | | -4014 | |
日志
SDK方法名:listMongoRuleLog
URL
Method
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
offset | Number | 否 | | 0 | |
limit | Number | 否 | | 10 | |
date_start | String | 否 | | | |
date_end | String | 否 | | | |
type | Number | 否 | | 1 | |
module_type | Number | 否 | | 1 | |
query_type | Number | 否 | | 1 | |
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 | |
列表
SDK方法名:listRule
URL
Method
Request
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
page | Number | | | 1 | |
limit | Number | | | 10 | |
search_field | String | | | | |
search_value | String | | | | |
group_uuid | String | | | | |
where_args | Object | | | | |
rule_uuid | String | | | | |
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
ret | Number | | | 200 | |
msg | String | | | | |
data | Object | | | | |
total | Number | | | 5 | |
info_list | Array | | | | 2 |
rule_uuid | Array | | | ["6FBC9EB9-A10A-E226-9F2B-A77B3CF1D337","3BF809AF-4A2E-DD28-072E-530D33BAC189"] | +1 |
rule_name | Array | | | ["Ronald Lopez","Melissa Brown"] | +1 |
src_db_uuid | String | | | | |
tgt_db_uuid | String | | | | |
tgt_type | String | | | kafka | |
user_uuid | String | | | 1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC | |
tgt_db_name | String | | | bei | |
map_type | String | | | database | |
config | Object | | | | |
start_rule_now | Number | | | 1 | |
table_map | String | | | | |
full_sync | Number | | | 1 | |
incre_sync | Number | | | 1 | |
full_sync_mode | String | | | | |
db_user_map | Object | | | | |
dbmap_topic | String | | | | |
row_map_mode | String | | | | |
kafka_time_out | String | | | | |
part_load_balance | String | | | | |
kafka_message_encoding | String | | | | |
src_db_name | String | | | 1111 | |
is_biz_admin | Number | | | 1 | |
can_del | Number | | | 1 | |
can_op | Number | | | 1 | |
can_up | Number | | | 1 | |
rule_type | Number | | | 40 | |
message | String | | | | |
code | Number | | | 0 | |
获取单个规则
SDK方法名:describeListRule;
URL
/mongo/rule/:rule_uuid([A-F0-9-]+)
Method
Request
Response
名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
---|
ret | Number | | | 200 | |
msg | String | | | | |
data | Object | | | | |
message | String | | | success | |
code | Number | | | 0 | |
mongo_rule | Object | | | | |
rule_name | String | | | test | |
src_db_uuid | String | | | 7B1BE386-4CB1-86AA-D39D-B644C2EADD57 | |
tgt_db_uuid | String | | | CD52E44B-D25A-4CE3-126F-6F5A460731E4 | |
tgt_type | String | | | kafka | |
map_type | String | | | db | |
config | Object | | | | |
table_map | String | | | '[{"src_user":"11","src_table":"22","dst_user":"11","dst_table":"22","column":[]}]' | |
start_rule_now | Number | | | 1 | |
full_sync | Number | | | | |
incre_sync | Number | | | | |
kafka | Object | | | | |
kafka_time_out | String | | | | |
part_load_balance | String | | | | |
kafka_message_encoding | String | | | | |
dbmap_topic | String | | | | |
db_user_map | String | | | | |
rule_uuid | String | | | | |