全部产品
存储与CDN 数据库 安全 应用服务 数加·人工智能 数加·大数据基础服务 互联网中间件 视频服务 阿里云办公 培训与认证 物联网
批量计算

创建集群

更新时间:2017-07-12 11:20:53

createCluster

方法说明:

创建一个集群。

参数说明:

参数 类型 是否必需 说明
clusterDescription ClusterDescription 构建集群的描述。

下面类的包名都是: com.aliyuncs.batchcompute.pojo.v20151111

(1) ClusterDescription的属性(都有getter和setter方法)

属性 类型 是否必需 说明
name String 集群名称。
description String 作业的简短描述信息。
imageId String 支持ECS镜像ID和注册的镜像ID。
groups Map<String, GroupDescription> 实例组。
instanceType String 构建集群的实例类型。不同region支持的实例类型不一样。
userData Map<String, String> 用户数据
configs Configs 集群的一些配置信息,比如实例的磁盘配置,由Configs描述。
notification Notification 消息通知配置,可以配置MNS服务的Topic和Cluster相关事件.

(2) GroupDescription 的属性(都有getter和setter方法)

属性 类型 是否必需 说明
desiredVMCount int 期望启动实例数。
instanceType String 实例类型。
resourceType String 资源类型,目前只支持且默认为:”OnDemand”。

(3) Notification的属性(都有getter和setter方法)

属性 类型 是否必需 描述
topic Topic 消息Topic

(4) Topic 的属性(都有getter和setter方法)

属性 类型 是否必需 描述
endpoint String MNS区域endpoint,格式如: http://${your_user_id}.mns.${region}-internal.aliyuncs.com/ ,请尽量使用内网Endpoint。
name String Topic名称。
events List<String> 事件列表,请填写cluster相关的事件。

返回值说明:

  • 创建成功后返回一个CreateClusterResponse实例,可以通过 response.getClusterId() 获取创建的集群ID。
类型 说明
CreateClusterResponse 可以获取创建成功的clusterId。

CreateClusterResponse的包名为:com.aliyuncs.batchcompute.model.v20151111,下面的其他Response都是在这个包下面。

  • 创建失败后,抛出异常: ClientException。

代码示例:

  1. package com.aliyuncs.batchcompute.sample.v20151111;
  2. import com.aliyuncs.batchcompute.main.v20151111.*;
  3. import com.aliyuncs.batchcompute.model.v20151111.*;
  4. import com.aliyuncs.batchcompute.pojo.v20151111.*;
  5. import com.aliyuncs.exceptions.ClientException;
  6. public class CreateCluster {
  7. public static void main(String[] args) {
  8. BatchCompute client = new BatchComputeClient("cn-shenzhen", "your_access_id", "your_access_secret");
  9. try {
  10. ClusterDescription clusterDescription = getClusterDesc();
  11. CreateClusterResponse response = client.createCluster(clusterDescription);
  12. String clusterId = response.getClusterId();
  13. //创建成功
  14. System.out.println("Got cluster id:" + clusterId);
  15. } catch (ClientException e) {
  16. e.printStackTrace();
  17. //创建失败
  18. }
  19. }
  20. private static ClusterDescription getClusterDesc(){
  21. ClusterDescription desc = new ClusterDescription();
  22. desc.setName("cluster_test");
  23. desc.setImageId("img-ubuntu");
  24. desc.setDescription("demo");
  25. GroupDescription groupDesc = new GroupDescription();
  26. groupDesc.setDesiredVMCount(1);
  27. groupDesc.setInstanceType("ecs.s3.large");
  28. groupDesc.setResourceType("OnDemand");
  29. desc.addGroup("group1", groupDesc);
  30. return desc;
  31. }
  32. }
本文导读目录