介紹

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

方法

主要是 def 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__‘:
     c = create.RunInstances(傳參)
     print(c)
 

參考

https://help.aliyun.com/document_detail/63440.html?spm=a2c4g.11186623.6.873.7e472386BkvcZq

python3.6 批量創建 多臺阿裏雲ECS主機 示例