OpenStack Mitaka Nova API 接口扩展之instance_resize
# Mitaka NOVA API 接口开发背景： OpenStack官方默认Resize接口支持local storage 不是很好，问题很多，因此重新定
制Resize接口,实现云主机套餐变更,比之前的接口提高了很多时间
### 配置 Resize 路由
vim /usr/lib/python2.7/site-packages/nova-13.1.0-py2.7.egg-info/entry_points.txt
instance_resize = nova.api.openstack.compute.instance_resize:InstanceResize
access_ips = nova.api.openstack.compute.access_ips:AccessIPs
admin_actions = nova.api.openstack.compute.admin_actions:AdminActions
admin_password = nova.api.openstack.compute.admin_password:AdminPassword
agents = nova.api.openstack.compute.agents:Agents
aggregates = nova.api.openstack.compute.aggregates:Aggregates
assisted_volume_snapshots = nova.api.openstack.compute.assisted_volume_snapshots:AssistedVolumeSnapshots
attach_interfaces = nova.api.openstack.compute.attach_interfaces:AttachInterfaces
availability_zone = nova.api.openstack.compute.availability_zone:AvailabilityZone
baremetal_nodes = nova.api.openstack.compute.baremetal_nodes:BareMetalNodes
block_device_mapping = nova.api.openstack.compute.block_device_mapping:BlockDeviceMapping
cells = nova.api.openstack.compute.cells:Cells
certificates = nova.api.openstack.compute.certificates:Certificates
cloudpipe = nova.api.openstack.compute.cloudpipe:Cloudpipe
config_drive = nova.api.openstack.compute.config_drive:ConfigDrive
console_auth_tokens = nova.api.openstack.compute.console_auth_tokens:ConsoleAuthTokens
console_output = nova.api.openstack.compute.console_output:ConsoleOutput ### 定制API 接口
* Mitaka 接口开发目录与Havana 版本发生变化，所有的接口放在nova/api/openstack/compute/目录中，在此目录中创建Resize 接口
# Copyright 2013 Rackspace Hosting
# All Rights Reserved.
#
# 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 webob import exc
from nova.api.openstack import common
from nova.api.openstack import extensions
from nova.api.openstack import wsgi
from nova import compute
#from nova.i18n import _
from oslo_log import log as logging
from nova.extend import api as extend_api
from nova import utils
LOG = logging.getLogger(__name__)
ALIAS = "os-instance-resize"
authorize = extensions.os_compute_authorizer(ALIAS)
class InstanceResizeController(wsgi.Controller):
def __init__(self):
#super(InstanceResizeController, self).__init__()
self.compute_api = compute.API(skip_policy_check=True)
@wsgi.Controller.api_version("2.1", "2.20")
def _get_instance(self, req, context, server_id):
return common.get_instance(self.compute_api, context, server_id)
@extensions.expected_errors(404)
def index(self,req):
"""Returns the list of actions recorded for a given instance."""
context = req.environ["nova.context"]
LOG.info("index.dir %s" %context)
LOG.info("index.InstanceResizeController is ok")
return "True"
@extensions.expected_errors(404)
def create(self,req,body):
try:
"""Return data about the given instance action."""
context = req.environ["nova.context"]
flavor = body['flavor']
instance_uuid= body['instance_uuid']
resize_api = extend_api.LocalAPI()
result = resize_api.instance_resize(context,req,flavor,instance_uuid)
#Reboot to instances
body = {'reboot': {'type': 'SOFT'}}
reboot_type = body['reboot']['type'].upper()
instance = self._get_instance(req, context, instance_uuid)
try:
self.compute_api.reboot(context, instance, reboot_type)
except exception.InstanceIsLocked as e:
raise exc.HTTPConflict(explanation=e.format_message())
except exception.InstanceInvalidState as state_error:
common.raise_http_conflict_for_instance_invalid_state(state_error,
'reboot', id)
LOG.info("create.InstanceResizeController is ok %s.%s.%s" % (result,flavor,instance_uuid))
return str(result )
except:
return "False"
LOG.error(traceback.format_exc())
@extensions.expected_errors(404)
def delete(self,req):
"""Return data about the given instance action."""
LOG.info("delete.InstanceResizeController is ok")
return "True"
@extensions.expected_errors(404)
def update(self,req):
"""Return data about the given instance action."""
LOG.info("update.InstanceResizeController is ok")
return "True"
@extensions.expected_errors(404)
def show(self,req):
"""Return data about the given instance action."""
LOG.info("show.InstanceResizeController is ok")
return "True"
class InstanceResize(extensions.V21APIExtensionBase):
"""View a log of actions and events taken on an instance."""
name = "InstanceResize"
alias = ALIAS
version = 1
def get_resources(self):
ext = extensions.ResourceExtension(ALIAS,
InstanceResizeController(),)
return
def get_controller_extensions(self):
"""It's an abstract function V21APIExtensionBase and the extension
will not be loaded without it.
"""
return [] ### 定制extend.api
# Copyright 2012 IBM Corp.
#
# 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.
"""Handles all requests to the extend service. Compute health checks"""
import os,sys,time,traceback,json
from oslo_config import cfg
import nova.conf
from nova.extend import manager
from oslo_log import log as logging
from nova import utils
from nova.extend import instance_resize as InstanceResize
conductor_opts = [
cfg.StrOpt('topic',
default='extend',
help='the topic extend nodes listen on'),
cfg.StrOpt('manager',
default='nova.extend.manager.ExtendManager',
help='full class name for the Manager for extend'),
cfg.IntOpt('workers',
help='Number of workers for OpenStack Extend service')
]
extend_group = cfg.OptGroup(name='extend',
title='exntend Options')
CONF=nova.conf.CONF
CONF.register_group(extend_group)
CONF.register_opts(conductor_opts, extend_group)
LOG = logging.getLogger(__name__)
class LocalAPI(object):
"""A local version of the exten API that does compute health chekcs and virtual machine restart.
"""
def __init__(self):
# TODO(danms): This needs to be something more generic for
# other/future users of this sort of functionality.
self._manager = utils.ExceptionHelper(manager.ExtendManager())
def instance_resize(self,context,req,flavor,instance_uuid):
# instance resize for nova.extend.instance_resize
try:
resize_action = InstanceResize.InstanceResize()
resize_action.work(context,req,flavor,instance_uuid)
LOG.info("instance_resize.Extend.API.%s.%s" %(flavor,instance_uuid))
return True
except:
LOG.error(traceback.format_exc())
return False ### 定制Extend.instance_resize
#opyright 2013 Rackspace Hosting
# All Rights Reserved.
#
# 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.
import os
import time
import sys
import nova.conf
import traceback
import json
from oslo_log import log as logging
from nova import db
from nova import compute
import base64
import re
from oslo_config import cfg
from oslo_log import log as logging
import oslo_messaging as messaging
from oslo_utils import strutils
from oslo_utils import timeutils
from oslo_utils import uuidutils
import six
import stevedore
import webob
from webob import exc
from nova.api.openstack import api_version_request
from nova.api.openstack import common
from nova.api.openstack.compute.schemas import servers as schema_servers
from nova.api.openstack.compute.views import servers as views_servers
from nova.api.openstack import extensions
from nova.api.openstack import wsgi
from nova.api import validation
from nova import compute
from nova.compute import flavors
from nova import exception
from nova.i18n import _
from nova.i18n import _LW
from nova.image import glance
from nova import objects
from nova import utils
LOG = logging.getLogger(__name__)
class InstanceResize(object):
def __init__(self):
version = 'v1.0'
self.compute_api = compute.API(skip_policy_check=True)
def instance_system_metadata_update_havana(self,context,req,instance_uuid,metadata,delete):
metadata = db.instance_system_metadata_update(context, instance_uuid, metadata,delete)
LOG.info("instance_system_metadata_update %s" %metadata)
def instance_extra_update_by_uuid_mitaka(self,context,req,instance_uuid,metadata):
values = {'flavor':metadata}
update_extra = db.instance_extra_update_by_uuid(context, instance_uuid,values)
if update_extra == 1:
LOG.info("instance_extra_update_by_uuid_mitaka %s update is oK" %instance_uuid )
def flavor_get_by_name_havana(self,context,req,name):
# get flavor dict for db.flavor_get_by_name to havana version
meta = db.flavor_get_by_name(context,name)
metadata = dict()
metadata['instance_type_memory_mb'] = meta['memory_mb']
metadata['instance_type_id'] = meta['id']
metadata['instance_type_name'] = meta['name']
metadata['instance_type_flavorid'] = meta['flavorid']
LOG.info('flavor_get_by_name metadata %s' %metadata)
return metadata
def flavor_get_by_name_mitaka(self,context,req,flavor,instance_uuid):
new_meta = db.flavor_get_by_name(context,flavor)
meta = db.instance_extra_get_by_instance_uuid(context,instance_uuid)
# get nova.instance_extra.flavor for data
json_meta = json.loads(meta['flavor'])
json_meta['cur']['nova_object.data'] = new_meta
# Time format to str
stime = json_meta['cur']['nova_object.data']['created_at']
timestamp=time.localtime(time.mktime(stime.timetuple()))
ntime = time.strftime("%Y-%m-%dT%H:%M:%S",timestamp)
json_meta['cur']['nova_object.data']['created_at'] = ntime
metadata = json.dumps(json_meta)
LOG.info("flavor_get_by_name_mitaka.meta:%s" %metadata)
returnmetadata
def work(self,context,req,flavor,instance_uuid):
LOG.info("InstanceResize.work.%s.%s"%(flavor,instance_uuid))
metadata =self.flavor_get_by_name_mitaka(context,req,flavor,instance_uuid)
self.instance_extra_update_by_uuid_mitaka(context,req,instance_uuid,metadata)
return True ### 接口验证测试
import os,sys,json,time,socket,traceback,urllib2,urllib
def post(url,data):
cmds ="""curl -d '{"auth": {"tenantName": "admin", "passwordCredentials": {"username": "root",
"password":"XXXXXXXXX"}}}' -H "Content-type: application/json" http://127.0.0.1:35357/v2.0/tokens"""
info =os.popen(cmds).readline()
jsondata = json.loads(info)
for x,y in jsondata.items():
dat = y
token_id= dat['token']['id']
tenant_id = dat['token']['tenant']['id']
url = "http://127.0.0.1:8774/v2.1/%s/os-instance-resize" % tenant_id
try:
json_data = json.dumps(data)
socket.setdefaulttimeout(5)
httpsHandler = urllib2.HTTPSHandler(debuglevel = 1)
opener = urllib2.build_opener(httpsHandler)
urllib2.install_opener(opener)
request = urllib2.Request(url, json_data)
request.add_header('User-Agent',"Mozilla/5.0 (Windows NT 6.1; rv:6.0.2) Gecko/20120701 Firefox/6.0.2")
request.add_header('Content-type','application/json')
request.add_header('Accept','application/json')
request.add_header('charset','UTF-8')
request.add_header('X-Auth-Token',token_id)
response = urllib2.urlopen(request)
#res =json.loads(response.readlines())
except Exception,e:
print ('Post %s is failed \n %s' %(url,traceback.format_exc()))
if __name__ == "__main__":
url= "http://127.0.0.1:8774/v2.1/82572642-04da-44aa-a18d-4280589b7a3d/os-instance-resize"
data ={"flavor":"windows-16-16G-100G","instance_uuid":"351ab096-6ab1-496c-a4d7-cc91f78c6eca"}
sc = post(url,data)
### 验证接口,日志输出
python extend/token.py
2016-09-23 12:31:26.382 5642 WARNING keystonemiddleware.auth_token [-] Using the in-process token cache is deprecated as of the 4.2.0 release and may be removed in the 5.0.0 release or the 'O'
development cycle. The in-process cache causes inconsistent results and high memory usage. When the feature is removed the auth_token middleware will not cache tokens by default which may result in performance issues. It is recommended to usememcache for the auth_token token cache by setting the memcached_servers option.2016-09-23 12:31:27.684 5642 INFO nova.extend.instance_resize InstanceResize.
work.linux-16-16G-100G.82572642-04da-44aa-a18d-4280589b7a3d2016-09-23 12:31:27.703 5642 INFO nova.extend.instance_resize flavor_get_by_n
ame_mitaka.meta:{"new": null, "old": null, "cur": {"nova_object.version": "1.1", "nova_object.name": "Flavor", "nova_object.namespace": "nova", "nova_object.data": {"memory_mb": 16384, "flavorid": "19552bc2-de5b-442d-80c8-e54907a08cc5", "name": "linux-16-16G-100G", "deleted": 0, "created_at": "2016-09-19T06:16:16", "ephemeral_gb": 100, "updated_at": null, "disabled": false, "vcpus": 16, "root_gb": 120, "extra_specs": {}, "swap": 0, "rxtx_factor": 1.0, "is_public": true, "deleted_at": null, "vcpu_weight": null, "id": 9}}}2016-09-23 12:31:27.707 5642 INFO nova.extend.instance_resize instance_extra_
update_by_uuid_mitaka 82572642-04da-44aa-a18d-4280589b7a3d update is oK2016-09-23 12:31:27.707 5642 INFO nova.extend.api instance_resize.Extend.API.
linux-16-16G-100G.82572642-04da-44aa-a18d-4280589b7a3d2016-09-23 12:31:27.829 5642 INFO nova.api.openstack.compute.instance_resize
create.InstanceResizeController is ok True.linux-16-16G-100G.82572642-04da-44aa-a18d-4280589b7a3d2016-09-23 12:31:27.830 5642 INFO nova.osapi_compute.wsgi.server 127.0.0.1 "P
OST /v2.1/7b98a7afb66542c7874ddec80b41a665/os-instance-resize HTTP/1.1" status: 200 len: 202 time: 1.4489350
页:
[1]