86 lines
3.4 KiB
Python
86 lines
3.4 KiB
Python
# Licensed under the Apache License, Version 2.0 (the "License"); you may
|
|
# not use this file except in compliance with the License. You may obtain
|
|
# a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
|
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
|
# License for the specific language governing permissions and limitations
|
|
# under the License.
|
|
|
|
from keystoneclient.auth.identity import v3 as keystone_v3
|
|
from keystoneclient import session
|
|
from novaclient.client import Client as novaclient
|
|
from novaclient.exceptions import ClientException
|
|
|
|
|
|
class NovaHealth(object):
|
|
|
|
def __init__(self, creds):
|
|
# creden['timeout'] = 30
|
|
cacert = creds['cacert']
|
|
del creds['cacert']
|
|
auth = keystone_v3.Password(**creds)
|
|
sess = session.Session(auth=auth, verify=cacert)
|
|
self.novaclient = novaclient(2, session=sess)
|
|
|
|
def nova_hypervisor_list(self):
|
|
try:
|
|
hypervisors = self.novaclient.hypervisors.list()
|
|
except (ClientException, Exception) as e:
|
|
return (400, e.message, [])
|
|
hypervisor_names = [node.hypervisor_hostname for node in hypervisors]
|
|
return (200, "success", hypervisor_names)
|
|
|
|
def nova_service_list(self):
|
|
try:
|
|
service_list = self.novaclient.services.list()
|
|
except (ClientException, Exception) as e:
|
|
return (400, e.message, [])
|
|
return (200, "success", service_list)
|
|
|
|
def nova_create_server(self, server_name, image_name,
|
|
flavor_name, network_id):
|
|
try:
|
|
image = self.novaclient.images.find(name=image_name)
|
|
flavor = self.novaclient.flavors.find(name=flavor_name)
|
|
networks = [{'net-id': network_id}]
|
|
server_ret = self.novaclient.servers.create(server_name, image,
|
|
flavor, nics=networks)
|
|
except (ClientException, Exception) as e:
|
|
return (400, e.message, [])
|
|
return (200, "success", server_ret)
|
|
|
|
def nova_delete_server(self, server_id):
|
|
try:
|
|
ret = self.novaclient.servers.delete(server_id)
|
|
except (ClientException, Exception) as e:
|
|
return (400, e.message, [])
|
|
return (200, "success", ret)
|
|
|
|
def nova_get_server_state(self, server_id):
|
|
try:
|
|
ret = self.novaclient.servers.get(server_id)
|
|
except (ClientException, Exception) as e:
|
|
return (400, e.message, [])
|
|
return (200, "success", ret)
|
|
|
|
def nova_attach_volume(self, server_id, volume_id):
|
|
try:
|
|
ret = self.novaclient.volumes.create_server_volume(server_id,
|
|
volume_id,
|
|
"/dev/vdb")
|
|
except (ClientException, Exception) as e:
|
|
return (400, e.message, [])
|
|
return (200, "success", ret)
|
|
|
|
def nova_detach_volume(self, server_id, attachment_id):
|
|
try:
|
|
ret = self.novaclient.volumes.delete_server_volume(server_id,
|
|
attachment_id)
|
|
except (ClientException, Exception) as e:
|
|
return (400, e.message, [])
|
|
return (200, "success", ret)
|