更新时间：2024-04-19 GMT+08:00
自动检查并重启失败的迁移任务
方案概述
通过API调用启动迁移任务/迁移任务组后，由于网络波动或其他原因导致迁移任务失败，需要重新启动迁移任务/迁移任务组，可以通过以下方式重新启动：
- 手动调用API重新启动迁移任务/迁移任务组。
- 在业务代码中自动检测并调用API重新启动迁移任务/迁移任务组。
- 使用函数工作流自动检查并重启失败的迁移任务。
本方案指导用户使用函数工作流检查指定任务id的迁移任务，若该任务迁移失败则自动重启。
图1 逻辑架构图
启动OMS迁移任务之后，触发函数工作流循环检查该迁移任务的执行状态，当迁移任务状态为失败时：
- 如果该迁移任务为单个迁移任务，函数工作流调用OMS的API重启该迁移任务。
- 如果该迁移任务为迁移任务组中的任务，函数工作流调用OMS的API检查迁移任务组的状态，直至迁移任务组的状态为失败，重新启动迁移任务。
当迁移成功或重试次数超过指定次数，则停止检查。
前提条件
- 已注册华为账号并开通华为云；访问位于中国大陆的Region时，还需完成实名认证。
- 已获取源端和目的端账号的AK/SK。
- 已创建迁移任务/迁移任务组并启动任务。
步骤一：创建程序包
本示例使用Java8语言实现定时检查并重启失败迁移任务的功能，有关函数开发的过程请参考Java函数开发。
图2 目录结构
pom.xml文件的依赖：
<dependency> <groupId>Runtime</groupId> <artifactId>Runtime</artifactId> <version>2.0.5</version> </dependency> <dependency> <groupId>com.huaweicloud.sdk</groupId> <artifactId>huaweicloud-sdk-oms</artifactId> <version>3.1.86</version> </dependency>
样例代码：
package com.huawei.demo;
import com.huawei.services.runtime.Context;
import com.huawei.services.runtime.RuntimeLogger;
import com.huawei.services.runtime.entity.timer.TimerTriggerEvent;
import com.huaweicloud.sdk.core.auth.BasicCredentials;
import com.huaweicloud.sdk.core.auth.ICredential;
import com.huaweicloud.sdk.core.exception.ConnectionException;
import com.huaweicloud.sdk.core.exception.RequestTimeoutException;
import com.huaweicloud.sdk.core.exception.ServiceResponseException;
import com.huaweicloud.sdk.oms.v2.OmsClient;
import com.huaweicloud.sdk.oms.v2.model.RetryTaskGroupReq;
import com.huaweicloud.sdk.oms.v2.model.RetryTaskGroupRequest;
import com.huaweicloud.sdk.oms.v2.model.ShowTaskGroupRequest;
import com.huaweicloud.sdk.oms.v2.model.ShowTaskGroupResponse;
import com.huaweicloud.sdk.oms.v2.model.ShowTaskRequest;
import com.huaweicloud.sdk.oms.v2.model.ShowTaskResponse;
import com.huaweicloud.sdk.oms.v2.model.StartTaskReq;
import com.huaweicloud.sdk.oms.v2.model.StartTaskRequest;
import com.huaweicloud.sdk.oms.v2.region.OmsRegion;
public class RetryTask {
private RuntimeLogger logger;
private String dstAk;
private String dstSk;
private String srcAk;
private String srcSk;
public String checkAndRetryTask(TimerTriggerEvent event, Context context) {
logger = context.getLogger();
String region = context.getUserData("region_id");
String taskId = context.getUserData("task_id");
int maxRetryCount = Integer.parseInt(context.getUserData("retry_count"));
srcAk = context.getUserData("src_ak");
srcSk = context.getUserData("src_sk");
dstAk = context.getUserData("dst_ak");
dstSk = context.getUserData("dst_ak");
String ak = context.getAccessKey();
String sk = context.getSecretKey();
ICredential auth = new BasicCredentials()
.withAk(ak)
.withSk(sk);
OmsClient client = OmsClient.newBuilder()
.withCredential(auth)
.withRegion(OmsRegion.valueOf(region))
.build();
ShowTaskRequest request = new ShowTaskRequest();
request.withTaskId(taskId);
int retryCount = 0;
try {
while (true) {
ShowTaskResponse taskResponse = client.showTask(request);
Integer status = taskResponse.getStatus();
logger.info("task status: "+status);
if (retryCount >= maxRetryCount || status == 5) {
break;
}
if ("NORMAL_TASK".equals(taskResponse.getGroupType().getValue()) && status == 4) {
retryTask(client, taskId);
logger.info("task restart:" + taskId);
retryCount++;
continue;
}
if ("GROUP_TASK".equals(taskResponse.getGroupType().getValue()) && status == 4) {
retryTasksGroup(client, taskResponse.getGroupId());
logger.info("task group restart:" + taskResponse.getGroupId());
retryCount++;
}
}
return "ok";
} catch (ConnectionException e) {
logger.error("Failed to restart the task, error_msg: " + e.getMessage());
} catch (RequestTimeoutException e) {
logger.error("Time out, failed to restart the task, error_msg: " + e.getMessage());
} catch (ServiceResponseException e) {
logger.error("Failed to restart the task, error_code: " + e.getErrorCode() + ", error_msg: " + e.getErrorMsg());
}
return "fail";
}
private void retryTasksGroup(OmsClient client, String groupId) {
ShowTaskGroupRequest taskGroupRequest = new ShowTaskGroupRequest();
taskGroupRequest.withGroupId(groupId);
ShowTaskGroupResponse taskGroupResponse = client.showTaskGroup(taskGroupRequest);
if (taskGroupResponse.getStatus() == 5) {
RetryTaskGroupRequest retryTaskGroupRequest = new RetryTaskGroupRequest();
retryTaskGroupRequest.withGroupId(groupId);
RetryTaskGroupReq body = new RetryTaskGroupReq();
body.withMigrateFailedObject(false);
body.withDstAk(dstAk);
body.withDstSk(dstSk);
body.withSrcAk(srcAk);
body.withSrcSk(srcSk);
retryTaskGroupRequest.withBody(body);
client.retryTaskGroup(retryTaskGroupRequest);
}
}
private void retryTask(OmsClient client, String taskId) {
StartTaskRequest startTaskRequest = new StartTaskRequest();
StartTaskReq body = new StartTaskReq();
body.withMigrateFailedObject(false);
body.withDstAk(dstAk);
body.withDstSk(dstSk);
body.withSrcAk(srcAk);
body.withSrcSk(srcSk);
startTaskRequest.withBody(body);
startTaskRequest.withTaskId(taskId);
client.startTask(startTaskRequest);
}
}
步骤二：创建函数
- 登录函数工作流控制台，在左侧导航栏选择“函数 > 函数列表”，进入函数列表界面。
- 单击“创建函数”，进入创建函数流程。
- 填写函数配置信息。输入基础配置信息，完成后单击“创建函数”。
- 函数名称：输入“check_retry_task”。
- 委托名称：选择default。
- 运行时语言：选择“Java 8”。
- 单击check_retry_task函数名称，进入函数详情页，在“代码”页签，代码选择“上传自JAR文件”，上传样例代码编译后的jar包，完成后单击“部署”。
- 在“设置 > 常规设置”页签，设置如下信息，完成后单击“保存”。
- 内存：选择“512”。
- 执行超时时间：输入“60”。
- 函数执行入口：输入“com.huawei.demo.RetryTask.checkAndRetryTask”。
函数执行入口格式为：[包名].[类名].[执行函数名]，根据自己上传的代码修改。
- 所属应用：默认“default”。
- 描述：输入描述内容。
步骤三：设置环境变量
- 进入check_retry_task函数详情页，在设置页签，选择环境变量。
- 单击“添加环境变量”，根据表1，配置环境变量，完成后单击“保存”。
步骤四：配置事件源
函数创建完成后，为函数添加事件源，可以通过添加定时触发器定时检查指定任务的迁移状态并重启。
- 进入check_retry_task函数详情页，在设置页签，选择“触发器”。
- 单击“创建触发器”，弹出“创建触发器”界面。
- 设置以下信息：
- 触发器类型：选择“定时触发器 (TIMER)”。
- 定时器名称：您自定义的定时器名称，例如：Timer。
- 触发规则：固定频率和Cron表达式。
- 固定频率：固定时间间隔触发函数，该类型下支持配置单位为分、时、天，每种类型仅支持整数配置，其中分钟支持范围(0，60]，小时支持范围(0，24]，天支持范围(0，30]。
- Cron表达式：设置更为复杂的函数执行计划，例如：周一到周五上午08:30:00执行函数等，具体请参见函数定时触发器Cron表达式规则。
- 是否开启：可选择是否开启定时触发器。
- 附加信息：如果用户配置了触发事件，会将该事件填写到TIMER事件源的“user_event”字段，详情请参见支持的事件源。
- 配置完成后，单击“确定”，完成触发器创建。
