如何查看同步作业状态_问答-阿里云开发者社区

描述

同步实例处于任何状态，都可以调用这个接口查询同步实例的状态及运行详情。

请求参数

参数名称	数据类型	是否必须	参数说明
Action	String	是	系统默认参数，为这个接口的接口定义，取值为：DescribeSynchronizationJobStatus
SynchronizationJobId	String	是	同步实例ID

返回参数

参数名称	数据类型	参数说明
SynchronizationJobId	String	同步实例ID
SynchronizationJobName	String	同步实例名称
SynchronizationJobClass	String	同步实例规格
PayType	String	付费类型
ExpireTime	String	到期时间，格式为：YYYY-MM-DDT hh:mm:ssZ,例如：2011-06-09T 12:11:11Z
SourceEndpoint	SourceEndpoint	同步实例的源实例连接信息
DestinationEndpoint	DestinationEndpoint	同步实例的目标实例连接信息
SynchronizationObjects	List	同步对象
StructureInitialization	String	是否进行结构初始化
DataInitialization	String	是否进行全量数据初始化
Status	String	同步实例状态，取值包括：NotStarted:未启动 Prechecking: 预检查中 PrecheckFailed: 预检查失败 Initializating : 同步初始化 InitializeFailed: 同步初始化失败Synchronizing : 同步中 Failed: 同步失败 Suspending: 暂停 Modifying: 同步中(同步对象变更中) Finished: 完成
ErrorMessage	String	同步失败原因
PrecheckStatus	PrecheckStatus	预检查状态，其中 PrecheckStatus的定义参考 PrecheckStatus 参数定义
StructureInitializationStatus	StructureInitializationStatus	结构初始化详情，其中 StructureInitializationStatus的定义参考StructureInitializationStatus参数定义
DataInitializationStatus	DataInitializationStatus	全量数据初始化详情，其中 DataInitializationStatus的定义参考DataInitializationStatus参数定义
DataSynchronizationStatus	DataSynchronizationStatus	增量初始化详情，其中 DataSynchronizationStatus的定义参考DataSynchronizationStatus参数定义
Delay	String	同步延迟，单位为秒
Performance	String	同步概况，其中 Performance的定义参考Performance参数定义

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	迁移延迟，单位为秒

Performance 参数定义

参数名称	数据类型	参数说明
TPS	String	每秒同步的记录数
Flow	String	每秒同步的流量，单位为：MB/s

示例

下面简单演示通过JAVA SDK 查询同步任务状态的示例：

public void descSyncJobStatus(String SyncJobId,DefaultAcsClient client) {
        DescribeSynchronizationJobStatusRequest request = new DescribeSynchronizationJobStatusRequest();
        request.setSynchronizationJobId(SyncJobId);
        DescribeSynchronizationJobStatusResponse response = new DescribeSynchronizationJobStatusResponse();
        try {
            response = client.getAcsResponse(request);
            /*Get Sync Configure of the Sync Job*/
            System.out.println("SyncJobId:"+response.getSynchronizationJobId()
                    +"SyncJobName:"+response.getSynchronizationJobName()
                    +"; PayType:"+response.getPayType()+"; ExpireTime:"+response.getExpireTime()
                    +"; SyncClass:"+response.getSynchronizationJobClass()
                    +"; StrucInit:"+response.getStructureInitialization()
                    +"; DataInit:"+response.getDataInitialization()+"; Status:"+response.getStatus()
                    +"; Delay:"+response.getDelay()
                    +"; ErrMSG:"+response.getErrorMessage());
            /*Get Sync Objects of the Sync Job*/
            System.out.println("Sync Objects:");
            List<SynchronizationObject> syncObjects = response.getSynchronizationObjects();
            /*Get the Source Endpoint of the synchronization job*/
            SourceEndpoint sourceEndpoint = response.getSourceEndpoint();
            System.out.println("InstanceType:"+sourceEndpoint.getInstanceType()
                    +"InstanceId:"+sourceEndpoint.getInstanceId());
            /*Get the Destination Endpoint of the synchronization job*/
            DestinationEndpoint destinationEndpoint = new DestinationEndpoint();
            System.out.println("Instance Type:"+destinationEndpoint.getInstanceType()
                    +destinationEndpoint.getInstanceId());
            // Get Sync Object of the synchronization job
            System.out.println("SyncObject:"+org.json.JSONObject.valueToString(syncObjects));
            // Get Precheck Status of the synchronization job
            try {
                com.aliyuncs.dts.model.v20160801.DescribeSynchronizationJobStatusResponse.PrecheckStatus precheckStatus = response.getPrecheckStatus();
                System.out.println("Get Precheck Status for Sync Job Succeed");
                System.out.println("Precheck Status:"+response.getPrecheckStatus().getStatus()
                        +";  Precheck Percent:"+response.getPrecheckStatus().getPercent());
                List<com.aliyuncs.dts.model.v20160801.DescribeSynchronizationJobStatusResponse.PrecheckStatus.CheckItem> precheckDetails= precheckStatus.getDetail();
                for (int i = 0; i < response.getPrecheckStatus().getDetail().size(); i++) {
                    System.out.println("CheckItem:"+response.getPrecheckStatus().getDetail().get(i).getCheckStatus()
                            +"; ErrorMSG:"+response.getPrecheckStatus().getDetail().get(i).getErrorMessage()
                            +"; RepairMethod:"+response.getPrecheckStatus().getDetail().get(i).getRepairMethod());
                }
            } catch (Exception e) {
                // TODO: handle exception
                System.out.println("Get Precheck Status for Sync Job Failed");
            }
            // Get Structure Initialization Status of the synchronization job
            try {
                System.out.println("Get Structure Initialization Status Succeed!");
                System.out.println("Structure Init Status:"+response.getStructureInitializationStatus().getStatus()
                        +"; Percent:"+response.getStructureInitializationStatus().getPercent()
                        +"; Progress:"+response.getStructureInitializationStatus().getProgress()
                        +"; ErrMSG:"+response.getStructureInitializationStatus().getErrorMessage());
            } catch (Exception e) {
                // TODO: handle exception
                System.out.println("Get Structure Init Status Failed!");
            }
            // Get Data Initialization Status of the synchronization job
            try {
                System.out.println("Get Data Initialization Status Succeed!");
                System.out.println("Data Init Status:"+response.getDataInitializationStatus().getStatus()
                        +"; Percent:"+response.getDataInitializationStatus().getPercent()
                        +"; Progress:"+response.getDataInitializationStatus().getProgress()
                        +"; ErrMSG:"+response.getDataInitializationStatus().getErrorMessage());
            } catch (Exception e) {
                // TODO: handle exception
                System.out.println("Get Data Init Status Failed!");
                System.out.println(e.toString());
            }
            //Get Data Sync Status
            try {
                com.aliyuncs.dts.model.v20160801.DescribeSynchronizationJobStatusResponse.DataSynchronizationStatus dataSyncStatus = response.getDataSynchronizationStatus(); 
                System.out.println("Get Data Synchronization Status Succeed!");
                System.out.println("Data Sync Status:"+response.getDataSynchronizationStatus().getStatus()
                        +"; Percent:"+response.getDataSynchronizationStatus().getPercent()
                        +"; Delay:"+response.getDataSynchronizationStatus().getDelay()
                        +"; ErrMSG:"+response.getDataSynchronizationStatus().getErrorMessage());
            } catch (Exception e) {
                // TODO: handle exception
                System.out.println("Get Data Sync Status Failed!");
                System.out.println(e.toString());
            }
            //Get Performance
            System.out.println("TPS:"+response.getPerformance().getRPS()
                    +"Flow:"+response.getPerformance().getRPS());
        } catch (Exception e) {
            // TODO: handle exception
            System.out.println("Describe Status of Data Sync Job "+ SyncJobId + "Failed");
            System.out.println(e.toString());
        }    
    }

如何查看同步作业状态

相关课程

相关电子书

相关实验场景

如何查看同步作业状态

相关课程

相关文章

相关电子书

相关实验场景