查询数据加工规则

project_id

是

String

租户在某一Region下的Project ID。

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

job_id

是

String

任务ID。

offset

否

Integer

偏移量，表示查询该偏移量后面的记录。

limit

否

Integer

查询返回记录的数量限制。

Content-Type

是

String

发送的实体的MIME类型。推荐用户默认使用application/json，如果API是对象、镜像上传等接口，媒体类型可按照流类型的不同进行确定。

缺省值：application/json

X-Auth-Token

是

String

从IAM服务获取的用户Token。 用户Token也就是调用获取用户Token接口的响应值，该接口是唯一不需要认证的接口。 请求响应成功后在响应消息头中包含的“X-Subject-Token”的值即为Token值。

X-Language

否

String

请求语言类型。

缺省值：en-us

枚举值：

• en-us
• zh-cn

data_process_info

Array of objects

数据加工规则响应体。

详情请参见表5。

count

Integer

数据加工规则总数目。

filter_conditions

Array of objects

指定任务数据加工规则请求体。

详情请参见表6。

is_batch_process

Boolean

库级、批量表级处理为true，单表操作为false。

add_columns

Array of objects

附加列，当选择附加列时必须填写。

详情请参见表7。

ddl_operation

Map<String,String>

支持DDL的语法，选择增量迁移或同步的DDL操作。取值及含义如下：

"table": "CREATE TABLE, ALTER TABLE,DROP TABLE,RENAME TABLE"

如该值为空，不迁移或同步DDL操作。

dml_operation

String

支持DML的语法，选择DML操作时，取值如下：

• i：INSERT
• u：UPDATE
• d：DELETE

如该值为空，不增量迁移或同步DML操作。

db_object_column_info

Object

列映射、过滤信息，当进行列映射、过滤信息时必须填写。

详情请参见表8。

db_or_table_rename_rule

Object

库表映射规则。

详情请参见表10。

db_object

Object

数据加工对象信息，当做过映射、进行数据过滤条件校验时，必须填写。

详情请参见表11。

is_synchronized

Boolean

表示该规则是否已同步至目标库。

value

String

过滤条件。当filtering_type是configConditionalFilter时，value默认填写config。当filtering_type是contentConditionalFilter时， value默认填写过滤条件。

filtering_type

String

过滤条件类型。

• contentConditionalFilter：简单条件过滤。
• configConditionalFilter：关联表过滤。

枚举值：

• contentConditionalFilter
• configConditionalFilter

column_type

String

列类型。

column_name

String

列名称。

column_value

String

列填充值。

data_type

String

填充列的数据类型。

db_name

String

数据库库名称。

schema_name

String

数据库schema名称。

table_name

String

数据库表名称。

column_infos

Array of objects

数据库列信息。

详情请参见表9。

total_count

Integer

数据库列信息总数，与分页无关，仅作为返回体参数

column_name

String

列名。

column_type

String

列类型。

primary_key_or_unique_index

String

主键或者唯一索引。

column_mapped_name

String

列映射后的名称。

is_filtered

Boolean

该列是否过滤。

is_partition_key

Boolean

该列是否partitionKey

prefix_name

String

前缀名称。当type为prefixAndSuffix，填写prefix_name，库表名称仅增加前缀，如果同时也填写suffix_name，库表名称增加前后缀。

suffix_name

String

后缀名称。当type为prefixAndSuffix，填写suffix_name，库表名称仅增加后缀，如果同时也填写prefix_name，库表名称同时增加前后缀。

type

String

库表映射类型。prefixAndSuffix：前缀、后缀或者前后缀。

枚举值：

• prefixAndSuffix
• manyToOne

object_scope

String

数据库对象迁移或同步范围。取值：

• all：全部迁移。
• database：库级迁移或同步。
• table：表级迁移或同步。

枚举值：

• all
• database
• table

target_root_db

Object

数据库对象迁移或同步目标库，两层到三层数据库同步需要填写。

详情请参见表12。

object_info

Map<String,DatabaseObject>

数据库对象迁移或同步信息，object_scope为all时不填，为库级或表级时必填。

详情请参见表13。

db_name

String

库名。

db_encoding

String

默认编码格式是utf8。

sync_type

String

该数据库在实时同步场景下的类型。取值：

config：仅当该库作为数据过滤高级设置的关联库时，需要填写，此时该库以及该库下的schemas、tables“不会”被同步到目标库，name、all属性不生效，schemas、tables需要填写被关联的相关对象。

枚举值：

• config

name

String

该数据库在目标库的名称（库名映射）。

all

Boolean

是否整库迁移或同步。

schemas

Map<String,SchemaObject>

需要迁移或同步的模式，当整库迁移或同步为false时需要填写。

详情请参见表14。

tables

Map<String,TableObject>

需要迁移或同步的表，当整库迁移或同步为false时需要填写。

详情请参见表15。

total_table_num

Integer

库下的表的数量，表的数量超过阈值就不显示。

is_synchronized

Boolean

是否已同步。

sync_type

String

该模式在实时同步场景下的类型。取值：

config：仅当该模式作为数据过滤高级设置的关联模式时，需要填写，此时该模式以及该模式下的tables“不会”被同步到目标库，name、all属性不生效，tables需要填写被关联的相关对象。

name

String

该模式在目标库的名称（模式名映射）。

all

Boolean

是否整模式迁移或同步。

tables

Map<String,TableObject>

需要迁移或同步的表，当整模式迁移或同步为false时需要填写。

详情请参见表15。

sync_type

String

该表在实时同步场景下的类型。取值：

config：仅当该表作为数据过滤高级设置的关联表时，需要填写，此时该表以及该表下的columns“不会”被同步到目标库，name、all、filtered、filter_conditions属性不生效，columns需要填写被关联的相关对象，config_conditions需要填写数据过滤高级设置的配置条件。

type

String

对象类型。取值：

• table：表。
• view：视图。
• procedure：存储过程。

枚举值：

• table
• view
• procedure

name

String

该表在目标库的名称（表名映射）。

all

Boolean

是否整表迁移或同步。

db_alias_name

String

一对多情况下，表级上对库名的映射。

schema_alias_name

String

一对多情况下，表级上对schema名的映射。

filtered

Boolean

该表是否进行数据过滤。

filter_conditions

Array of strings

该表数据的过滤条件，生成加工规则值为SQL条件语句，长度限制512。

最小长度：0

最大长度：512

config_conditions

Array of strings

该表数据过滤高级设置的配置条件，当该表作为联表查询时填写，生成加工规则值为SQL条件语句，长度限制512。

最小长度：0

最大长度：512

is_synchronized

Boolean

是否已经进行同步。

columns

Map<String,ColumnObject>

需要同步/映射/过滤/新增的列，当需要列过滤、列映射、附加列功能时填写，仅在实时同步任务中生效，当整表同步为false时需要填写。

详情请参见表16。

sync_type

String

该列在实时同步场景下的类型。取值：

config：当该列作为数据过滤高级设置的关联列时，需要填写，同时如果该列是主建或优化查询所需的索引，则需要填写primary_key_for_data_filtering或index_for_data_filtering。

primary_key_for_data_filtering

String

该列是否在数据过滤高级设置场景下为主键，如果是主建则填该列列名，否则不填。

index_for_data_filtering

String

优化查询所需的索引，将会为缓存数据增加索引，不会影响源表，当该列作为数据过滤高级设置的关联索引时，需要填写，否则不填。

name

String

该列在目标库的名称（列名映射），当该列为“附加列”时须与数据库表级对象中列名保持一致。

type

String

该列字段的数据类型。 列过滤：填写源列字段的数据类型。 附加列：新填充的列指定字段的数据类型，根据不同操作类型来决定取值范围与约束。取值：

• 以默认值方式，支持：int,long,varchar(256),datetime,timestamp。
• 以create_time为列，支持：long,datetime,timestamp。
• 以update_time为列，支持：long,datetime,timestamp。
• 以表达式为列，支持：varchar(256)，且列值仅为：concat(__current_database, '@', __current_table)
• 以serverName@database@table为列，支持：varchar(256)。

primary_key_for_column_filtering

String

该列是否在列映射场景下为主键，如果是主建则填PRI，否则填空。

filtered

Boolean

该列是否进列过滤，不能与附加列additional同时使用。取值：

• true：表示同步该列。
• false：表示过滤该列不同步。

additional

Boolean

该列是否为附加列，当该列为附加列时：name必须与表级对象中列名一致，并且不能与列过滤filtered同时使用。

operation_type

String

操作类型，以特定的操作类型填充新加的列。取值：

• 以默认值方式："operation_type":"ADDITIONALCOLUMN,default_value"
• 以create_time为列："operation_type":"ADDITIONALCOLUMN,create_time"
• 以update_time为列："operation_type":"ADDITIONALCOLUMN,update_time"
• 以表达式为列："operation_type":"ADDITIONALCOLUMN,expression"
• 以serverName@database@table为列："operation_type":"ADDITIONALCOLUMN,server_database_table"

value

String

附加列的值。约束：

• 当操作类型仅“以默认值方式”，“以serverName@database@table为列”时，才支持输入对应字段类型的值。
• 当操作类型为“以表达式为列”时，该字段为固定值"concat(__current_database, '@', __current_table)"，不需要填写。

error_code

String

错误码。

最小长度：12

最大长度：12

error_msg

String

错误描述。

最小长度：1

最大长度：512

200

OK

400

Bad Request