AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

阿里云抢占实例OpenApi入门实践

2017-10-23 4210
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 本文目标是介绍开发者如何通过阿里云ECS SDK，合理快速的创建需要的SPOT竞价实例

阿里云竞价实例OpenApi入门实践

目的

本文目标是介绍开发者如何通过阿里云ECS SDK，合理快速的创建需要的抢占实例

准备工作：

  • 首先要熟悉了解阿里云SDK的基础知识和调用方法，可以参考SDK 使用说明
  • Spot竞价实例代码需要依赖的ECS SDK版本4.2.0 以上，
  • 以JAVA POM依赖举例，修改引入pom依赖：
<dependency>
    <groupId>com.aliyun</groupId>
    <artifactId>aliyun-java-sdk-core</artifactId>
    <version>3.2.8</version>
</dependency>
<dependency>
    <groupId>com.aliyun</groupId>
    <artifactId>aliyun-java-sdk-ecs</artifactId>
    <version>4.2.0</version>
</dependency>



## 哪些地域与规格可以购买竞价实例：

> 典型一个场景，我需要创建一批价格便宜量又足的计算资源，做业务数据处理。
但我不知道去哪个地域去创建需要的计算资源。
我们需要规划下对计算资源的大致需求：
1. 地域，创建的竞价实例哪个地域创建。
2. 规格  根据你的业务需求确定什么样规格实例

> 但是由于目前aliyun 每个地域因为售卖比率不同，每个地域可用对外开放售卖的规格存在很大差异。
所以建议通过DesribeZones接口来获取您的账户可创建的地域与规格信息，帮助您选择地域和规格。
* API名称： DesribeZones
* API说明：https://help.aliyun.com/document_detail/25610.html
* 代码示例：

>  OpenApiCaller.java

public class OpenApiCaller {

IClientProfile profile;
IAcsClient client;

public OpenApiCaller() {
    profile = DefaultProfile.getProfile("cn-hangzhou", AKSUtil.accessKeyId, AKSUtil.accessKeySecret);
    client = new DefaultAcsClient(profile);
}

public  <T extends AcsResponse> T doAction(AcsRequest<T> var1) {
    try {
        return  client.getAcsResponse(var1);
    } catch (Throwable e) {
        e.printStackTrace();
        return null;
    }
}

｝


> DescribeZonesSample.java

public class DescribeZonesSample {

public static void main(String[] args) {

    OpenApiCaller caller = new OpenApiCaller();
    DescribeZonesRequest request = new DescribeZonesRequest();
    request.setRegionId("cn-zhangjiakou");//可以通过DescribeRegionsRequest获取每个地域的regionId
    request.setSpotStrategy("SpotWithPriceLimit");//对于查询是否可购买竞价实例此项必填
    request.setInstanceChargeType("PostPaid");//后付费模式，竞价实例必须是后付费模式
    DescribeZonesResponse response = caller.doAction(request);
    System.out.println(JSON.toJSONString(response));

}

}

输出结果：

{

"requestId": "388D6321-E587-470C-8CFA-8985E2963DAE",
"zones": [
    {

        "localName": "华北 3 可用区 A",
        "zoneId": "cn-zhangjiakou-a",
        "availableDiskCategories": [
            "cloud_ssd",
            "cloud_efficiency"
        ],
        "availableInstanceTypes": [
            "ecs.e4.large",
            "ecs.n4.4xlarge",
            "ecs.sn2.medium",
            "ecs.i1.2xlarge",
            "ecs.se1.2xlarge",
            "ecs.n4.xlarge",
            "ecs.se1ne.2xlarge",
            "ecs.se1.large",
            "ecs.sn2.xlarge",
            "ecs.se1ne.xlarge",
            "ecs.xn4.small",
            "ecs.sn2ne.4xlarge",
            "ecs.se1ne.4xlarge",
            "ecs.sn1.medium",
            "ecs.n4.8xlarge",
            "ecs.mn4.large",
            "ecs.e4.2xlarge",
            "ecs.mn4.2xlarge",
            "ecs.mn4.8xlarge",
            "ecs.n4.2xlarge",
            "ecs.e4.xlarge",
            "ecs.sn2ne.large",
            "ecs.sn2ne.xlarge",
            "ecs.sn1ne.large",
            "ecs.n4.large",
            "ecs.sn1.3xlarge",
            "ecs.e4.4xlarge",
            "ecs.sn1ne.2xlarge",
            "ecs.e4.small",
            "ecs.i1.4xlarge",
            "ecs.se1.4xlarge",
            "ecs.sn2ne.2xlarge",
            "ecs.sn2.3xlarge",
            "ecs.i1.xlarge",
            "ecs.n4.small",
            "ecs.sn1ne.4xlarge",
            "ecs.mn4.4xlarge",
            "ecs.sn1ne.xlarge",
            "ecs.se1ne.large",
            "ecs.sn2.large",
            "ecs.i1-c5d1.4xlarge",
            "ecs.sn1.xlarge",
            "ecs.sn1.large",
            "ecs.mn4.small",
            "ecs.mn4.xlarge",
            "ecs.se1.xlarge"
        ],
        "availableResourceCreation": [
            "VSwitch",
            "IoOptimized",
            "Instance",
            "Disk"
        ],
        "availableResources": [
            {
                "dataDiskCategories": [
                    "cloud_ssd",
                    "cloud_efficiency"
                ],
                "instanceGenerations": [
                    "ecs-3",
                    "ecs-2"
                ],
                "instanceTypeFamilies": [
                    "ecs.mn4",
                    "ecs.sn1",
                    "ecs.sn2",
                    "ecs.sn1ne",
                    "ecs.xn4",
                    "ecs.i1",
                    "ecs.se1",
                    "ecs.e4",
                    "ecs.n4",
                    "ecs.se1ne",
                    "ecs.sn2ne"
                ],
                "instanceTypes": [
                    "ecs.n4.4xlarge",
                    "ecs.sn2.medium",
                    "ecs.i1.2xlarge",
                    "ecs.se1.2xlarge",
                    "ecs.n4.xlarge",
                    "ecs.se1ne.2xlarge",
                    "ecs.se1.large",
                    "ecs.sn2.xlarge",
                    "ecs.se1ne.xlarge",
                    "ecs.xn4.small",
                    "ecs.sn2ne.4xlarge",
                    "ecs.se1ne.4xlarge",
                    "ecs.sn1.medium",
                    "ecs.n4.8xlarge",
                    "ecs.mn4.large",
                    "ecs.mn4.2xlarge",
                    "ecs.mn4.8xlarge",
                    "ecs.n4.2xlarge",
                    "ecs.sn2ne.large",
                    "ecs.sn2ne.xlarge",
                    "ecs.sn1ne.large",
                    "ecs.n4.large",
                    "ecs.sn1.3xlarge",
                    "ecs.sn1ne.2xlarge",
                    "ecs.e4.small",
                    "ecs.i1.4xlarge",
                    "ecs.se1.4xlarge",
                    "ecs.sn2ne.2xlarge",
                    "ecs.sn2.3xlarge",
                    "ecs.i1.xlarge",
                    "ecs.n4.small",
                    "ecs.sn1ne.4xlarge",
                    "ecs.mn4.4xlarge",
                    "ecs.sn1ne.xlarge",
                    "ecs.se1ne.large",
                    "ecs.sn2.large",
                    "ecs.i1-c5d1.4xlarge",
                    "ecs.sn1.xlarge",
                    "ecs.sn1.large",
                    "ecs.mn4.small",
                    "ecs.mn4.xlarge",
                    "ecs.se1.xlarge"
                ],
                "ioOptimized": true,
                "networkTypes": [
                    "vpc"
                ],
                "systemDiskCategories": [
                    "cloud_ssd",
                    "cloud_efficiency"
                ]
            }
        ],
        "availableVolumeCategories": [
            "san_ssd",
            "san_efficiency"
        ]
    }
]

}



## 通过查询spot历史价格接口来获得最佳性价比的地域，规格信息

通过上一步我们可以基本确定哪个可用区可以生产的哪些具体规格，有了这些信息就可以通过
DescribeSpotPriceHistory接口查询获取价格历史变化，最多允许获取30天内的价格变化数据。
* API名称：DescribeSpotPriceHistory
* API文档：https://help.aliyun.com/document_detail/60400.html
* 代码实例：DescribeSpotPriceHistorySample.java

public class DescribeSpotPriceHistorySample {

public static void main(String[] args) {

    OpenApiCaller caller = new OpenApiCaller();
    List<DescribeSpotPriceHistoryResponse.SpotPriceType> result = new ArrayList<DescribeSpotPriceHistoryResponse.SpotPriceType>();
    int offset = 0;
    while (true) {
        DescribeSpotPriceHistoryRequest request = new DescribeSpotPriceHistoryRequest();
        request.setRegionId("cn-hangzhou");//可以通过DescribeRegionsRequest获取可购买的每个地域的regionId
        request.setZoneId("cn-hangzhou-b");//可用区必填
        request.setInstanceType("ecs.sn2.medium");//参考DescribeZones 返回的实例类型，必填
        request.setNetworkType("vpc");//参考DescribeZones 返回的网络类型，必填

// request.setIoOptimized("optimized");//是否Io优化类型，DescribeZones 返回的IoOptimized，选填
// request.setStartTime("2017-09-20T08:45:08Z");//价格开始时间，选填，默认3天内数据
// request.setEndTime("2017-09-28T08:45:08Z");//价格结束时间，选填

        request.setOffset(offset);
        DescribeSpotPriceHistoryResponse response = caller.doAction(request);
        if (response != null && response.getSpotPrices() != null) {
            result.addAll(response.getSpotPrices());
        }
        if (response.getNextOffset() == null || response.getNextOffset() == 0) {
            break;
        } else {
            offset = response.getNextOffset();
        }
    }
    if (!result.isEmpty()) {
        for (DescribeSpotPriceHistoryResponse.SpotPriceType spotPriceType : result) {
            System.out.println(spotPriceType.getTimestamp() + "--->spotPrice:" + spotPriceType.getSpotPrice() + "---->originPrice:" + spotPriceType.getOriginPrice());
        }
        System.out.println(result.size());
    } else {
    }

}

}


* 返回结果

2017-09-26T06:28:55Z--->spotPrice:0.24---->originPrice:1.2
2017-09-26T14:00:00Z--->spotPrice:0.36---->originPrice:1.2
2017-09-26T15:00:00Z--->spotPrice:0.24---->originPrice:1.2
2017-09-27T14:00:00Z--->spotPrice:0.36---->originPrice:1.2
2017-09-27T15:00:00Z--->spotPrice:0.24---->originPrice:1.2
2017-09-28T14:00:00Z--->spotPrice:0.36---->originPrice:1.2
2017-09-28T15:00:00Z--->spotPrice:0.24---->originPrice:1.2
2017-09-29T06:28:55Z--->spotPrice:0.24---->originPrice:1.2


* 重复以上步骤，您可以判断出该规格资源在可用区的价格变化趋势和最近价格。
* 简单的策略通过平均价格和最高价格来决定是否可以接受购买该spot实例。
* 当然从最小成本出发，可以通过更加合理的数据模型来分析价历史价格数据，随时调整创建资源的规格和可用区，到达最佳性价比。


## 创建Spot实例

通过以上过程，我们最终得到可以创建的资源的地域信息，规格属性，磁盘，网络等信息。
现在就可以开始真正创建竞价实例了。
* API名称：CreateInstance
* 建议您提前在控制台或者openapi方式 在需要创建vm资源的地区创建好vpc专有网络，获取创建参数vswitchId
* 建议您提前在控制台或者openapi方式 在需要创建vm资源的地区创建安全组,获取创建参数：SecurityGroupId

* 接口文档：https://help.aliyun.com/document_detail/25499.html
* 示例代码：CreateInstaneSample.java

public class CreateInstaneSample {

public static void main(String[] args) {
    OpenApiCaller caller = new OpenApiCaller();
    CreateInstanceRequest request = new CreateInstanceRequest();
    request.setRegionId("cn-hangzhou");//地域Id
    request.setZoneId("cn-hangzhou-b"); //可用区Id
    request.setSecurityGroupId("sg-bp11nhf94ivkdxwb2gd4");//提前创建的安全组Id
    request.setImageId("centos_7_03_64_20G_alibase_20170818.vhd");//建议选择您自己在该地域准备的自定义镜像
    request.setVSwitchId("vsw-bp164cyonthfudn9kj5br");//vpc 类型需要虚拟路由Id

    request.setInstanceType("ecs.sn2.medium"); //填入您询价后需要购买的规格
    request.setIoOptimized("optimized");//参考 DescirbeZones返回参数
    request.setSystemDiskCategory("cloud_ssd");//参考 DescirbeZones返回参数，多选一 cloud_ssd，cloud_efficiency，cloud
    request.setSystemDiskSize(40);

    request.setInstanceChargeType("PostPaid");//竞价实例必须后付费
    request.setSpotStrategy("SpotWithPriceLimit");//SpotWithPriceLimit出价模式，SpotAsPriceGo不用出价，最高按量付费价格
    request.setSpotPriceLimit(0.25F);//SpotWithPriceLimit出价模式生效，用户您能接受的最高价格,单元元每小时,必须高于当前的公共价格才能成功

    CreateInstanceResponse response = caller.doAction(request);
    System.out.println(response.getInstanceId());

}

}


## spot实例中断

* 竞价实例可能会因为价格因素或者其他ecs内部库存因素会强制回收竞价资源，此时会触发spot的中断
* 在真正开始释放vm前 vm 会进入锁定状态， 提示vm 将会被自动回收，您可以针对vm 回收状态来自动化处理实例的退出逻辑
* 目前spot的中断锁定状态可以通过2种方式来感知
1.  vpc 实例可以通过metadata 来获取

* metadata访问示例：

curl 'http://100.100.100.200/latest/meta-data/instance/spot/termination-time'
返回格式示例：2015-01-05T18:02:00Z，时间为UTC时间，如果返回为空，说明可持续使用


2.  通过查询 describeInstances 返回的OperationLocks 感知是否vm进入准备回收状态

* openapi获取锁定状态代码示例：DescribeInstancesSample.java

public class DescribeInstancesSample {

public static void main(String[] args) throws InterruptedException {
    OpenApiCaller caller = new OpenApiCaller();
    JSONArray allInstances = new JSONArray();
    allInstances.addAll(Arrays.asList("i-bp18hgfai8ekoqwo0y2n", "i-bp1ecbyds24ij63w146c"));
    while (!allInstances.isEmpty()) {
        DescribeInstancesRequest request = new DescribeInstancesRequest();
        request.setRegionId("cn-hangzhou");
        request.setInstanceIds(allInstances.toJSONString());//指定实例Id，效率最高
        DescribeInstancesResponse response = caller.doAction(request);
        List<DescribeInstancesResponse.Instance> instanceList = response.getInstances();
        if (instanceList != null && !instanceList.isEmpty()) {
            for (DescribeInstancesResponse.Instance instance : instanceList) {
                System.out.println("result:instance:" + instance.getInstanceId() + ",az:" + instance.getZoneId());
                if (instance.getOperationLocks() != null) {
                    for (DescribeInstancesResponse.Instance.LockReason lockReason : instance.getOperationLocks()) {
                        System.out.println("instance:" + instance.getInstanceId() + "-->lockReason:" + lockReason.getLockReason() + ",vmStatus:" + instance.getStatus());
                        if ("Recycling".equals(lockReason.getLockReason())) {
                            //do your action
                            System.out.println("spot instance will be recycled immediately, instance id:" + instance.getInstanceId());
                            allInstances.remove(instance.getInstanceId());
                        }
                    }
                }
            }
            System.out.print("try describeInstances again later ...");
            Thread.sleep(2 * 60 * 1000);
        } else {
            break;
        }
    }

}

}


触发回收时输出结果：

instance:i-bp1ecbyds24ij63w146c-->lockReason:Recycling,vmStatus:Stopped
spot instance will be recycled immediately, instance id:i-bp1ecbyds24ij63w146c


## 启动，关机，释放 SPOT竞价实例

启动，停止，释放实例Spot 实例和其他实例没有任何区别，本文不再介绍，请参看相关api文档即可。
文章标签：
云服务器 ECS
专有网络VPC
Java
API
开发工具
弹性计算
关键词：
阿里云openapi
openapi实例
openapi阿里云
实例openapi
OpenAPI Explorer实例
相关实践学习
2分钟自动化部署人生模拟器
本场景将带你借助云效流水线Flow实现人生模拟器小游戏的自动化部署
7天玩转云服务器
云服务器ECS（Elastic Compute Service）是一种弹性可伸缩的计算服务，可降低 IT 成本，提升运维效率。本课程手把手带你了解ECS、掌握基本操作、动手实操快照管理、镜像管理等。了解产品详情:&nbsp;https://www.aliyun.com/product/ecs
抹达
目录
相关文章
vohelon
|
6月前
|
JavaScript API 开发工具
阿里云OpenAPI AssignJobs返回404错误可能有以下几个原因：
【2月更文挑战第20天】阿里云OpenAPI AssignJobs返回404错误可能有以下几个原因：
vohelon
164 1
三分钟热度的鱼
|
6月前
|
域名解析 弹性计算 tengine
阿里云DNS常见问题之阿里云OpenAPI判断域名的dns服务器是否在阿里云失败如何解决
阿里云DNS（Domain Name System）服务是一个高可用和可扩展的云端DNS服务，用于将域名转换为IP地址，从而让用户能够通过域名访问云端资源。以下是一些关于阿里云DNS服务的常见问题合集：
三分钟热度的鱼
193 0
lsug6eziqmdfk1111
|
1月前
|
弹性计算 网络安全
阿里云国际OpenAPI多接口快速管理ECS服务器教程
阿里云国际OpenAPI多接口快速管理ECS服务器教程
lsug6eziqmdfk1111
44 0
开放平台助手
|
1月前
|
IDE API 开发工具
沉浸式集成阿里云 OpenAPI｜Alibaba Cloud API Toolkit for VS Code
Alibaba Cloud API Toolkit for VSCode 是集成了 OpenAPI 开发者门户多项功能的 VSCode 插件，开发者可以通过这个插件方便地查找API文档、进行API调试、插入SDK代码，并配置基础环境设置。我们的目标是缩短开发者在门户和IDE之间的频繁切换，实现API信息和开发流程的无缝结合，让开发者的工作变得更加高效和紧密。
开放平台助手
488 3
沉浸式集成阿里云 OpenAPI｜Alibaba Cloud API Toolkit for VS Code
阿里云云原生
|
5月前
|
存储 监控 数据可视化
基于阿里云 OpenAPI 插件，让 Grafana 轻松实现云上数据可视化
本文旨在提供一个指导性的框架，帮助用户了解插件的安装、配置以及探索如何通过 Grafana 内的阿里云 OpenAPI 插件来对云上数据进行可视化和快速验证开发原型，加强数据可视化和云监控能力，助力开发速度。
阿里云云原生
33529 18
开放平台助手
|
3月前
|
IDE API 开发工具
通过IDE插件体验阿里云OpenAPI的高效集成， 精品礼品等你来拿！
轻量级的开放API工具——Alibaba Cloud Developer Toolkit及Alibaba Cloud API Toolkit。这些插件支持快速查阅阿里云产品的开放API，提供API调试与SDK示例生成等功能，帮助开发者轻松集成阿里云服务。您可通过JetBrains Marketplace或VS Code Marketplace搜索安装，完成身份验证后即刻体验。欢迎分享您的使用反馈，有机会获得精美礼品！
开放平台助手
58 0
嘟嘟嘟嘟嘟嘟
|
4月前
|
敏捷开发 测试技术 持续交付
阿里云云效产品使用合集之OpenAPI列表可以在什么地方查看
云效作为一款全面覆盖研发全生命周期管理的云端效能平台，致力于帮助企业实现高效协同、敏捷研发和持续交付。本合集收集整理了用户在使用云效过程中遇到的常见问题，问题涉及项目创建与管理、需求规划与迭代、代码托管与版本控制、自动化测试、持续集成与发布等方面。
嘟嘟嘟嘟嘟嘟
69 0
三分钟热度的鱼
|
6月前
|
域名解析 网络协议 API
阿里云DNS常见问题之阿里云OpenAPI的cdn20180510包没有DescribeCdnSubList如何解决
阿里云DNS（Domain Name System）服务是一个高可用和可扩展的云端DNS服务，用于将域名转换为IP地址，从而让用户能够通过域名访问云端资源。以下是一些关于阿里云DNS服务的常见问题合集：
三分钟热度的鱼
95 2
vohelon
|
6月前
|
消息中间件 API PHP
阿里云OpenAPI RocketMQ 5.0的PHP收发消息文档
【2月更文挑战第23天】阿里云OpenAPI RocketMQ 5.0的PHP收发消息文档
vohelon
359 7
sunrr
|
6月前
|
弹性计算 网络安全
阿里云OpenAPI提供了多种接口来管理ECS实例
【2月更文挑战第1天】阿里云OpenAPI提供了多种接口来管理ECS实例
sunrr
83 0

热门文章

最新文章

  • 1
    使用OpenApi弹性创建云服务器ECS
  • 2
    基于专有云EDAS OpenAPI构建企业级云原生CICD——Series1：概述及准备
  • 3
    Java程序如何通过阿里云OpenAPI调用短信接口
  • 4
    OpenAPI开发者挑战赛第三期——是时候展现真正的“码术”了！
  • 5
    OpenAPI变更日志全新上线
  • 6
    Kubernetes官方java客户端之六：OpenAPI基本操作
  • 7
    使用 OpenAPI 构建 API 文档
  • 8
    云服务OpenAPI的7大挑战，架构师如何应对？ | 开发者必读（081期）
  • 9
    如何集成PTS的JMeter OpenAPI搭建压测平台
  • 10
    使用阿里云OpenAPI专有云ASO产品
  • 1
    【Ant Design Pro】使用ant design pro做为你的开发模板（六）OpenAPI，快速管理你的请求接口
    1107
  • 2
    一套满足企业自建OpenAPI、接口平台的解决方案、产品和源代码
    1495
  • 3
    Kubernetes官方java客户端之六：OpenAPI基本操作
    796
  • 4
    通过OpenAPI管理Dataphin的成员
    427
  • 5
    阿里云openapi接口使用，PHP，视频直播
    3721
  • 6
    PolarDB-X 1.0-API参考-1.0（2017版本）-OpenAPI简介
    173
  • 7
    PolarDB-X 1.0-API参考-1.0（2017版本）-OpenAPI使用-资源授权
    149
  • 8
    PolarDB-X 1.0-API参考-1.0（2017版本）-OpenAPI使用-SDK 说明
    215
  • 9
    PolarDB-X 1.0-API参考-1.0（2017版本）-OpenAPI使用-公共参数
    145
  • 10
    PolarDB-X 1.0-API参考-1.0（2017版本）-OpenAPI使用-请求结构
    148

    • 相关课程

    更多
  • 阿里云资源编排ROS使用教程

    • 相关电子书

    更多
  • AutoTalk第七期：自动化工具-OpenAPI在线调试
  • 最大化阿里云OpenAPI能力的方法和实践
  • AutoTalk第六期：自动化工具-OpenAPI错误诊断
    • 下一篇
    无影云桌面