全部产品
数据传输服务DTS

配置同步作业

更新时间:2017-08-18 15:41:18   分享:   

描述

当调用购买同步作业接口购买完同步实例后,可以调用这个接口配置同步作业。
只有当同步作业处于未配置状态时,才可以调用这个接口配置作业。

请求参数

参数名称 数据类型 是否必须 参数说明
Action String 系统默认参数,这个接口的接口定义,取值为:ConfigureSynchronizationJob
SynchronizationJobId String 同步作业Id
SynchronizationJobName String 同步作业名称
SourceEndpoint.InstanceId String 同步源实例的实例ID
SourceEndpoint.OwnerID String 当同步源实例跟目标实例实例不属于同一个阿里云账号时,这个参数为源实例所属阿里云账号的UID
SourceEndpoint.Role String 当同步源实例跟目标实例实例不属于同一个阿里云账号时,这个参数为源实例所属账号对目标实例所属阿里云账号的授权角色,角色的相关权限及授权步骤 参考 跨账号迁移同步
DestinationEndpoint.InstanceId String 同步目标实例的实例ID,如果为ODPS、Datahub那么为对应的Project;如果为AnalyticDB,那么为对应的数据库名。
SynchronizationObjects List 同步对象,其中SynchronizationObject的定义参考SynchronizationObject参数定义
StructureInitialization Boolean 同步之前是否进行结构对象初始化,取值包括:
true: 表示进行结构对象初始化
false:表示不进行结果对象初始化
默认取值为:true
DataInitialization Boolean 同步之前是否进行全量数据初始化,取值包括:
true: 表示进行全量数据初始化
false:表示不进行全量数据初始化
默认取值为:true
PartitionKey.ModifyTime_Year Boolean 当同步的目标实例为ODPS时,这个参数为ODPS中增量日志表的分区键定义,取值包括:
true:表示增量日志表的一级分区为年分区
false:表示增量日志表不支持年分区
默认取值为:true
PartitionKey.ModifyTime_Month Boolean 当同步的目标实例为ODPS时,这个参数为ODPS中增量日志表的分区键定义,取值包括:
true:表示增量日志表支持月分区
false:表示增量日志表不支持月分区
默认取值为:true
PartitionKey.ModifyTime_Day Boolean 当同步的目标实例为ODPS时,这个参数为ODPS中增量日志表的分区键定义,取值包括:
true:表示增量日志表支持天分区
false:表示增量日志表不支持天分区
默认取值为:true
PartitionKey.ModifyTime_Hour Boolean 当同步的目标实例为ODPS时,这个参数为ODPS中增量日志表的分区键定义,取值包括:
true:表示增量日志表支持小时分区
false:表示增量日志表不支持小时分区
默认取值为:true
PartitionKey.ModifyTime_Minute Boolean 当同步的目标实例为ODPS时,这个参数为ODPS中增量日志表的分区键定义,取值包括:
true:表示增量日志支持分钟分区
false:表示增量日志表不支持分钟分区。对于分钟分区,15分钟一个分区

返回参数

参数名称 数据类型 参数说明
<公共返回参数> 接口请求ID

示例

下面简单演示通过JAVA SDK 配置同步实例的示例:

  1. public void configureSyncJobRDS2RDS(String SyncJobId,DefaultAcsClient client) {
  2. ConfigureSynchronizationJobRequest request = new ConfigureSynchronizationJobRequest();
  3. request.setSynchronizationJobId(SyncJobId);
  4. request.setSynchronizationJobName("jiangliu_test_rds2rds_sync");
  5. request.setSourceEndpointInstanceId("rm-bp185gso372vbd1l8");
  6. request.setDestinationEndpointInstanceId("rm-bp1nx2h5fm3v6q26l");
  7. request.setStructureInitialization(true);
  8. request.setDataInitialization(true);
  9. String SyncObject="[{\"DBName\":\"jiangliutest\",\"NewDBName\":\"jiangliutest\","
  10. + "\"TableIncludes\":[{\"TableName\":\"t1\",\"NewTableName\":\"t1\"}]}]";
  11. request.setSynchronizationObjects(SyncObject);
  12. ConfigureSynchronizationJobResponse response = new ConfigureSynchronizationJobResponse();
  13. try {
  14. response = client.getAcsResponse(request);
  15. System.out.println("Configure Sync Job Succeed!");
  16. } catch (Exception e) {
  17. // TODO: handle exception
  18. System.out.println("Configure Sync Job Failed");
  19. System.out.println(e.toString());
  20. }
  21. }
本文导读目录
本文导读目录
以上内容是否对您有帮助?