public static void main()

in schedulerx-demo/schedulerx-example-api/src/main/java/com/aliyun/schedulerx/example/api/TestDesignateWorkers.java [27:66]


    public static void main(String[] args) {
     // Open API 的接入点,具体查看上表支持地域列表以及购买机器地域填写
        String regionId = "public";
      //鉴权使用的 AccessKeyId,由阿里云官网控制台获取
        String accessKeyId = "xxxxxxxx";
        //鉴权使用的 AccessKeySecret,由阿里云官网控制台获取
        String accessKeySecret = "xxxxxxxxx";
        //产品名称
        String productName ="schedulerx2";
        //对照支持地域列表选择Domain填写
        String domain ="schedulerx.aliyuncs.com";
        //构建 OpenApi 客户端
        DefaultProfile.addEndpoint(regionId, productName, domain);
        DefaultProfile defaultProfile = DefaultProfile.getProfile(regionId, accessKeyId, accessKeySecret);
        DefaultAcsClient client = new DefaultAcsClient(defaultProfile);
        
        DesignateWorkersRequest request = new DesignateWorkersRequest();
        request.setNamespace("433d8b23-06e9-408c-aaaa-90d4d1b9a4af");
        request.setGroupId("xuren_test");
        request.setJobId(3048L);
        //是否故障转移
        request.setTransferable(true);
        //1表示指定worker,2表示指定label
        request.setDesignateType(1);
        List<String> workers = new ArrayList<>();
        workers.add("30.225.16.104");
        //workers需要json格式
        request.setWorkers(new Gson().toJson(workers));
        DesignateWorkersResponse response;
        try {
            response = client.getAcsResponse(request);
            System.out.println(new Gson().toJson(response));
        } catch (ServerException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (ClientException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }