如何查看迁移任务状态
描述
当任务处于任意状态时，都可以调用这个接口查看数据迁移状态。可以查询的迁移状态包括：整个任务的迁移状态，各个迁移阶段(结构迁移、全量数据迁移、增量数据迁移)的迁移状态及进度 以及 预检查的状态。
请求参数
| 参数名称 | 数据类型 | 是否必须 | 参数描述 |
| Action | String | 是 | 系统必须参数，为这个接口的接口定义，具体取值为：DescribeMigrationJobStatus |
| MigrationJobId | String | 是 | 迁移任务ID |
返回参数
| 参数名称 | 数据类型 | 参数描述 |
| MigrationJobId | String | 迁移任务ID` |
| MigrationJobName | String | 迁移任务名称 |
| PayType | String | 付费类型 |
| MigrationJobClass | String | 迁移实例规格 |
| SourceEndpoint | Endpoint | 迁移源实例的连接方式Endpoint的定义参考Endpoint参数定义 |
| DestinationEndpoint | Endpoint | 迁移目标实例的连接方式Endpoint的定义参考Endpoint参数定义 |
| MigrationMode | MigrationMode | 迁移类型MigrationMode的定义参考MigrationMode参数定义 |
| MigrationObjects | List | 迁移对象 |
| MigrationJobStatus | String | 迁移任务状态，取值包括：NotStarted : 表示未启动 Prechecking : 表示预检查中 PrecheckFailed : 表示预检查失败 Migrating : 表示迁移中 Suspengding : 表示暂停中 MigrationFailed : 表示迁移失败 Finished : 表示完成 |
| PrecheckStatus | PrecheckStatus | 预检查的状态，包括检查进度及检查状态PrecheckStatus的定义详见PrecheckStatus的参数定义 |
| StructureInitializationStatus | StructureInitializationStatus | 结构迁移的状态,包括迁移状态及具体的迁移进度StructureInitializationStatus的定义详见 StructureInitializationStatus参数定义 |
| DataInitializationStatus | DataInitializationStatus | 全量数据迁移的状态，包括迁移状态及具体的迁移进度DataInitializationStatus的定义详见DataInitializationStatus参数定义 |
| DataSynchronizationStatus | DataSynchronizationStatus | 增量数据迁移的状态，包括迁移状态及具体的迁移进度DataSynchronizationStatus定义详见DataSynchronizationStatus参数定义 |
Endpoint 参数定义
| 参数名称 | 数据类型 | 参数描述 |
| InstanceType | String | 实例类型 |
| Region | String | 源实例所在地域 |
| InstanceId | String | 实例ID |
| EngineName | String | 数据库类型 |
| IP | String | 数据库连接地址 |
| Port | String | 数据库监听端口 |
| UserName | String | 数据库访问账号 |
| OracleSID | String | Oracle SID |
| DatabaseName | String | 数据库名称 |
MigrationMode参数定义
| 参数名称 | 数据类型 | 参数描述 |
| StructureInitialization | String | 是否进行结构迁移 |
| DataInitialization | String | 是否进行全量数据迁移 |
| DataSynchronization | String | 是否进行增量数据迁移 |
PrecheckStatus参数定义
| 参数名称 | 数据类型 | 参数说明 |
| Status | String | 预检查状态 |
| Percent | String | 预检查进度，单位为百分比 |
| Detail | List | 各个预检查项的检查情况CheckItem的定义详见CheckItem的参数定义 |
CheckItem的参数定义
| 参数名称 | 数据类型 | 参数说明 |
| ItemName | String | 检查项名称 |
| CheckStatus | String | 检查状态，取值包括NotStarted : 未启动 Checking : 检查中Failed : 检查失败Finished : 检查成功 |
| ErrorMessage | String | 失败原因 |
| RepairMethod | String | 修复方法 |
StructureInitializationStatus参数定义
| 参数名称 | 数据类型 | 参数说明 |
| Status | String | 迁移状态，取值包括：NotStarted：未启动Migrating : 迁移中Failed :迁移失败Finished: 迁移完成 |
| ErrorMessage | String | 迁移失败原因 |
| Percent | String | 迁移进度，单位为百分比 |
| Progress | String | 已经完成迁移的表数量 |
DataInitializationStatus参数定义
| 参数名称 | 数据类型 | 参数说明 |
| Status | String | 迁移状态，取值包括：NotStarted：未启动Migrating : 迁移中Failed :迁移失败Finished: 迁移完成 |
| ErrorMessage | String | 迁移失败原因 |
| Percent | String | 迁移进度，单位为百分比 |
| Progress | String | 已经完成迁移的表数量 |
DataSynchronizationStatus参数定义
| 参数名称 | 数据类型 | 参数说明 |
| Status | String | 迁移状态，取值包括：NotStarted：未启动Migrating : 迁移中Failed :迁移失败Finished: 迁移完成 |
| ErrorMessage | String | 迁移失败原因 |
| Percent | String | 迁移进度，单位为百分比 |
| Delay | String | 迁移延迟 |
示例
下面简单演示通过JAVA SDK 查询迁移任务状态的示例：
private static void describeMigrationJobStatus(String MigrationJobId){
DescribeMigrationJobStatusRequest request = new DescribeMigrationJobStatusRequest();
request.setMigrationJobId(MigrationJobId);
try {
DescribeMigrationJobStatusResponse response = client.getAcsResponse(request);
System.out.println("Get Status of Migration Job "+MigrationJobId+" Succeed!");
String JobStatus=response.getMigrationJobStatus();
/*Get the basic information of the migration job*/
System.out.println("MigrationJobName:"+response.getMigrationJobName()
+"MigrationJobId:"+response.getMigrationJobId()
+"MigrationObjects:"+response.getMigrationObject()
+"; MigrationMode.StructureInitialization:" + response.getMigrationMode().getStructureInitialization()
+"; MigrationMode.DataInitialization:"+response.getMigrationMode().getDataInitialization()
+"; MigrationMode.DataSynchronization:"+response.getMigrationMode().getDataSynchronization()
+"; MigrationJobStatus:"+response.getMigrationJobStatus());
/*Get the source endpoint of the migration job*/
System.out.println("SourceEndpoint.InstanceType:"+response.getSourceEndpoint().getInstanceType()
+"; SourceEndpoint.InstanceId:"+response.getSourceEndpoint().getInstanceId()
+"; SourceEndpoint.EngineName:"+response.getSourceEndpoint().getEngineName()
+"; SourceEndpoint.IP:"+response.getSourceEndpoint().getIP()
+"; SourceEndpoint.Port"+response.getSourceEndpoint().getPort()
+"; SourceEndpoint.UserName:"+response.getSourceEndpoint().getUserName()
+"; SourceEndpoint.DatabaseName:"+response.getSourceEndpoint().getDatabaseName()
+"; SourceEndpoint.OracleSID:"+response.getSourceEndpoint().getOracleSID());
/*Get the destination endpoint of the migration job*/
System.out.println("DestinationEnpoint.InstanceType:"+response.getDestinationEndpoint().getInstanceType()
+"DestinationEndpoint.InstanceId:"+response.getDestinationEndpoint().getInstanceId()
+"DestinationEndpint.EngineName:"+response.getDestinationEndpoint().getEngineName()
+"DestinationEndpoint.IP:"+response.getDestinationEndpoint().getIP()
+"DestinationEndpoint:Port:"+response.getDestinationEndpoint().getPort()
+"DestinationEndpoint.UserName:"+response.getDestinationEndpoint().getUserName()
+"DestinationEndpoint.DatabaseName"+response.getDestinationEndpoint().getDatabaseName()
+"DestinationEndpoint.OracleSID:"+response.getDestinationEndpoint().getOracleSID());
/*Get Status of Precheck*/
try {
com.aliyuncs.dts.model.v20160801.DescribeMigrationJobStatusResponse.PrecheckStatus precheckStatus = response.getPrecheckStatus();
System.out.println("Get Precheck Status of Migration Job "+MigrationJobId +" Succeed!");
System.out.println("Precheck Status:"+ precheckStatus.getStatus()+";Precheck Percent:"+precheckStatus.getPercent());
List<CheckItem> checkItems = precheckStatus.getDetail();
for (int i = 0; i < checkItems.size(); i++) {
String checkItem=checkItems.get(i).getItemName();
String checkStatus = checkItems.get(i).getCheckStatus();
String repairMethod = checkItems.get(i).getRepairMethod();
String errorMessage =checkItems.get(i).getErrorMessage();
System.out.println("CheckItem:"+checkItem+"; CheckStatus:"+checkStatus
+"errorMessage:"+errorMessage+"; repairMethod:"+repairMethod);
}
} catch (Exception e) {
// TODO: handle exception
System.out.println("Get Precheck Status of Migration Job "+MigrationJobId +" Failed!");
System.out.println(e.toString());
}
/*Get Status of Structure Migration*/
try {
StructureInitializationStatus strucInitStatus = new StructureInitializationStatus();
strucInitStatus = response.getStructureInitializationStatus();
String status = strucInitStatus.getStatus();
String percent = strucInitStatus.getPercent();
String progress = strucInitStatus.getProgress();
String errorMsg = strucInitStatus.getErrorMessage();
System.out.println("Get Structure Initialization Status of Migration Job " +MigrationJobId+" Succeed!");
System.out.println("Status:"+status+";percent:"+percent+"; progress:"+progress+"; errorMsg:"+errorMsg);
} catch (Exception e) {
// TODO: handle exception
System.out.println("Get Structure Initialization Status of Migration Job " +MigrationJobId+" Failed!");
System.out.println(e.toString());
}
/*Get Status of Data Migration*/
try {
DataInitializationStatus dataInitStatus = new DataInitializationStatus();
dataInitStatus = response.getDataInitializationStatus();
String datainitstatus=dataInitStatus.getStatus();
String datainitpercent = dataInitStatus.getPercent();
String datainitprogress = dataInitStatus.getProgress();
String datainiterrormsg = dataInitStatus.getErrorMessage();
System.out.println("Get Data Initialization Status of Migration Job " +MigrationJobId+" Succeed!");
System.out.println("Status:"+datainitstatus+";percent:"+datainitpercent+"; progress:"+datainitprogress+"; errorMsg:"+datainiterrormsg);
} catch (Exception e) {
// TODO: handle exception
System.out.println("Get Data Initialization Status of Migration Job " +MigrationJobId+" Failed!");
System.out.println(e.toString());
}
/*Get Status of Data Synchronization*/
try {
DataSynchronizationStatus dataSyncStatus = new DataSynchronizationStatus();
dataSyncStatus = response.getDataSynchronizationStatus();
String datasynstatus=dataSyncStatus.getStatus();
String datasyncpercent=dataSyncStatus.getPercent();
String datasyncdelay=dataSyncStatus.getDelay();
String datasyncerrormsg=dataSyncStatus.getErrorMessage();
System.out.println("Get Data Synchronization Status of Migration Job " +MigrationJobId+" Succeed!");
System.out.println("Status:"+datasynstatus+";percent:"+datasyncpercent+"; delay:"+datasyncdelay+"; errorMsg:"+datasyncerrormsg);
} catch (Exception e) {
// TODO: handle exception
System.out.println("Get Data Synchronization Status of Migration Job " +MigrationJobId+" Failed!");
System.out.println(e.toString());
}
} catch (Exception e) {
// TODO: handle exception
System.out.println("Get Status of Migration Job "+MigrationJobId+" Failed");
System.out.println(e.toString());
}
}
展开
收起
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
问答排行榜
最热
最新
推荐问答
相关电子书
更多
