python3.6 批量创建 多台阿里云ECS主机 示例
2018-11-15 15:03
821 查看
RunInstances
介绍
http://blog.51cto.com/hequan/2174407 上一篇是创建单台，如果想创建多台，需要for循环，比较麻烦，还容易被api限流。 利用RunInstances 可以批量创建多台。 调用该接口时，您需要注意： 单次最多能创建100台实例。 您可以指定参数AutoReleaseTime设置实例自动释放时间。 创建成功后会返回实例ID列表，您可以通过API DescribeInstances查询新建实例状态。 创建实例前，您需要确保您已经有可用的安全组。更多详情，请参阅CreateSecurityGroup。 创建实例时，默认自动启动实例，直到实例状态变成运行中（Running）。 创建专有网络VPC类型实例前，您需要预先在相应的阿里云地域 创建 VPC。 与CreateInstance相比，通过RunInstances创建的实例如果参数InternetMaxBandwidthOut的值大于0，则自动为实例分配公网IP。 提交创建任务后，参数不合法或者库存不足的情况下会报错，具体的报错原因参阅错误码。
SDK
aliyun-python-sdk-core-v3==2.9.1 aliyun-python-sdk-ecs==4.10.1
方法
主要使用 RunInstances()
import re
import os
import configparser
import logging
import json
from aliyunsdkcore import client
from aliyunsdkecs.request.v20140526 import DescribeInstancesRequest, DescribeRegionsRequest, \
DescribeAvailableResourceRequest, DescribeImagesRequest, DescribeSecurityGroupsRequest, DescribeVpcsRequest, \
DescribeVSwitchesRequest, CreateInstanceRequest, AllocatePublicIpAddre***equest, StartInstanceRequest, \
RunInstancesRequest
logger = logging.getLogger('test')
class AliyunEcsCreate(object):
def __init__(self, AccessKeyId, AccessKeySecret, City):
self.AccessKeyId = AccessKeyId
self.AccessKeySecret = AccessKeySecret
self.City = City
def DescribeRegions(self):
"""
地域
:return: {'cn-qingdao': '华北 1'}
"""
regionsclt = client.AcsClient(self.AccessKeyId, self.AccessKeySecret)
regionsreq = DescribeRegionsRequest.DescribeRegionsRequest()
regionsreq.set_accept_format('json')
regionsre = json.loads(regionsclt.do_action_with_exception(regionsreq), encoding='utf-8')
regions = {}
for i in regionsre['Regions']['Region']:
regions[i['RegionId']] = i['LocalName']
return regions
def DescribeAvailableResource(self, InstanceChargeType, region_id, DestinationResource, ZoneId=None):
"""
可用资源查询接口
:param ZoneId:
:param InstanceChargeType:
:param region_id: 地域
:param DestinationResource: 查询的资源类型
:return:
"""
resourceclt = client.AcsClient(self.AccessKeyId, self.AccessKeySecret, region_id)
resourcereq = DescribeAvailableResourceRequest.DescribeAvailableResourceRequest()
if DestinationResource == 'InstanceType':
resourcereq.set_ZoneId(ZoneId)
resourcereq.set_IoOptimized('optimized')
resourcereq.set_InstanceChargeType(InstanceChargeType)
resourcereq.set_DestinationResource(DestinationResource)
resourcereq.set_accept_format('json')
resourcere = json.loads(resourceclt.do_action_with_exception(resourcereq), encoding='utf-8')
return resourcere
def AvailableZones(self, InstanceChargeType, region_id):
"""
可用区
:param InstanceChargeType: 计费方式
:param region_id: 地域
:return: ['cn-huhehaote-a', 'cn-huhehaote-b']
"""
zonesre = self.DescribeAvailableResource(InstanceChargeType, region_id, 'Zone')
zones = []
for i in zonesre['AvailableZones']['AvailableZone']:
zones.append(i['ZoneId'])
return zones
def AvailableInstanceType(self, InstanceChargeType, region_id, ZoneId):
"""
可用实例规格
:param ZoneId:
:param InstanceChargeType:
:param region_id: 计费方式 地域 可用区
:return:
"""
instanceres = self.DescribeAvailableResource(InstanceChargeType, region_id, 'InstanceType', ZoneId)
instance = []
instance_list = instanceres['AvailableZones']['AvailableZone'][0]['AvailableResources']['AvailableResource'][0][
'SupportedResources']['SupportedResource']
return instance_list
def DescribeImages(self, region_id):
"""
:param region_id: 地域
:return: 镜像列表 {'centos_6_09_64_20G_alibase_20180326.vhd': 'CentOS 6.9 64位',}
"""
imagesclt = client.AcsClient(self.AccessKeyId, self.AccessKeySecret, region_id)
imagesreq = DescribeImagesRequest.DescribeImagesRequest()
imagesreq.set_ActionType('DescribeImages')
imagesreq.set_accept_format('json')
imagesreq.set_PageSize(100)
imagesre = json.loads(imagesclt.do_action_with_exception(imagesreq), encoding='utf-8')
images = {}
ubuntu16 = {
'cn-beijing': 'm-2ze6tsxqsldo4qkvjb3u',
'cn-zhangjiakou': 'm-8vba9qdqeeca3zpm2sc8',
}
for i in imagesre['Images']['Image']:
if i['Platform'] == 'CentOS':
images[i['ImageId']] = i['OSName']
if i['Platform'] == 'Ubuntu':
images[i['ImageId']] = i['OSName']
if i['Platform'] == 'Windows Server 2008':
images[i['ImageId']] = i['OSName']
return images
def DescribeVpcs(self, region_id):
"""
VPC
:param region_id: 地域
:return: {'vpc-hp33ep5m55q5vdebkjpxk': '华北5预发布VPC', 'vpc-hp3xfrxc78pgc0rianhge': '华北5测试'}
"""
vpcsclt = client.AcsClient(self.AccessKeyId, self.AccessKeySecret, region_id)
vpcsreq = DescribeVpcsRequest.DescribeVpcsRequest()
vpcsreq.set_action_name('DescribeVpcs')
vpcsreq.set_accept_format('json')
vpcsreq.set_PageSize(50)
vpcsre = json.loads(vpcsclt.do_action_with_exception(vpcsreq), encoding='utf-8')
vpcs = {}
for i in vpcsre['Vpcs']['Vpc']:
vpcs[i['VpcId']] = i['VpcName']
return vpcs
def DescribeVSwitches(self, region_id, zone_id, vpc_id):
"""
:param region_id: 地域
:param zone_id: 可用区
:param vpc_id: vpc
:return: {'vsw-hp3ffb8524tt1gqp22utj': '华北5测试B交换机'}
"""
vswitchesclt = client.AcsClient(self.AccessKeyId, self.AccessKeySecret, region_id)
vswitchesreq = DescribeVSwitchesRequest.DescribeVSwitchesRequest()
vswitchesreq.set_action_name('DescribeVSwitches')
vswitchesreq.set_VpcId(vpc_id)
vswitchesreq.set_accept_format('json')
vswitchesreq.set_PageSize(50)
vswitchesreq.set_ZoneId(zone_id)
vswitchesre = json.loads(vswitchesclt.do_action_with_exception(vswitchesreq), encoding='utf-8')
vswitches = {}
for i in vswitchesre['VSwitches']['VSwitch']:
vswitches[i['VSwitchId']] = i['VSwitchName']
return vswitches
def DescribeSecurityGroups(self, region_id, vpc_id, ):
"""
安全组
:param region_id: 地域
:param vpc_id: vpc
:return: {'sg-hp3738k45fqqbfja11fl': '华北5测试2', 'sg-hp3hzvhrr2gk8skyo3ul': '华北5测试1'}
"""
groupsclt = client.AcsClient(self.AccessKeyId, self.AccessKeySecret, region_id)
groupsreq = DescribeSecurityGroupsRequest.DescribeSecurityGroupsRequest()
groupsreq.set_action_name('DescribeSecurityGroups')
groupsreq.set_VpcId(vpc_id)
groupsreq.set_accept_format('json')
groupsreq.set_PageSize(50)
groupsre = json.loads(groupsclt.do_action_with_exception(groupsreq), encoding='utf-8')
groups = {}
for i in groupsre['SecurityGroups']['SecurityGroup']:
groups[i['SecurityGroupId']] = i['SecurityGroupName']
return groups
def CreateInstance(self, region_id, ZoneId, ImageId, InstanceType, InstanceName, InstanceChargeType, HostName,
Password, VSwitchId, SecurityGroupId, SystemDiskSize, Size, Description):
"""
创建 实例
:param region_id: 地域
:param ZoneId: 可用区
:param ImageId: 镜像
:param InstanceType: 实例模板
:param InstanceName: 实例名字
:param InstanceChargeType: 实例的付费方式 ,PrePaid PostPaid
# :param InternetChargeType: 网络计费方式 PayByBandwidth：按固定带宽计费 PayByTraffic：按使用流量计费
# :param InternetMaxBandwidthOut: 出网带宽
:param HostName: 主机名字
:param Password: 密码
:param VSwitchId: 交换机
:param SecurityGroupId: 安全组
:param SystemDiskSize: 系统盘 默认40
:param Size: 数据盘
:param Description: 描述
:return: {'InstanceId': 'i-2ze210z0uiwyadm1m7x6'}
"""
createclt = client.AcsClient(self.AccessKeyId, self.AccessKeySecret, region_id, timeout=30)
createreq = CreateInstanceRequest.CreateInstanceRequest()
createreq.set_action_name('CreateInstance')
createreq.set_accept_format('json')
createreq.set_ZoneId(ZoneId)
createreq.set_ImageId(ImageId)
createreq.set_InstanceType(InstanceType)
createreq.set_InstanceName(InstanceName)
if InstanceChargeType == 'PrePaid':
createreq.set_Period('1')
createreq.set_InstanceChargeType(InstanceChargeType)
createreq.set_InternetChargeType('PayByBandwidth')
# if InternetChargeType:
# createreq.set_InternetMaxBandwidthOut(InternetMaxBandwidthOut)
createreq.set_HostName(HostName)
createreq.set_Password(Password)
createreq.set_AutoRenew('True')
createreq.set_AutoRenewPeriod('1')
createreq.set_VSwitchId(VSwitchId)
createreq.set_SecurityGroupId(SecurityGroupId)
createreq.set_SystemDiskSize(SystemDiskSize)
createreq.set_Description(Description)
if Size != 0:
createreq.set_DataDisks([{'Size': Size, 'Category': 'cloud_efficiency'}])
createre = json.loads(createclt.do_action_with_exception(createreq), encoding='utf-8')
return createre
def RunInstances(self, region_id, ZoneId, ImageId, InstanceType, InstanceName, InstanceChargeType, HostName,
Password, VSwitchId, SecurityGroupId, SystemDiskSize, Size, Description, Amount):
"""
一次创建多台 实例
:param region_id: 地域
:param ZoneId: 可用区
:param ImageId: 镜像
:param InstanceType: 实例模板
:param InstanceName: 实例名字
:param InstanceChargeType: 实例的付费方式 ,PrePaid PostPaid
# :param InternetChargeType: 网络计费方式 PayByBandwidth：按固定带宽计费 PayByTraffic：按使用流量计费
# :param InternetMaxBandwidthOut: 出网带宽
:param HostName: 主机名字
:param Password: 密码
:param VSwitchId: 交换机
:param SecurityGroupId: 安全组
:param SystemDiskSize: 系统盘 默认40
:param Size: 数据盘
:param Description: 描述
:param Amount: 数量
:return: {'InstanceId': 'i-2ze210z0uiwyadm1m7x6'}
"""
createclt = client.AcsClient(self.AccessKeyId, self.AccessKeySecret, region_id, timeout=30)
createreq = RunInstancesRequest.RunInstancesRequest()
createreq.set_action_name('RunInstances')
createreq.set_accept_format('json')
createreq.set_ZoneId(ZoneId)
createreq.set_ImageId(ImageId)
createreq.set_InstanceType(InstanceType)
createreq.set_InstanceName(InstanceName)
if InstanceChargeType == 'PrePaid':
createreq.set_Period('1')
createreq.set_InstanceChargeType(InstanceChargeType)
createreq.set_InternetChargeType('PayByBandwidth')
# if InternetChargeType:
# createreq.set_InternetMaxBandwidthOut(InternetMaxBandwidthOut)
createreq.set_HostName(HostName)
createreq.set_Password(Password)
createreq.set_AutoRenew('True')
createreq.set_VSwitchId(VSwitchId)
createreq.set_SecurityGroupId(SecurityGroupId)
createreq.set_SystemDiskSize(SystemDiskSize)
createreq.set_Description(Description)
if Size != 0:
createreq.set_DataDisks([{'Size': Size, 'Category': 'cloud_efficiency'}])
createreq.set_Amount(Amount)
createreq.set_UniqueSuffix('true')
createre = json.loads(createclt.do_action_with_exception(createreq), encoding='utf-8')
return createre
def AllocatePublicIpAddress(self, region_id, InstanceId):
"""
绑定外网IP
:param region_id: 地域
:param InstanceId: 实例ID
:return: {'IpAddress': ''}
"""
ipclt = client.AcsClient(self.AccessKeyId, self.AccessKeySecret, region_id)
ipreq = AllocatePublicIpAddre***equest.AllocatePublicIpAddre***equest()
ipreq.set_action_name('AllocatePublicIpAddress')
ipreq.set_accept_format('json')
ipreq.set_InstanceId(InstanceId)
ipre = json.loads(ipclt.do_action_with_exception(ipreq), encoding='utf-8')
return ipre
def StartInstance(self, region_id, InstanceId):
"""
启动实例
:param region_id: 地域
:param InstanceId: 实例ID
:return:
"""
startclt = client.AcsClient(self.AccessKeyId, self.AccessKeySecret, region_id)
startreq = StartInstanceRequest.StartInstanceRequest()
startreq.set_action_name('StartInstance')
startreq.set_accept_format('json')
startreq.set_InstanceId(InstanceId)
start = json.loads(startclt.do_action_with_exception(startreq), encoding='utf-8')
return start
if __name__ == '__main__':
create = AliyunEcsCreate(key, secret, region)
c = create.RunInstances(传参)
print(c)
返回结果
{'RequestId': '61E9D626-010D-4FD1-A2C0-5BF41F88034F', 'InstanceIdSets': {'InstanceIdSet': ['i-2ze2mwf5cl1jnjzht09z', 'i-2ze2mwf5cl1jnjzht0a0']}}
参考
https://help.aliyun.com/document_detail/63440.html?spm=a2c4g.11186623.6.873.7e472386BkvcZq
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- 阿里云通过API 创建ECS主机示例
- 阿里云ECS开放批量创建实例接口，实现弹性资源的创建
- 阿里云centos7.3下 python3.6 使用 virtualenv 创建独立的虚拟环境
- python使用循环实现批量创建文件夹示例
- 阿里云ECS开放批量创建实例接口，实现弹性资源的创建
- 阿里云ECS开放批量创建实例接口，实现弹性资源的创建
- python使用循环实现批量创建文件夹示例
- 阿里云基于ecs云主机创建日志服务
- [bigdata-83] python3+图数据库neo4j 电话号码 身份证 黑名单 创建节点 标签 关系 增标记 增关系 查询pattern示例
- 阿里云服务器 非root权限 创建基于python的虚拟环境
- 阿里云ECS主机自定义进程监控
- 阿里云ECS主机 Ubuntu下设置Mysql 5.7.17为远程访问
- python3.6 通过调用 阿里云 API (非SDK方式) 16ca 查询 可用区 例子
- Python批量创建迅雷任务及创建多个文件
- Python3.6基于正则实现的计算器示例【无优化简单注释版】
- python3.6+BeautifulSoup4 爬取360手机助手app应用的信息并存储数据库 批量下载apk
- Python使用numpy模块创建数组操作示例
- 阿里云 创建镜像及使用镜像创建ecs实例
- Python3基础 创建包 package 的简单示例
- python 脚本之批量更改主机名