Qianbase同步

SDK类名：/active/QianBaseSync;

同步规则 - 列表

SDK方法名：listQianbaseRule

URL

/qianbase/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	否
status	String
src_db_name	String
tgt_db_name	String
db_ip	String
node_ip	String
username	String
rule_name	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			["Ronal","Melissa"]	+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
can_del	Number
can_op	Number
can_up	Number
message	String
code	Number			0

同步规则 - 新建

SDK方法名：createQianbaseRule

URL

/qianbase/rule

Method

POST

Request

名称	类型	必选	简介	Mock初始值	Mock规则
rule_name	String			test
src_db_uuid	String			7B1BE386-4CB1-86AA-D39D-B644C2EADD57
map_type	String			table
config	Object
start_rule_now	Number			1
db_set	Array
tgt_db_uuid	String			CD52E44B-D25A-4CE3-126F-6F5A460731E4
filter_type	Number			[1:filter_table,0:no_fileter]
table_map	Array
src_table	String
dst_table	String
custom_config	Array
key	String
value	String
tgt_type	String
all_custom_config	Array
key	String
value	String
sync_content	Array
sync_col	String
jointing	Object		字段拼接
table	String
op	String		操作 op类型定义 前辍 prefix 后辍 append 常量 const 拼接 join 加 add 减 sub 乘 multiply 除 divide
content	String		目标列+其他两行
save_json_text	String		【目标类型为Kafka】保存为文件
kafka_db_uuid	String		kafka消息引擎
conn_num	Number		数据库最大连接数
loader	Number		并发装载数
schema_name	String		同步的Schema名

Response

名称	类型	必选	简介	Mock初始值	Mock规则
ret	Number			200
msg	String
data	Object
code	Number			0
message	String			success

同步规则 - 修改

SDK方法名：modifyQianbaseRule

URL

/qianbase/rule

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	Array	否
full_sync	Number	否		0
incre_sync	Number	否
full_sync_mode	String	否		1
db_user_map	String
dbmap_topic	String
row_map_mode	String
kafka_time_out	String
part_load_balance	String
kafka_message_encoding	String
db_set	Array
tgt_db_uuid	String
filter_type	String
tgt_type	String
table_map	Array
src_table	String
dst_table	String
custom_config	Array
key	String
value	String
all_custom_config	Array
key	String
value	String
sync_content	Array
sync_col	String
rule_uuid	String

Response

名称	类型	必选	简介	Mock初始值	Mock规则
ret	Number	否		200
msg	String	否
data	Object	否
code	Number	否		0
message	String	否		success

同步规则 - 删除

SDK方法名：deleteQianbaseRule

URL

/qianbase/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方法名：listQianbaseStatus

URL

/qianbase/rule/status

Method

GET

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
peak	Number		峰值	2	10
delay	Number		延迟	2	110
extract	String		解析时间	2019-06-25 11:26:19
load	String			2019-06-25 11:26:19
stage	String		pause: 停止 dump: 全量 track:增量 done:完成 offline:离线	done
state	Number		错误码：0 正常 非0 错误码	0
progress	String		进度	80	80
scheduleState	String		ACTIVE_RULE_SCHEDULING：调度中 ACTIVE_RULE_STOP_SCHEDUL:停止调度

同步规则 - 操作

SDK方法名： 继续：resumeQianbaseRule; 停止：stopQianbaseRule; 重启：restartQianbaseRule

URL

/qianbase/rule/operate

Method

POST

Request

名称	类型	必选	简介	Mock初始值	Mock规则
operate	String		resume | stop （暂时只保留这两个） 暂时弃（	restart	stop_schedule 停止调度 start_schedule 启动调度 start_analysis 开始解析 stop_analysis 停止解析 reset_analysis 重置解析）
uuids	Array
scn	String

Response

名称	类型	必选	简介	Mock初始值	Mock规则
ret	Number			200
msg	String
data	Object
code	Number			0
message	String			success

qianbase日志

SDK方法名：listQianbaseRuleLog

URL

/qianbase/rule/log

Method

POST

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

qianbase 表比较

URL

/========qianbase表比较======

Method

GET

Request

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

Response

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

qianbase获取单个信息

SDK方法名：describeQianbaseRules

URL

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

Method

GET

Request

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

Response

名称	类型	必选	简介	Mock初始值	Mock规则
ret	Number	是		200
msg	String	否
data	Object	否
message	String	否
code	Number	否		0
qianbase_rule	Object	否
rule_name	String	否		postgres->kafka
src_db_uuid	String	否		1111
tgt_db_uuid	String	否		2222
tgt_type	String	否		kafka
map_type	String			database
config	Object
start_rule_now	Number			1
table_map	String			[{"src_user":"111","src_table":"222","dst_user":"333","dst_table":"444","column":[]}]
full_sync	Number			1
incre_sync	Number	否		1
full_sync_mode	String			logic
db_user_map	String			{"111":"1112"}
dbmap_topic	String			111
row_map_mode	String			rowid
kafka_time_out	String			1200000
part_load_balance	String			by_table
kafka_message_encoding	String			UTF-8
rule_uuid	String			@uuid

qianbase表比较 - 新建

SDK方法名：createQbTbCmp

URL

/qianbase/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	否		user,table,db
db_user_map	String	否		{"CTT":"CTT"}
filter_table	Array	否		[用户.表名]
db_tb_map	String	否		表映射
dump_thd	Number	否	抽取线程数
rule_uuid	String	否		@guid
polices	String	否	策略	"0|00:00
policy_type	String	否	策略类型;periodic(周期) ，one_time 一次性任务 immediate 立刻执行	one_time
concurrent_table	Array	否	并发表	["hh.ww"]
try_split_part_table	Number	否	尝试并发设置 0:否 1：是	0
one_time	String	否	策略的开始时间，如果不是一次性任务为空值	2019-05-27 16:07:08
repair	Number	否		0
fix_related	Number	否		0
config	Object
tab_cmp_filter	Array
user	String			test
table	String			test
condition	String			select * from xxx

Response

名称	类型	必选	简介	Mock初始值	Mock规则
ret	Number	否		200
msg	String	否
data	Object	否
message	String	否
code	Number	否

qianbase状态接口

SDK方法名：listQbTbCmpStatus;状态接口

URL

/qianbase/tb_cmp/status

Method

GET

Request

名称	类型	必选	简介	Mock初始值	Mock规则
uuids	Array	否		@guid

Response

名称	类型	必选	简介	Mock初始值	Mock规则
ret	Number	否		200
msg	String	否
data	Object	否
code	Number	否		0
message	String	否
info_list	Array	否			2
extract	String	否	解析时间	2019-06-25 11:26:19
cmp_uuid	String	否		@guid
peak	String	否	峰值	100
dst_state	Object	否	目标端
status	String	否	目标端状态	OFFLINE
delay	String	否	延迟	10
load	String	否	装载时间	2019-06-23 20:23:18
work_state	Object	否	同步规则对应导出，其他规则对应源机
status	String	否	状态	ABNORMAL
error_code	String	否	错误码	4017
src_state	Object	否	源端
status	String	否		ONLINE
back_state	Object	否
status	String	否		DUMP
progress	String	否		80
relay_state	Object	否	装载
status	String	否		TRACK
track_state	Object	否	解析
status	String	否		UNKNOWN

qianbase表比较 - 获取单个

SDK方法名：describeQbTbCmp

URL

/qianbase/tb_cmp/:uuid([A-F0-9-]+)

Method

GET

Request

名称	类型	必选	简介	Mock初始值	Mock规则
uuid	String	否	表比较规则的uuid	@guid

Response

名称	类型	必选	简介	Mock初始值	Mock规则
src_db_uuid	String	否		4CA773F4-36E3-A091-122C-ACDFB2112C21
ret	Number	否		200
msg	String	否
data	Object	否
code	Number	否		0
message	String	否
qianbase_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	否		user
db_user_map	String	否		{"CTT":"CTT"}
filter_table_settings	String	否		[用户.表名]
db_tb_map	String	否		表映射
dump_thd	Number	否		1
rule_uuid	String	否		5DA7469c-b5d5-Bd53-5ADB-7Eee6D31e60B
policies	String	否		1|00:09	1,2,3*1
policy_type	String	否		periodic
concurrentTab	Array	否		["hh.ww"]
try_split_part_table	Number	否		0
one_time	String	否		2019-05-27 16:07:08

qianbase表比较 - 删除

SDK方法名：deleteQbTbCmp

URL

/qianbase/tb_cmp

Method

DELETE

Request

名称	类型	必选	简介	Mock初始值	Mock规则
uuids	Array	否		@guid
force	Boolean			false

Response

名称	类型	必选	简介	Mock初始值	Mock规则
ret	Number	否		200
msg	String	否
data	Object	否
message	String	否
code	Number	否		0
success_list	Array
code	String
message	String
tb_cmp_name	String
tb_cmp_uuid	String
fail_list	Array
code	String
message	String
tb_cmp_name	String
tb_cmp_uuid	String

qianbase表比较 - 列表

SDK方法名：listQbTbCmp

URL

/qianbase/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	否		20
info_list	Array	否
create_time	String	否		1593511163
tb_cmp_name	String	否		name321
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
username	String	否		admin
can_op	Number	否		1
can_up	Number	否		1
can_del	Number	否		1
is_biz_admin	Number	否		1
src_db_name	String	否		yuan
policy_type	String		immediate; one_time;periodic	immediate
message	String	否

qianbase 历史结果

SDK方法名：listQbTbCmpResultTimeList

URL

/qianbase/tb_cmp/result_time_list

Method

GET

Request

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

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	否
total	Number	否		1192
use_time	Number	否		844
diff	Number	否		130
time	String	否		2019-07-05_17-35-13
total	Number	否		20

qianbase表比较-操作

SDK方法名：

停止：stopQbTbCmp;

重启：restartQbTbCmp;

URL

/qianbase/tb_cmp/operate

Method

POST

Request

名称	类型	必选	简介	Mock初始值	Mock规则
tb_cmp_uuids	Array	否		@guid
operate	String	否	cmp_stop | cmp_restart

Response

名称	类型	必选	简介	Mock初始值	Mock规则
ret	Number	否		200
msg	String	否
data	Object	否
message	String	否
code	Number	否		0

qianbase表比较-比较结果的删除

SDK方法名：describeQbTbCmpResuluTimeList;查看结果删除

URL

/qianbase/tb_cmp/result_time_list

Method

DELETE

Request

名称	类型	必选	简介	Mock初始值	Mock规则
uuid	String	否
time_list	Array	否		@guid

Response

名称	类型	必选	简介	Mock初始值	Mock规则
ret	Number	否		200
msg	String	否
data	Object	否
message	String	否
code	Number	否		0

qianbase表比较-比较任务结果

SDK方法名：describeQbTbCmpResult

URL

/qianbase/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
total	Number	否		30

qianbase表比较-错误信息

SDK方法名：describeQbTbCmpErrorMsg;错误信息

URL

/qianbase/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	否			10
src_row	String	否		@name
dst_row	String	否		@name
total	Number	否		2000

qianbase表比较-比较结果

SDK方法名：describeQbTbCmpCmpResult

URL

/qianbase/tb_cmp/cmp_result

Method

GET

Request

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

Response

名称	类型	必选	简介	Mock初始值	Mock规则
ret	Number	否		200
msg	String	否
data	Object	否
code	Number	否		0
message	String	否
summary	Object	否
total	Number	否		1192
use_time	Number	否		844
diff	Number	否		130