描述
当调用购买同步作业接口购买完同步实例后,可以调用这个接口配置同步作业。只有当同步作业处于未配置状态时,才可以调用这个接口配置作业。
请求参数
参数名称 | 数据类型 | 是否必须 | 参数说明 |
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 |
public void configureSyncJobRDS2RDS(String SyncJobId,DefaultAcsClient client) {
ConfigureSynchronizationJobRequest request = new ConfigureSynchronizationJobRequest();
request.setSynchronizationJobId(SyncJobId);
request.setSynchronizationJobName("jiangliu_test_rds2rds_sync");
request.setSourceEndpointInstanceId("rm-bp185gso372vbd1l8");
request.setDestinationEndpointInstanceId("rm-bp1nx2h5fm3v6q26l");
request.setStructureInitialization(true);
request.setDataInitialization(true);
String SyncObject="[{\"DBName\":\"jiangliutest\",\"NewDBName\":\"jiangliutest\","
+ "\"TableIncludes\":[{\"TableName\":\"t1\",\"NewTableName\":\"t1\"}]}]";
request.setSynchronizationObjects(SyncObject);
ConfigureSynchronizationJobResponse response = new ConfigureSynchronizationJobResponse();
try {
response = client.getAcsResponse(request);
System.out.println("Configure Sync Job Succeed!");
} catch (Exception e) {
// TODO: handle exception
System.out.println("Configure Sync Job Failed");
System.out.println(e.toString());
}
}
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。