您可以使用SDK调用分布式任务调度的API,完成日常的管理操作。

在应用程序的pom.xml文件中添加OpenAPI的SDK依赖。

<dependency>
      <groupId>com.aliyun</groupId>
      <artifactId>aliyun-java-sdk-schedulerx2</artifactId>
      <version>1.0.0</version>
 </dependency>

 <dependency>
     <groupId>com.aliyun</groupId>
     <artifactId>aliyun-java-sdk-core</artifactId>
     <version>4.3.3</version>
 </dependency>       

使用子账号调用

您可以使用子账号(RAM)调用分布式任务调度的API,但需要先获取、配置子账号的Access Key ID和Access Key Secret,并由主账号对子账号授予相应的资源的操作权限。

支持地域列表

在使用SDK调用API的时候需要用到地域的Region ID、Domain等信息,参见下面的表格。

说明 下表中Domain(VPC)适用于没有公网的VPC的环境。
名称 RegionId Domain Domain(VPC)
华东1 cn-hangzhou schedulerx.cn-hangzhou.aliyuncs.com schedulerx-vpc.cn-hangzhou.aliyuncs.com
华南1 cn-shenzhen schedulerx.cn-shenzhen.aliyuncs.com schedulerx-vpc.cn-shenzhen.aliyuncs.com
华东2 cn-shanghai schedulerx.cn-shanghai.aliyuncs.com schedulerx-vpc.cn-shanghai.aliyuncs.com
华北2 cn-beijing schedulerx.cn-beijing.aliyuncs.com schedulerx-vpc.cn-beijing.aliyuncs.com

使用SDK调用API

下面以一个通用的示例说明如何使用SDK调用API。

public static void main(String[] args) throws Exception{
         // OpenAPI的接入点,具体参见支持地域列表和购买实例的地域String regionId = "XXXXX";
     //鉴权使用的Access Key ID
     String accessKeyId = "XXXXXXXXXXXXXXXXX";
     //鉴权使用的Access Key Secret
     String accessKeySecret = "XXXXXXXXXXXXXXXXX";
     //产品名称String productName ="schedulerx2";
     //参见支持地域列表,选择Domain
     String domain ="schedulerx.xxxx.aliyuncs.com";
     //构建OpenApi客户端DefaultProfile.addEndpoint(regionId, productName, domain);
     DefaultProfile defaultProfile = DefaultProfile.getProfile(regionId, accessKeyId, accessKeySecret);
     DefaultAcsClient defaultAcsClient = new DefaultAcsClient(defaultProfile);
         //构建接口请求(根据接口中参数类型和是否必填进行填充)
     EnableJobRequest request = new EnableJobRequest();
     request.setJobId(jobId);
     request.setNamespace("xxxxxx");
     request.setGroupId("yyyyyy");
     //发送请求EnableJobResponse response = defaultAcsClient.getAcsResponse(request);
     if (!response.getSuccess()) {
         System.out.println(response.getMessage());
         System.out.println("EnableJob: "+response.getRequestId());
     }
}