MongoDB同步

SDK类名：/active/MongoDB;

同步规则 - 新建

SDK方法名：createMongoRule

URL

/mongo/rule

Method

POST

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

名称	类型	必选	简介	Mock初始值	Mock规则

同步规则 - 修改

SDK方法名：modifyMongoRule

URL

/mongo/rule/:uuid([A-F0-9-]+)

Method

PUT

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

/mongo/rule

Method

DELETE

Request

名称	类型	必选	简介	Mock初始值	Mock规则
uuids	Array
force	String			true

Response

名称	类型	必选	简介	Mock初始值	Mock规则
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方法名： 继续：resumeMongoRule; 停止：stopMongoRule; 重启：restartMongoRule

URL

/mongo/rule/operate

Method

POST

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方法名：listRule

URL

/mongo/rule

Method

GET

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/:uuid([A-F0-9-]+)

Method

GET

Request

名称	类型	必选	简介	Mock初始值	Mock规则

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