批量设置同步策略

project_id

是

String

租户在某一Region下的Project ID。

获取方法请参见获取项目ID。

Content-Type

是

String

指定类型为application/json。

缺省值：application/json

X-Auth-Token

是

String

从IAM服务获取的用户Token。

X-Language

否

String

请求语言类型。

缺省值：en-us

取值：

• en-us
• zh-cn

jobs

是

Array of objects

批量设置同步策略请求列表。

详情请参见表4。

job_id

是

String

任务ID。

conflict_policy

否

String

冲突策略。

取值：

• ignore：忽略。
• overwrite：覆盖。
• stop：报错。

filter_ddl_policy

否

String

过滤DDL策略。

取值：drop_database

ddl_trans

否

Boolean

同步增量是否同步DDL。

index_trans

否

Boolean

同步增量是否同步索引。

topic_policy

否

String

同步Topic策略，目标库为Kafka时必填。

GaussDB分布式版到Kafka同步取值：

• 0：集中投递到一个Topic。
• 1：按库名-schema-表名自动生成Topic名字。
• 2：按库名自动生成Topic名字。
• 3：按库名-schema自动生成Topic名字。
• 4：按库名-dn序号自动生成Topic名字。

GaussDB主备版到Kafka同步、PostgreSQL到Kafka同步取值：

• 0：集中投递到一个Topic。
• 1：按库名-schema-表名自动生成Topic名字。
• 2：按库名自动生成Topic名字。
• 3：按库名-schema自动生成Topic名字。

Oracle到Kafka同步取值：

• 0：集中投递到一个Topic。
• 1：按schema-表名自动生成Topic。
• 3：按schema自动生成Topic。

MySQL到Kafka同步取值：

• 0：集中投递到一个Topic。
• 1：自动生成Topic。

GaussDB(for MySQL)到Kafka同步取值：

• 0：集中投递到一个Topic。
• 1：自动生成Topic。

topic

否

String

Topic名称，topic_policy为0时必填，确保topic已存在。

partition_policy

否

String

同步到kafka partition策略。目标库为Kafka时必填。

• 0：按库名.schema.表名的hash值投递到不同Partition。
• 1：全部投递到Partition 0。
• 2：按主键的hash值投递到不同Partition。
• 3：按库名.schema的hash值投递到不同Partition。
• 4： 按库名.dn序号的hash值投递到不同Partition（仅GaussDB分布式版到Kafka支持选择）。
• 5：按非主键列的hash值投递到不同Partition。

当topic_policy取0时，可以取0、1、2、3、4、5；当topic_policy取1时，可以取1、2、5；当topic_policy取2时，可以取0、1、3、4；当topic_policy取3时，可以取0、1；当topic_policy取4时，可以取0、1、3。

kafka_data_format

否

String

投送到kafka的数据格式，取值：

• json
• avro
• json_c

不填默认为json。

topic_name_format

否

String

Topic名字格式，topic_policy为1,2,3,时需要。

PostgreSQL到Kafka同步、GaussDB主备版到Kafka同步取值：

• 当topic_policy取1时，Topic名字格式支持database、schema两个变量，其他字符当做常量。分别用$database$代替数据库名，$schema$代替模式名，不填默认为$database$-$schema$。
• 当topic_policy取2时，Topic名字格式支持database一个变量，其他字符都当做常量，不填默认为$database$
• 当topic_policy取3时，Topic名字格式支持database、schema和tablename三个变量，其他字符当做常量。分别用$database$代替数据库名，$schema$代替模式名，$tablename$代替表名，不填默认为$database$-$schema$-$tablename$。

Oracle到Kafka同步取值：

• 当topic_policy取1时，Topic名字格式支持schema和tablename两个变量，其他字符都当做常量。分别用$schema$代替模式名，$tablename$代替表名。不填默认为$schema$-$tablename$。
• 当topic_policy取3时，Topic名字格式支持schema变量，其他字符都当做常量。用$schema$代替模式名。不填默认为$schema$。

MySQL到Kafka、GaussDB(for MySQL)到Kafka同步取值：

• 当topic_policy取1时，Topic名字格式支持database和tablename两个变量，其他字符都当做常量。分别用$database$代替数据库名，$tablename$代替表名。不填默认为$database$-$tablename$。

partitions_num

否

String

Partition个数，取值1-2147483647之间，topic_policy为1,2,3,时需要，不填默认为1。

replication_factor

否

String

副本个数，取值1-32767之间，topic_policy为1,2,3,时需要，不填默认为1。

is_fill_materialized_view

否

Boolean

PostgreSQL全量阶段是否填充物化视图，不填默认为false。

export_snapshot

否

Boolean

PostgreSQL全量阶段是否使用快照模式导出，不填默认为false。

slot_name

否

String

复制槽名称，gaussdbv5ha-to-kafka主备任务必填。

file_and_position

否

String

• MySQL为源通过show master status命令获取源库位点，根据提示分别填写File:Position。例如：mysql-bin.000277:805。文件名只能为1-60个字符且不能包含< > & : " ' / \\ 特殊字符，文件编号只能为3-20个数字，binlog事件位置只能为1-20个数字，且总长度不能超过100个字符。格式为：文件名.文件编号:事件位点。
• MongoDB为源的任务，任务的源库日志从位点开始获取（含当前启动位点），位点需设置在oplog范围以内。非集群通过db.getReplicationInfo()直接获得oplog范围，集群通过db.watch([], {startAtOperationTime: Timestamp(xx, xx)})命令，将启动位点填在xx处，校验位点是否在oplog范围以内。格式为：timestamp:incre。timestamp和incre均为范围在1~2,147,483,647之间的整数。

gtid_set

否

String

• MySQL为源的任务需要填写。通过show master status命令获取源库位点，根据提示填写Executed_Gtid_Set（如果源库为MySQL 5.5版本，则不支持使用同步任务）。
• 不能包含< > & " ' / \\ 特殊字符和中文，且不能超过2048个字符。

ddl_topic

否

String

存储DDL的topic，Kafka为目标且ddl_trans为true时必填。

取值：目标库已存在的topic名称，确保topic已存在。

count

Integer

总数。

results

Array of objects

批量设置同步策略返回列表。

详情请参见表6。

id

String

任务ID。

status

String

状态。取值：

• success：成功。
• failed：失败。

error_code

String

错误码。

error_msg

String

错误信息。

200

OK

400

Bad Request