使用OpenApi弹性创建云服务器ECS

本文涉及的产品
云服务器ECS,u1 2核4GB 1个月
推荐场景:
2048小游戏搭建
云服务器 ECS,每月免费额度280元 3个月
简介: 除了可以在ECS控制台或者售卖页创建ECS之外,您可以使用OpenApi代码来弹性的创建和管理ECS。这里使用Python来作例子。 开通按量付费产品,您的账户余额不得少于100元,更多的需求参见ECS 使用须知,您需要在阿里云的费用中心确保自己的余额充足。
+关注继续查看

除了可以在ECS控制台或者售卖页创建ECS之外,您可以使用OpenApi代码来弹性的创建和管理ECS。这里使用Python来作例子。

开通按量付费产品,您的账户余额不得少于100元,更多的需求参见ECS 使用须知,您需要在阿里云的费用中心确保自己的余额充足。

创建ECS的有下面几个API需要关注:

按量的云服务器创建

创建一台云服务器有很多关键参数,下面几个是必选属性:

  • SecurityGroupId: 安全组Id,安全组通过安全组防火墙规则配置实现对一组实例的防火墙配置。保护您的实例的网络出入请求。在设置安全组的出入规则的时候建议按需开放而不要默认开放所有的出入规则。您也可以通过ECS控制台创建安全组进行创建。
  • InstanceType: 实例规格, 参考ECS售卖页的选项,界面上1核2GB n1.small则入参为 ecs.n1.small
  • ImageId: 镜像Id, 参考ECS控制台的镜像列表,您可以过滤系统公共镜像或者自定义镜像
  • 更多参数参考创建ECS实例来进行设置。
创建一台云服务器

创建一台云服务器也比较简单。如下面的代码就创建一台经典网络的ECS,使用的系统盘是ssd 盘参数为cloud_ssd,选择的是io优化实例optimized。代码如下:

# create one after pay ecs instance.
def create_after_pay_instance(image_id, instance_type, security_group_id):
    request = CreateInstanceRequest();
    request.set_ImageId(image_id)
    request.set_SecurityGroupId(security_group_id)
    request.set_InstanceType(instance_type)
    request.set_IoOptimized('optimized')
    request.set_SystemDiskCategory('cloud_ssd')
    response = _send_request(request)
    instance_id = response.get('InstanceId')
    logging.info("instance %s created task submit successfully.", instance_id)
    return instance_id;

创建成功会返回相应的实例id,失败的话也会有对应的ErrorCode,创建实例的参数较多,您可以参考ecs的售卖页面进行调整。

{"InstanceId":"i-***","RequestId":"006C1303-BAC5-48E5-BCDF-7FD5C2E6395D"}
云服务器生命周期

对于云服务器的状态操作, 请参考云服务器实例生命周期

只有Stopped状态的实例可以执行Start操作。也只有Running状态的ECS可以执行Stop操作。查询云服务器的状态可以通过查询实例列表传入InstanceId进行过滤, 在DescribeInstancesRequest的时候可以通过传入一个JSON数组格式的String就可以查询这个资源的状态。对于查询单个实例的状态建议使用DescribeInstances而不要使用DescribeInstanceAttribute, 因为前者比后者返回更多的属性和内容。

下面的代码会检查实例的状态,只有实例的状态符合入参才会返回实例的详情

# output the instance owned in current region.
def get_instance_detail_by_id(instance_id, status='Stopped'):
    logging.info("Check instance %s status is %s", instance_id, status)
    request = DescribeInstancesRequest()
    request.set_InstanceIds(json.dumps([instance_id]))
    response = _send_request(request)
    instance_detail = None
    if response is not None:
        instance_list = response.get('Instances').get('Instance')
        for item in instance_list:
            if item.get('Status') == status:
                instance_detail = item
                break;
        return instance_detail;
启动云服务器

创建成功后的ECS默认状态是Stopped,如果要启动ECS为Running状态, 只需要发送启动指令即可。

def start_instance(instance_id):
    request = StartInstanceRequest()
    request.set_InstanceId(instance_id)
    _send_request(request)
停止云服务器

停止云服务器也是非常的简单,只需要传入instanceId即可。

def stop_instance(instance_id):
    request = StopInstanceRequest()
    request.set_InstanceId(instance_id)
    _send_request(request)
创建时启动自动启动云服务器

服务器的启动和停止都是一个异步的操作,所以我们可以通过脚本在创建时候检测云服务器符合状态的时候执行相应的操作。

在创建资源之后得到实例id,首先判断实例是否处于Stopped的状态,如果处于Stopped状态,我们下发Start服务器的指令,然后等待服务器的状态变成 Running状态。

def check_instance_running(instance_id):
    detail = get_instance_detail_by_id(instance_id=instance_id, status=INSTANCE_RUNNING)
    index = 0
    while detail is None and index < 60:
        detail = get_instance_detail_by_id(instance_id=instance_id);
        time.sleep(10)

    if detail and detail.get('Status') == 'Stopped':
        logging.info("instance %s is stopped now.")
        start_instance(instance_id=instance_id)
        logging.info("start instance %s job submit.")

    detail = get_instance_detail_by_id(instance_id=instance_id, status=INSTANCE_RUNNING)
    while detail is None and index < 60:
        detail = get_instance_detail_by_id(instance_id=instance_id, status=INSTANCE_RUNNING);
        time.sleep(10)

    logging.info("instance %s is running now.", instance_id)
    return instance_id;

这样就完成了资源的创建。

分配公网IP

如果在创建云服务器的过程中,您指定了公网带宽,如果想要公网的访问权限还需要调用API来分配公网IP。分配公网 IP 地址可以参考这个文档来完成。

包年包月的资源创建

除了创建按量服务的云服务器,我们的API还支持创建包年包月的服务器。包年包月的创建和官网的创建流程不同,使用的是自动扣费的模式,也就是说您需要在创建服务器之前确保账号有足够的余额或者信用额度,在创建的时候将会直接扣费无需确认。

和按量付费的ECS相比我们只需要指定付费类型和时长即可,下面的时长为1个月。

    request.set_Period(1)
    request.set_InstanceChargeType('PrePaid')

创建包年包月实例的整体的代码如下

# create one prepay ecs instance.
def create_prepay_instance(image_id, instance_type, security_group_id):
    request = CreateInstanceRequest();
    request.set_ImageId(image_id)
    request.set_SecurityGroupId(security_group_id)
    request.set_InstanceType(instance_type)
    request.set_IoOptimized('optimized')
    request.set_SystemDiskCategory('cloud_ssd')
    request.set_Period(1)
    request.set_InstanceChargeType('PrePaid')
    response = _send_request(request)
    instance_id = response.get('InstanceId')
    logging.info("instance %s created task submit successfully.", instance_id)
    return instance_id;

完整的代码

完整的代码如下,您可以按照自己的资源参数进行设置。

#  coding=utf-8

# if the python sdk is not install using 'sudo pip install aliyun-python-sdk-ecs'
# if the python sdk is install using 'sudo pip install --upgrade aliyun-python-sdk-ecs'
# make sure the sdk version is 2.1.2, you can use command 'pip show aliyun-python-sdk-ecs' to check

import json
import logging
import time

from aliyunsdkcore import client
from aliyunsdkecs.request.v20140526.CreateInstanceRequest import CreateInstanceRequest
from aliyunsdkecs.request.v20140526.DescribeInstancesRequest import DescribeInstancesRequest
from aliyunsdkecs.request.v20140526.StartInstanceRequest import StartInstanceRequest

# configuration the log output formatter, if you want to save the output to file,
# append ",filename='ecs_invoke.log'" after datefmt.

logging.basicConfig(level=logging.INFO,
                    format='%(asctime)s %(filename)s[line:%(lineno)d] %(levelname)s %(message)s',
                    datefmt='%a, %d %b %Y %H:%M:%S')

clt = client.AcsClient('Your Access Key Id', 'Your Access Key Secrect', 'cn-beijing')

IMAGE_ID = 'ubuntu1404_64_40G_cloudinit_20160727.raw'
INSTANCE_TYPE = 'ecs.s2.large'  # 2c4g generation 1
SECURITY_GROUP_ID = 'sg-****'
INSTANCE_RUNNING = 'Running'


def create_instance_action():
    instance_id = create_after_pay_instance(image_id=IMAGE_ID, instance_type=INSTANCE_TYPE,
                                            security_group_id=SECURITY_GROUP_ID)
    check_instance_running(instance_id=instance_id)


def create_prepay_instance_action():
    instance_id = create_prepay_instance(image_id=IMAGE_ID, instance_type=INSTANCE_TYPE,
                                         security_group_id=SECURITY_GROUP_ID)
    check_instance_running(instance_id=instance_id)


# create one after pay ecs instance.
def create_after_pay_instance(image_id, instance_type, security_group_id):
    request = CreateInstanceRequest();
    request.set_ImageId(image_id)
    request.set_SecurityGroupId(security_group_id)
    request.set_InstanceType(instance_type)
    request.set_IoOptimized('optimized')
    request.set_SystemDiskCategory('cloud_ssd')
    response = _send_request(request)
    instance_id = response.get('InstanceId')
    logging.info("instance %s created task submit successfully.", instance_id)
    return instance_id;


# create one prepay ecs instance.
def create_prepay_instance(image_id, instance_type, security_group_id):
    request = CreateInstanceRequest();
    request.set_ImageId(image_id)
    request.set_SecurityGroupId(security_group_id)
    request.set_InstanceType(instance_type)
    request.set_IoOptimized('optimized')
    request.set_SystemDiskCategory('cloud_ssd')
    request.set_Period(1)
    request.set_InstanceChargeType('PrePaid')
    response = _send_request(request)
    instance_id = response.get('InstanceId')
    logging.info("instance %s created task submit successfully.", instance_id)
    return instance_id;


def check_instance_running(instance_id):
    detail = get_instance_detail_by_id(instance_id=instance_id, status=INSTANCE_RUNNING)
    index = 0
    while detail is None and index < 60:
        detail = get_instance_detail_by_id(instance_id=instance_id);
        time.sleep(10)

    if detail and detail.get('Status') == 'Stopped':
        logging.info("instance %s is stopped now.")
        start_instance(instance_id=instance_id)
        logging.info("start instance %s job submit.")

    detail = get_instance_detail_by_id(instance_id=instance_id, status=INSTANCE_RUNNING)
    while detail is None and index < 60:
        detail = get_instance_detail_by_id(instance_id=instance_id, status=INSTANCE_RUNNING);
        time.sleep(10)

    logging.info("instance %s is running now.", instance_id)
    return instance_id;


def start_instance(instance_id):
    request = StartInstanceRequest()
    request.set_InstanceId(instance_id)
    _send_request(request)


# output the instance owned in current region.
def get_instance_detail_by_id(instance_id, status='Stopped'):
    logging.info("Check instance %s status is %s", instance_id, status)
    request = DescribeInstancesRequest()
    request.set_InstanceIds(json.dumps([instance_id]))
    response = _send_request(request)
    instance_detail = None
    if response is not None:
        instance_list = response.get('Instances').get('Instance')
        for item in instance_list:
            if item.get('Status') == status:
                instance_detail = item
                break;
        return instance_detail;


# send open api request
def _send_request(request):
    request.set_accept_format('json')
    try:
        response_str = clt.do_action(request)
        logging.info(response_str)
        response_detail = json.loads(response_str)
        return response_detail
    except Exception as e:
        logging.error(e)


if __name__ == '__main__':
    logging.info("Create ECS by OpenApi!")
    create_instance_action()
    # create_prepay_instance_action()
相关实践学习
一小时快速掌握 SQL 语法
本实验带您学习SQL的基础语法,快速入门SQL。
7天玩转云服务器
云服务器ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,可降低 IT 成本,提升运维效率。本课程手把手带你了解ECS、掌握基本操作、动手实操快照管理、镜像管理等。了解产品详情:&nbsp;https://www.aliyun.com/product/ecs
目录
相关文章
|
存储 弹性计算 运维
阿里云 ECS 主机的创建 | 学习笔记
快速学习阿里云 ECS 主机的创建
404 0
阿里云 ECS 主机的创建 | 学习笔记
|
弹性计算 Linux 网络安全
ECS 创建|学习笔记
快速学习 ECS 创建
1135 0
ECS 创建|学习笔记
|
弹性计算 关系型数据库 MySQL
|
弹性计算 安全 Java
ecs学生算力使用举例——创建自己的mc服务器
使用阿里云赠送的学生服务器,创建纯净服。
261 0
ecs学生算力使用举例——创建自己的mc服务器
|
弹性计算 网络安全
阿里云专有宿主机创建的ECS实例和云服务器ECS有什么区别?
阿里云专有宿主机具有物理资源独享、配置灵活及性价比高的特性。专有宿主机是单租户独享物理资源,在宿主机上创建的ECS云服务器,大体上和云服务器ECS差不多,均支持划分专有网络VPC连接、挂载云盘和设置故障迁移。
399 0
阿里云专有宿主机创建的ECS实例和云服务器ECS有什么区别?
|
弹性计算 数据中心
新加坡ap-southeast-1创建ECS与查询时region不一致的BUG
实习用terraform做锤子时偶然碰见,简单来说是:创建ECS时region需要写为ap-southeast-1;而查询时region应该写为all并指定region ID,或将region改为ap-southeast,否则会返回无效信息。 目前,初步认为是IP限制导致的
新加坡ap-southeast-1创建ECS与查询时region不一致的BUG
|
弹性计算 JSON 网络安全
初次体验阿里云创建ECS实例
因为有对云的需求,据说阿里云是比较符合国人的习惯,所以决定使用阿里云来进行初体验,有了解到阿里云有一个学生的免费使用ECS的活动,因此就申请了,在一段时间的使用下,我觉得用ECS来创建用户比较方便,并且可以给用户进行精准授权,同时也可以切换到新创建的用户进行登录,切换也是很方便,阿里云提供了一个RAM用户登录的界面,直接输入用户名和密码就可以。我认为阿里云的搜索框做的也很全面,可以在搜索框中搜索到与自己搜索的名词对应的或者相关的功能以及各个领域的相关文件,也会有对你想要了解的东西进行描述,只要在搜索框中搜索你想要的,一定能搜到相关信息。阿里云的控制台把所有的功能模块都列出,界面清晰明了。
|
弹性计算 JSON 容灾
【ECS】使用弹性供应组API批量创建ECS实例
在需要大批量创建按量付费实例的场景中,通过API完成创建操作更加高效。其中,使用RunInstances完成该需求较为复杂,本文将推荐您使用交付过程更加方便稳定的CreateAutoProvisioningGroup。
240 0
【ECS】使用弹性供应组API批量创建ECS实例
|
弹性计算 监控 安全
Day3 在云服务器上创建自己的微信公众号管理系统
Day3 在云服务器上创建自己的微信公众号管理系统
197 0
Day3 在云服务器上创建自己的微信公众号管理系统
在服务器上管理微信小程序最方便的就是使用微擎系统了,很高效,而且也很简洁。
206 0
Day3 在云服务器上创建自己的微信公众号管理系统
相关产品
云服务器 ECS
推荐文章
更多