华为云各类操作 - slqt

华为云各类操作

删除云服务器
# coding: utf8
import json
import re
import requests
import sys


class ExecError(Exception):
    pass


class ServerAction(object):
    def __init__(self, openstack_auth, user, password, project_info, region, domain=None,
                 notify=None):
        self.version = \'v3\'
        self.keystone_url = openstack_auth
        self.region = region

        self.user = user
        self.password = password
        if isinstance(project_info, str):
            self.project_id = project_info
        else:
            self.project_id = getopenstack.Get_infos(project_info).get_project()[\'Y_systemID\']

        self.domain = domain
        self.notify = notify
        self.token = self.get_token()
        # print self.endpoints

    def get_token(self):
        if self.version>= \'v3\':
            data = {"auth": {"identity": {"methods": ["password"], "password":
                {"user": {"name": self.user, "password": self.password, "domain": {
                    "name": self.domain}}}},
                             "scope": {"project": {"name": self.project_id}}}}
            url = self.keystone_url + \'/{}/auth/tokens\'.format(self.version)
        else:
            data = {"auth": {"tenantName": str(self.project_id), "passwordCredentials":
                {"username": str(self.user), "password": str(self.password)}}}
            url = self.keystone_url + \'/{}/tokens\'.format(self.version)

        data = json.dumps(data)

        if self.version >= \'v3\':
            res = requests.post(url, data=data)
            if res.status_code == 201:
                content = json.loads(res.content)
                self.endpoints = content[\'token\'][\'catalog\']
                self.tenant_id = content[\'token\'][\'project\'][\'id\']
                if self.notify:
                    print \'身份认证请求成功\'
                return res.headers[\'X-Subject-Token\']
            else:
                raise ExecError(\'身份认证请求失败\')
        else:
            status, res = fetch_res(url, action=\'post\', data=data, get_status=True, use_token=None)
            if status == 200:
                res = json.loads(res)
                self.endpoints = res[\'access\'][\'serviceCatalog\']
                self.tenant_id = res[\'token\'][\'project\'][\'id\']
                res = res[\'access\'][\'token\'][\'id\']
                if self.notify:
                    print \'身份认证请求成功\'
                return res
            else:
                raise ExecError(\'身份认证请求失败\')

    def post_action(self, data, type=\'action\', add_url=None):
        if type == \'action\':
            url = self.server_url
        else:
            url = self.get_host(type=type)
        if add_url:
            url = url.strip(\'https://\')
            url = \'https://\' + url.split(\'/\')[0] + \'/v1/{}\'.format(self.tenant_id)
            url += add_url
        data = json.dumps(data)
        print data, url
        return fetch_res(url, use_token=self.token, action=\'post\', data=data, get_status=True)

    def delete_action(self, type=None, add_url=\'\'):
        url = self.get_host(type=type)
        if add_url:
            url += add_url
        return fetch_res(url, use_token=self.token, action=\'delete\',
                         get_status=True)

    def get_action(self, type=None, add_url=\'\'):
        url = self.get_host(type=type)
        if add_url:
            url += add_url
        return fetch_res(url, use_token=self.token, action=\'get\',
                         get_status=True)

    def put_action(self, data, type=None, add_url=\'\'):
        url = self.get_host(type=type)
        if add_url:
            url += add_url
        data = json.dumps(data)
        return fetch_res(url, use_token=self.token, action=\'put\', data=data,
                         get_status=True)

    def get_host(self, type=None):
        hosts = {}
        for endpoint in self.endpoints:
            # print endpoint
            for i in endpoint[\'endpoints\']:
                if i[\'region\'] == self.region or i[\'region\'] == \'*\':
                    try:
                        if self.version>= \'v3\':
                            url = i[\'url\']
                        else:
                            url = i[\'url\']
                    except:
                        url = \'\'
                    hosts.update({endpoint[\'name\']: url})

        if hosts[type] == \'\':
            print \'url未取到\'
        # print hosts
        return hosts[type]


def fetch_res(url, use_token=None, action=\'get\', data=None, get_content=False, get_status=False):
    if use_token:
        header = {\'X-Auth-Token\': use_token, \'Content-Type\': \'application/json\'}
    else:
        header = {\'Content-Type\': \'application/json\'}
    res = getattr(requests, action.lower())(url, headers=header, data=data)
    if get_status:
        return res.status_code, res.content
    if get_content:
        return res.content
    else:
        if res.status_code != 200:
            raise ExecError(\'请求发送失败:{}\'.format(res.content))
        else:
            return res.content


def del_vm(openstack_auth=None, project_info=None, domain=None,
           user=None, password=None, region=None,
           server_id=None, delete_publicip=None, delete_volume=None,
           **kwargs):
    try:
        if delete_publicip==\'true\':
            delete_publicip=True
        else:
            delete_publicip=False

        if delete_volume==\'true\':
            delete_volume = True
        else:
            delete_volume = False

        data = {
            "servers": [
                {
                    "id": server_id
                }
            ],
            "delete_publicip": delete_publicip,
            "delete_volume": delete_volume
        }
        print data
        status, res = ServerAction(openstack_auth, user, password, project_info, region,
                                   domain=domain, notify=True). \
            post_action(data, type=\'nova\', add_url=\'/cloudservers/delete\')

        if status == 200:
            print \'正在删除……\'
            while 1:
                status, res = ServerAction(openstack_auth, user, password, project_info, region,
                                           domain=domain, notify=False). \
                    get_action(type=\'nova\',
                               add_url=\'/servers/{server_id}\'.format(server_id=server_id))
                if status == 200:
                    continue
                elif status == 404 and json.loads(res).has_key("itemNotFound"):
                    return {\'success\': True, \'message\': \'云服务器删除成功\'}
                else:
                    return {\'success\': False, \'message\': \'云服务器删除失败:{}\'.format(res)}
        else:
            return {\'success\': False, \'message\': \'云服务器删除失败:{}\'.format(res)}
    except Exception as e:
        return {\'success\': False, \'message\': \'云服务器删除失败:{}\'.format(e)}


if __name__ == \'__main__\':
    vm_info = del_vm(openstack_auth=AUTH_URL, project_info=project_name,
                     domain=domain, user=user, password=password,
                     region=region, server_id=server_id, delete_volume=delete_volume,
                     delete_publicip=delete_publicip)

    print vm_info[\'message\']
    if not vm_info[\'success\']:
        ExitCode = -1

　　

创建虚拟私有云
def create_vpc(openstack_auth=None, project_info=None, domain=None, user=None, password=None,
              region=None,vpc_name=None,cidr=None,
              **kwargs):
    try:
        status, res = ServerAction(openstack_auth, user, password, project_info, region,
                                   domain=domain).get_action(type=\'neutron\')

        #print status, res
        vpc_id = None
        if status == 200:
            vpcs=json.loads(res)[\'vpcs\']
            for vpc in vpcs:
                if vpc[\'name\']==vpc_name:
                    vpc_id=vpc[\'id\']
        if vpc_id:
            return {\'success\': True, \'message\': \'虚拟私有云id为：{}\'.format(vpc_id),\'outputParam\': vpc_id}

        data={"vpc":
             {
             "name": vpc_name,
             "cidr": cidr
             }
        }
        status, res = ServerAction(openstack_auth, user, password, project_info, region,
                                   domain=domain).post_action(data,type=\'neutron\')

        #print status, res
        if status == 200:
            vpc_id=json.loads(res)[\'vpc\'][\'id\']
            return {\'success\': True, \'message\': \'虚拟私有云id为：{}\'.format(vpc_id), \'outputParam\': vpc_id}
        else:
            return {\'success\': False, \'message\': \'虚拟云创建失败:{}\'.format(res)}
    except Exception as e:
        return {\'success\': False, \'message\': \'虚拟云创建失败:{}\'.format(e)}

　　

获取实例IP
def get_vm(openstack_auth=None, project_info=None, domain=None,user=None,password=None,
              region=None,vmname=None,vpc_id=None,
              **kwargs):
    try:
        status, res = ServerAction(openstack_auth, user,password, project_info,region,
                                   domain=domain,notify=True).get_action(type=\'nova\',add_url=\'/servers\')

        #print status, res
        if status == 200:
            servers = json.loads(res)[\'servers\']
            for i in servers:
                if i[\'name\']==vmname:
                    server_id=i[\'id\']
            if server_id:
                status, res = ServerAction(openstack_auth, user, password, project_info, region,
                                       domain=domain, notify=True).get_action(type=\'nova\',
                                                                              add_url=\'/servers/{}\'.format(server_id))
                if status == 200:
                    ips = json.loads(res)[\'server\'][\'addresses\'].get(vpc_id, None)
                    if ips:
                        ip = ips[0][\'addr\']
                    else:
                        ip = None

                    if ip:
                        return {\'success\': True, \'message\': \'实例ip为:{}\'.format(ip),
                                \'outputParam\': ip,\'id\':server_id}
                    else:
                        return {\'success\': False, \'message\': \'查询实例ip失败:{}\'.format(res)}

            else:
                return {\'success\': False, \'message\': \'查询实例ip失败:{}\'.format(res)}
    except Exception as e:
        return {\'success\': False, \'message\': \'查询实例ip失败:{}\'.format(e)}

　　

虚拟机启停
def stop_vm(openstack_auth=None, project_info=None,
            domain=None, user=None, password=None, region=None, server_id=None, **kwargs):
    try:
        data={"os-stop": {}}
        status, res = ServerAction(openstack_auth, user, password, project_info, region,
                                       domain=domain,notify=True). \
                post_action(data, type=\'nova\',
                            add_url=\'/servers/{server_id}/action\'.format(server_id=server_id))
        if status == 200:
            return {\'success\': True, \'message\': \'虚拟机关闭成功\'}
        elif status == 202:
            while 1:
                status, res = ServerAction(openstack_auth, user, password, project_info, region,
                                           domain=domain,notify=False). \
                    get_action(type=\'nova\',
                                add_url=\'/servers/{server_id}\'.format(server_id=server_id))
                server_status = json.loads(res)[\'server\'][\'status\']
                if status==200:
                    if server_status==\'ACTIVE\':
                        continue
                    elif server_status==\'SHUTOFF\':
                        return {\'success\': True, \'message\': \'虚拟机关闭成功\'}
                    else:
                        return {\'success\': False, \'message\': \'虚拟机关闭失败:{}\'.format(res)}
                else:
                    return {\'success\': False, \'message\': \'虚拟机关闭失败:{}\'.format(res)}
        else:
            return {\'success\': False, \'message\': \'虚拟机关闭失败:{}\'.format(res)}

    except Exception as e:
        return {\'success\': False, \'message\': \'虚拟机关闭失败:{}\'.format(e)}

　　

创建子网

def create_subnet(openstack_auth=None, project_info=None, domain=None, user=None, password=None,
              region=None,vpc_id=None,cidr=None,availability_zone=None,
                  subnet_name=None,gateway_ip=None,primary_dns=None,secondary_dns=None,
                  dhcp_enable=None,subnet_id=None,availability_zone_order=None,
              **kwargs):
    try:
        subnet_id=None
        status, res = ServerAction(openstack_auth, user, password, project_info, region,
                                   domain=domain).\
            get_action(type=\'neutron\',add_url=\'/subnets?vpc_id={}\'.format(vpc_id))

        # print status, res
        if status == 200:
            subnets = json.loads(res)[\'subnets\']
            # print res
            for subnet in subnets:
                if subnet[\'name\'] == subnet_name:
                    subnet_id = subnet[\'id\']

        if subnet_id:
            return {\'success\': True, \'message\': \'虚拟云子网id为：{}\'.format(subnet_id),
                    \'outputParam\': subnet_id}
        availability_zone = \'{}{}\'.format(region, chr(ord(\'a\') - 1 + int(availability_zone_order) % 26))
        data={"subnet":
         {
          "name": subnet_name,
          "cidr": cidr,
          "gateway_ip": gateway_ip,
          "dhcp_enable": dhcp_enable,
          "availability_zone":availability_zone,
          "vpc_id":vpc_id
          }
}
        if primary_dns:
            data.update({"primary_dns":primary_dns})
        if secondary_dns:
            data.update({"secondary_dns":secondary_dns})

        status, res = ServerAction(openstack_auth, user, password, project_info, region,
                                   domain=domain).post_action(data,type=\'neutron\')

        #print status, res
        if status == 200:
            subnet_id=json.loads(res)[\'subnet\'][\'id\']
            return {\'success\': True, \'message\': \'虚拟云子网id为：{}\'.format(subnet_id), \'outputParam\': subnet_id}
        else:
            return {\'success\': False, \'message\': \'虚拟云子网id创建失败:{}\'.format(res)}
    except Exception as e:
        return {\'success\': False, \'message\': \'虚拟云子网id创建失败:{}\'.format(e)}

　　

查找可用分区
def get_availibility_zone_name(openstack_auth=AUTH_URL,project_info=project_name,
                      domain=domain,user=user,password=password,region=region,
                               availibility_zone_order=None,**kwargs):
    try:
        status, res = ServerAction(openstack_auth, user,password, project_info,region,
                                   domain=domain).get_action(type=\'nova\',add_url=\'/os-availability-zone\')
        #print status, res
        if status == 200:
            zones = json.loads(res)[\'availabilityZoneInfo\']
            zone_name_req=\'{}{}\'.format(region , chr(ord(\'a\') - 1 + int(availibility_zone_order) % 26))
            print zone_name_req
            for zone in zones:
                if zone[\'zoneName\']==zone_name_req and zone[\'zoneState\'][\'available\']:
                    zone_name=zone[\'zoneName\']
                    return {\'success\': True, \'message\': \'可用分区为：{}\'.format(zone_name), \'outputParam\': zone_name}
            return {\'success\': False, \'message\': \'查找可用分区失败:{}\'.format(zones)}
        else:
            return {\'success\': False, \'message\': \'查找可用分区失败:{}\'.format(res)}

    except Exception as e:
        return {\'success\': False, \'message\': \'查找可用分区失败:{}\'.format(e)}

　　

获取镜像
def get_image_id(openstack_auth=None,project_info=None,
                      domain=None,user=None,password=None,region=None,image_name=None,**kwargs):
    try:
        image_id=None
        image_name=image_name.strip()
        status, res = ServerAction(openstack_auth, user,password, project_info,region,
                                   domain=domain).\
            get_action(type=\'glance\',add_url=\'/v2/images?status=active&name={}\'.format(image_name))

        #print status, res
        if status == 200:
            # print res
            image_id = json.loads(res)[\'images\'][0][\'id\']
        
        if image_id:
            return {\'success\': True, \'message\': \'镜像id为：{}\'.format(image_id), \'outputParam\': image_id}
        else:
            return {\'success\': False, \'message\': \'查找镜像失败:{}\'.format(res)}

    except Exception as e:
        return {\'success\': False, \'message\': \'查找镜像失败:{}\'.format(e)}

　　

获取虚拟机规格参数
def get_flavor_id(openstack_auth=AUTH_URL,project_info=project_name,
                      domain=domain,user=user,password=password,region=region,
                  minDisk=None,minRam=None,vcpus=None,flavor_name=None,**kwargs):
    try:
        add_url = \'/flavors\'
        if minDisk or minRam:
            add_url+=\'/detail?is_public=true&\'
        if minDisk:
            add_url +=\'minDisk=0&\'#.format(minDisk)
        if minRam:
            add_url += \'minRam={}\'.format(minRam)
        add_url=add_url.strip(\'&\')

        status, res = ServerAction(openstack_auth, user,password, project_info,region,
                                   domain=domain).get_action(type=\'nova\',add_url=add_url)
        #print status, res
        if status == 200:
            flavors = json.loads(res)[\'flavors\']
            flavor_names=[]
            for flavor in flavors:
                flavor_names.append(flavor[\'name\'])
                if flavor_name and flavor[\'name\']==flavor_name:
                    flavor_id=flavor[\'id\']
                    return {\'success\': True, \'message\': \'规格id为：{}\'.format(flavor_id), \'outputParam\': flavor_id}

            flavor_infos={}
            flavor_infos1={}
            for flavor in flavors:
                if flavor[\'vcpus\']==int(vcpus) and flavor[\'OS-FLV-EXT-DATA:ephemeral\']==0:
                    flavor_infos.update({flavor[\'id\']:flavor[\'name\']})
                if flavor[\'vcpus\']>int(vcpus) and flavor[\'OS-FLV-EXT-DATA:ephemeral\']==0:
                    flavor_infos1.update({flavor[\'id\']:flavor[\'name\']})

            if flavor_infos:
                flavor_id=min(flavor_infos.items(), key=lambda x: x[1])[0]
                return {\'success\': True, \'message\': \'规格id为：{}\'.format(flavor_id),
                        \'outputParam\': flavor_id}
            if flavor_infos1:
                flavor_id=min(flavor_infos1.items(), key=lambda x: x[1])[0]
                return {\'success\': True, \'message\': \'规格id为：{}\'.format(flavor_id),
                        \'outputParam\': flavor_id}
            return {\'success\': False, \'message\': \'查找规格失败,符合标准的有以下规格:{}\'.format(\',\'.join(flavor_names))}
        else:
            return {\'success\': False,\'message\': \'查找规格失败:{}\'.format(res)}

    except Exception as e:
        return {\'success\': False, \'message\': \'查找规格失败:{}\'.format(e)}

　　

查找弹性ip
def get_publicip_id(openstack_auth=None, project_info=None,
                    domain=None, user=None, password=None, region=None,
                    **kwargs):
    try:
        publicip_id = None
        status, res = ServerAction(openstack_auth, user, password, project_info, region,
                                   domain=domain). \
            get_action(type=\'neutron\', add_url=\'/publicips\')
        #print status, res
        if status == 200:
            res = json.loads(res)
            for i in res[\'publicips\']:
                if i[\'status\'] == \'DOWN\':
                    publicip_id = i[\'id\']
                    public_ip = i[\'public_ip_address\']
                    return {\'success\': True,
                            \'message\': \'弹性ip的id为：{},ip为{}\'.format(publicip_id, public_ip),
                            \'outputParam\': publicip_id, \'ip\': public_ip}

        data = {"publicip": {"type": "5_bgp"},
                "bandwidth": {"name": int(time.time()), "size": 1, "share_type": "PER"}}
        status, res = ServerAction(openstack_auth, user, password, project_info, region,
                                   domain=domain). \
            post_action(data, type=\'neutron\', add_url=\'/publicips\')

        print status, res
        if status == 200:
            # print res
            publicip_id = json.loads(res)[\'publicip\'][\'id\']
            public_ip = json.loads(res)[\'publicip\'][\'public_ip_address\']
        if publicip_id:
            return {\'success\': True, \'message\': \'弹性ip的id为：{},ip为{}\'.
                format(publicip_id, public_ip),
                    \'outputParam\': publicip_id, \'ip\': public_ip}
        else:
            return {\'success\': False, \'message\': \'查找弹性ip失败:{}\'.format(res)}

    except Exception as e:
        return {\'success\': False, \'message\': \'查找弹性ip失败:{}\'.format(e)}

　　

创建云服务器
def create_vm(openstack_auth=None, project_info=None, domain=None, user=None, password=None,
              region=None,
              image_id=None, flavor_id=None, vm_name=None, adminPass=None, publicip_id=None,
              subnet_id=None,
              ip_address=None, vpc_id=None, volume_type=None, charge_mode=None,
              availibility_zone_order=None, data_volume=None,
              **kwargs):
    try:
        status, res = ServerAction(openstack_auth, user, password, project_info, region,
                                   domain=domain, notify=True).get_rest_action(type=\'nova\',
                                                                          add_url=\'/servers\')

        #print status, res
        if status == 200:
            servers = json.loads(res)[\'servers\']
            for i in servers:
                if i[\'name\'] == vm_name:
                    return {\'success\': False, \'message\': \'创建实例失败:该虚拟机名称已存在\'}

        availibility_zone = \'{}{}\'.format(region, chr(ord(\'a\') - 1 + int(availibility_zone_order) % 26))

        nics = {"subnet_id": subnet_id}
        if ip_address:
            nics.update({"ip_address": ip_address})

        data = {"imageRef": image_id,
                "flavorRef": flavor_id,
                "name": vm_name,
                "adminPass": adminPass,
                "availability_zone": availibility_zone,
                "vpcid": vpc_id,
                "nics": [nics],
                "key_name": "",
                "personality": [],
                "root_volume": {"volumetype": volume_type},
                "extendparam": {"chargingMode": int(charge_mode)},
                "count": 1,
                "data_volumes": [{"volumetype": volume_type, "size": int(data_volume)}]
                # "security_groups": [
                #     {
                #         "id": "7ec29785-2892-40fb-a572-12f7a012a0d4"
                #     }]
                }
        if publicip_id:
            data.update({"publicip": {"id": publicip_id}})
        data = {"server": data}

        status, res = ServerAction(openstack_auth, user, password, project_info, region,
                                   domain=domain, notify=True).post_action(data, type=\'nova\',
                                                                           add_url=\'/cloudservers\')
        if status == 200:
            print \'云服务器正在创建……\'
            job_id = json.loads(res)[\'job_id\']
            while status == 200:
                status, res = ServerAction(openstack_auth, user, password, project_info, region,
                                           domain=domain, notify=False).get_action(type=\'nova\',
                                                                                   add_url=\'/jobs/{}\'.format(
                                                                                       job_id))
                if json.loads(res)[\'status\'] not in (\'RUNNING\', \'INIT\'):
                    break
            # print status, res
            if json.loads(res)[\'status\'] == \'SUCCESS\':
                server_id = json.loads(res)[\'entities\'][\'sub_jobs\'][0][\'entities\'][\'server_id\']
                return {\'success\': True, \'message\': \'实例创建成功,id为：{}\'.format(server_id),
                        \'outputParam\': server_id}
            else:
                return {\'success\': False, \'message\': \'创建实例失败:{}\'.format(res)}
        else:
            return {\'success\': False, \'message\': \'创建实例失败:{}\'.format(res)}

    except Exception as e:
        return {\'success\': False, \'message\': \'创建实例失败:{}\'.format(e)}