PostgreSQL同步

SDK类名：/active/Postgres

同步规则 - 列表

SDK方法名：listPgsqlRule

URL

/pgsql/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
can_del	Number
can_op	Number
can_up	Number
message	String
code	Number			0

同步规则 - 新建

SDK方法名：createPgsqlRule

URL

/pgsql/rule

Method

POST

Request

名称	类型	必选	简介	Mock初始值	Mock规则
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			sqlserver
map_type	String		db：整库映射 inst：整实例映射 user：用户映射 table：表映射	table
config	Object
table_map	Array
src_user	String			1
src_table	String			2
dst_user	String			1
dst_table	String			2
column	Array
start_rule_now	Number			1
db_user_map	String
dbmap_topic	String
full_sync	Number			1
incre_sync	Number			1
full_sync_mode	String			logic
row_map_mode	String			rowid
kafka_time_out	String			120000
part_load_balance	String			by_table
kafka_message_encoding	String			UTF-8
dst_connect_user	String
src_connect_user	String
jointing	Object		字段拼接
table	String		表
op	String		操作 op类型定义 前辍 prefix 后辍 append 常量 const 拼接 join 加 add 减 sub 乘 multiply 除 divide
content	String		目标列+其他两行
save_json_text	Boolean		【目标类型为Kafka】保存为文件	false
full_sync_custom_cfg	Array		全局自定义配置
key	String
value	String
full_sync_settings	Object		全量设置
full_sync_custom_cfg	Array		全局自定义配置
key	String
value	String
dump_thd	String		全量导出线程数
load_thd	String		全量装载线程数
start_lsn	String		起始lsn
existing_table	String		表覆盖策略
end_db_map	Array
src_db	String
tar_db	String
end_tab_map	Array
dst_db	String
dst_table	String
src_db	String
src_table	String
column	Array
src_column	String
dst_column	String
end_target_type	String		最终目标库类型
end_target_db	String		最终目标库
table_msg_uuid	String		表元信息库
inc_sync_ddl_filter	Object		增量DDL过滤设置
inc_sync_ddl_data	Array
database_map	Array		整库映射信息
src_database	String		源端库
tgt_database	String		备端库
src_schema	String		源端模式
tgt_schema	String		备端模式

Response

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

同步规则 - 修改

SDK方法名：modifyPgsqlRule

URL

/pgsql/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	String	否
full_sync	Number	否		0
incre_sync	Number	否
full_sync_mode	String	否		1
rule_uuid	String

Response

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

同步规则 - 删除

SDK方法名：deletePgsqlRule

URL

/pgsql/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方法名： 继续：resumePgsqlRule; 停止：stopPgsqlRule; 重启：restartPgsqlRule；复制：duplicatePgsqlRule

URL

/pgsql/rule/operate

Method

POST

Request

名称	类型	必选	简介	Mock初始值	Mock规则
operate	String		resume | stop	restart stop_schedule 停止调度 start_schedule 启动调度 start_analysis 启动解析 stop_analysis 停止解析 reset_analysis 重置解析 duplicate 复制
uuids	String
scn	String		起始scn
all	Number		只有在重置装载时才有此值

Response

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

同步规则 - 获取单个

SDK方法名：describePgsqlRules

URL

/pgsql/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
postgres_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