|
@@ -3,10 +3,14 @@ package com.winhc.dataworks.flow.touch.service;
|
|
|
import com.aliyuncs.IAcsClient;
|
|
|
import com.aliyuncs.dataworks_public.model.v20180601.CreateManualDagRequest;
|
|
|
import com.aliyuncs.dataworks_public.model.v20180601.CreateManualDagResponse;
|
|
|
+import com.aliyuncs.dataworks_public.model.v20180601.SearchManualDagNodeInstanceRequest;
|
|
|
+import com.aliyuncs.dataworks_public.model.v20180601.SearchManualDagNodeInstanceResponse;
|
|
|
import com.aliyuncs.http.ProtocolType;
|
|
|
import com.helospark.lightdi.annotation.Autowired;
|
|
|
import com.helospark.lightdi.annotation.Service;
|
|
|
+import com.winhc.dataworks.flow.touch.bean.TaskParam;
|
|
|
import com.winhc.dataworks.flow.touch.configuration.DataWorksAccessProperties;
|
|
|
+import com.winhc.dataworks.flow.touch.utils.JsonUtils;
|
|
|
import lombok.SneakyThrows;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
|
@@ -43,4 +47,43 @@ public class TouchService {
|
|
|
return response;
|
|
|
}
|
|
|
|
|
|
+
|
|
|
+ @SneakyThrows
|
|
|
+ public CreateManualDagResponse touch(TaskParam taskParam) {
|
|
|
+ log.info("触发任务:{}", taskParam.toString());
|
|
|
+ CreateManualDagRequest request = new CreateManualDagRequest();
|
|
|
+ request.setProjectName(taskParam.getProjectName());
|
|
|
+ request.setFlowName(taskParam.getFlowName());
|
|
|
+ request.setBizdate(taskParam.getBizDate() + " 00:00:00");
|
|
|
+ request.setRegionId(dataWorksAccessProperties.getRegionId());
|
|
|
+ request.setProtocol(ProtocolType.HTTP);
|
|
|
+ request.setNodePara(JsonUtils.jsonObjToString(taskParam.getNodeParam()));
|
|
|
+ CreateManualDagResponse response = client.getAcsResponse(request);
|
|
|
+ log.info("\n任务结果:\n\trequestId:{},\n\treturnCode:{},\n\treturnErrorSolution:{},\n\treturnMessage:{},\n\treturnValue:{}",
|
|
|
+ response.getRequestId()
|
|
|
+ , response.getReturnCode()
|
|
|
+ , response.getReturnErrorSolution()
|
|
|
+ , response.getReturnMessage()
|
|
|
+ , response.getReturnValue());
|
|
|
+ return response;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ @SneakyThrows
|
|
|
+ public void query(String projectName, Long dagId) {
|
|
|
+ SearchManualDagNodeInstanceRequest searchNodeInstanceListRequest
|
|
|
+ = new SearchManualDagNodeInstanceRequest();
|
|
|
+ searchNodeInstanceListRequest.setDagId(dagId);
|
|
|
+ searchNodeInstanceListRequest.setProjectName(projectName); //项目名。
|
|
|
+ searchNodeInstanceListRequest.setProtocol(ProtocolType.HTTP);
|
|
|
+ SearchManualDagNodeInstanceResponse searchResponse = client
|
|
|
+ .getAcsResponse(searchNodeInstanceListRequest); //查询实例。
|
|
|
+ java.util.List<SearchManualDagNodeInstanceResponse.NodeInsInfo> nodeInsfos = searchResponse.getData();
|
|
|
+ System.out.println(searchResponse.getErrMsg()); //错误码。0代码正常;非0数值代表报错。
|
|
|
+ for (SearchManualDagNodeInstanceResponse.NodeInsInfo nodeInsInfo : nodeInsfos) {
|
|
|
+ System.out.println(nodeInsInfo.getNodeName()); //输出节点名称。
|
|
|
+ System.out.println(nodeInsInfo.getStatus()); //输出状态信息。
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
}
|