用于触发生成新的手动业务流程实例,本SDK仅适用于DataWorks V2.0。

参数信息

参数名 类型 说明
projectName STRING 必选,项目名称。
FlowName STRING 必选,手动业务流程名称。
bizdate STRING 必选,格式为yyyy-MM-dd hh:mm:ss
DagPara STRING 可选,格式为{"key1":"value1","key2":"value2"}。
NodePara STRING 可选,格式为"节点ID": "key1=value1 key2=value2"
说明 如果您希望DagPara参数在节点中生效,需要在NodePara定义对应的同名参数,DagPara的同名参数会覆盖NodePara中的参数。

代码说明

标准调用代码格式如下所示:
@Test
public void createManualDagTest() throws ClientException { 
  CreateManualDagRequest request = new CreateManualDagRequest();
  request.setProjectName("UPPER_CASE_PROJECT2");
  request.setFlowName("test_flow");
  request.setBizdate("2018-07-25 00:00:00");
  request.setDagPara("dagppp,dagvvv");
   JsonObject dagPara = new JsonObject();
   dagPara.addProperty("key1","5");
   dagPara.addProperty("key2","6");
   request.setDagPara(dagPara.toString());
  resquest.setRegionId("cn-shanghai")// 需要在此处更新项目所在Region。
  JsonObject nodePara = new JsonObject();
  nodePara.addProperty("220168343", "aaaa=bbbb"); //配置调用和节点参数。
  System.out.println(nodePara.toString());
  request.setNodePara(nodePara.toString());

  DefaultProfile.addEndpoint(
    "cn-shanghai",  //对应DataWorks工作空间所在的Region ID。
    "cn-shanghai",  //对应DataWorks工作空间所在的Region ID。
    "dataworks-public",
    "dataworks.aliyuncs.com");
  DefaultProfile profile = DefaultProfile.getProfile(
    <regionId>,<accessKeyId>,<secret>); // 填写实际的RegionID、AccessKeyID和AccessKeySecret。
  IAcsClient client = new DefaultAcsClient(profile);
  request.setProtocol(ProtocolType.HTTP);
  CreateManualDagResponse response = client.getAcsResponse(request); //调用客户端。
  System.out.println(response.getRequestId());
  System.out.println(response.getReturnCode());
  System.out.println(response.getReturnErrorSolution());
  System.out.println(response.getReturnMessage());
  System.out.println(response.getReturnValue()); //输出响应。
}

使用示例

  1. 创建任务并提交发布。


  2. 编辑运行内容,此处以使用Eclipse为例。

    具体代码如下:
    package MavenDemo.MavenDemo;
    
    import org.junit.Test;
    import com.aliyuncs.DefaultAcsClient;
    import com.aliyuncs.IAcsClient;
    import com.aliyuncs.dataworks_public.model.v20180601.CreateManualDagRequest;
    import com.aliyuncs.dataworks_public.model.v20180601.CreateManualDagResponse;
    import com.aliyuncs.http.ProtocolType;
    import com.aliyuncs.profile.DefaultProfile;
    import com.google.gson.JsonObject;
    
    public class sdk {
    
      @Test
      public void createManualDagTest() throws Exception { 
        CreateManualDagRequest request = new CreateManualDagRequest();
        request.setProjectName("hello_sh_sh");//项目名称。
        request.setFlowName("test_flow");//手动业务流程名称。
        request.setBizdate("2019-03-20 00:00:00");//运行的业务时间,注意日期应为当前日期的前一天。
        JsonObject dagPara = new JsonObject();
        dagPara.addProperty("ssss","testsetstsetsetest");//业务流程参数。
        request.setDagPara(dagPara.toString());
        request.setRegionId("cn-shanghai");// 需要在此处更新项目所在Region。
        JsonObject nodePara = new JsonObject();
        nodePara.addProperty("700000246408", "ssss=oooo"); //配置节点参数,如果业务流程配置节点参数不生效。
        System.out.println(nodePara.toString());
        request.setNodePara(nodePara.toString());
        DefaultProfile.addEndpoint(
          "cn-shanghai",  //对应DataWorks工作空间所在的Region ID。
          "cn-shanghai",  //对应DataWorks工作空间所在的Region ID。
          "dataworks-public",//固定值。
          "dataworks.aliyuncs.com");//访问DataWorks地址。
        DefaultProfile profile = DefaultProfile.getProfile("cn-shanghai","LTAI**************","OU9g38cCpT***********"); // 填写实际的RegionID、AccessKeyID和AccessKeySecret。
        IAcsClient client = new DefaultAcsClient(profile);
        request.setProtocol(ProtocolType.HTTP);
        CreateManualDagResponse response = client.getAcsResponse(request); //调用客户端。
        System.out.println(response.getRequestId());//
        System.out.println(response.getReturnCode());//
        System.out.println(response.getReturnErrorSolution());//
        System.out.println(response.getReturnMessage());//
        System.out.println(response.getReturnValue()); //输出响应。
      }
    
      public static void main(String[] args) {
    
      }
    }
  3. 运行任务。
    该操作相当于您在运维中心触发手动任务的运行按钮。