¡@
OpenStack Study: cinder.py**** CubicPower OpenStack Study ****
# 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. """Storage backend for Cinder""" from cinderclient import exceptions as cinder_exception from cinderclient import service_catalog from cinderclient.v2 import client as cinderclient from oslo.config import cfg from glance.common import exception from glance.common import utils import glance.openstack.common.log as logging from glance.openstack.common import units import glance.store.base import glance.store.location LOG = logging.getLogger(__name__) cinder_opts = [ cfg.StrOpt('cinder_catalog_info', default='volume:cinder:publicURL', help='Info to match when looking for cinder in the service ' 'catalog. Format is: separated values of the form: ' ' cfg.StrOpt('cinder_endpoint_template', default=None, help='Override service catalog lookup with template for cinder ' 'endpoint e.g. http://localhost:8776/v1/%(project_id)s.'), cfg.StrOpt('os_region_name', default=None, help='Region name of this node.'), cfg.StrOpt('cinder_ca_certificates_file', default=None, help='Location of CA certicates file to use for cinder client ' 'requests.'), cfg.IntOpt('cinder_http_retries', default=3, help='Number of cinderclient retries on failed http calls.'), cfg.BoolOpt('cinder_api_insecure', default=False, help='Allow to perform insecure SSL requests to cinder.'), ] CONF = cfg.CONF CONF.register_opts(cinder_opts)
**** CubicPower OpenStack Study **** def get_cinderclient(context): if CONF.cinder_endpoint_template: url = CONF.cinder_endpoint_template % context.to_dict() else: info = CONF.cinder_catalog_info service_type, service_name, endpoint_type = info.split(':') # extract the region if set in configuration if CONF.os_region_name: attr = 'region' filter_value = CONF.os_region_name else: attr = None filter_value = None # FIXME: the cinderclient ServiceCatalog object is mis-named. # It actually contains the entire access blob. # Only needed parts of the service catalog are passed in, see # nova/context.py. compat_catalog = { 'access': {'serviceCatalog': context.service_catalog or []}} sc = service_catalog.ServiceCatalog(compat_catalog) url = sc.url_for(attr=attr, filter_value=filter_value, service_type=service_type, service_name=service_name, endpoint_type=endpoint_type) LOG.debug(_('Cinderclient connection created using URL: %s') % url) c = cinderclient.Client(context.user, context.auth_tok, project_id=context.tenant, auth_url=url, insecure=CONF.cinder_api_insecure, retries=CONF.cinder_http_retries, cacert=CONF.cinder_ca_certificates_file) # noauth extracts user_id:project_id from auth_token c.client.auth_token = context.auth_tok or '%s:%s' % (context.user, context.tenant) c.client.management_url = url return c
**** CubicPower OpenStack Study **** class StoreLocation(glance.store.location.StoreLocation): """Class describing a Cinder URI"""
**** CubicPower OpenStack Study **** def process_specs(self): self.scheme = self.specs.get('scheme', 'cinder') self.volume_id = self.specs.get('volume_id')
**** CubicPower OpenStack Study **** def get_uri(self): return "cinder://%s" % self.volume_id
**** CubicPower OpenStack Study **** def parse_uri(self, uri): if not uri.startswith('cinder://'): reason = _("URI must start with cinder://") LOG.error(reason) raise exception.BadStoreUri(uri, reason) self.scheme = 'cinder' self.volume_id = uri[9:] if not utils.is_uuid_like(self.volume_id): reason = _("URI contains invalid volume ID: %s") % self.volume_id LOG.error(reason) raise exception.BadStoreUri(uri, reason)
**** CubicPower OpenStack Study **** class Store(glance.store.base.Store): """Cinder backend store adapter.""" EXAMPLE_URL = "cinder://volume-id"
**** CubicPower OpenStack Study **** def get_schemes(self): return ('cinder',)
**** CubicPower OpenStack Study **** def configure_add(self): """ Configure the Store to use the stored configuration options Any store that needs special configuration should implement this method. If the store was not able to successfully configure itself, it should raise `exception.BadStoreConfiguration` """ if self.context is None: reason = _("Cinder storage requires a context.") raise exception.BadStoreConfiguration(store_name="cinder", reason=reason) if self.context.service_catalog is None: reason = _("Cinder storage requires a service catalog.") raise exception.BadStoreConfiguration(store_name="cinder", reason=reason)
**** CubicPower OpenStack Study **** def get_size(self, location): """ Takes a `glance.store.location.Location` object that indicates where to find the image file and returns the image size :param location `glance.store.location.Location` object, supplied from glance.store.location.get_location_from_uri() :raises `glance.exception.NotFound` if image does not exist :rtype int """ loc = location.store_location try: volume = get_cinderclient(self.context).volumes.get(loc.volume_id) # GB unit convert to byte return volume.size * units.Gi except cinder_exception.NotFound as e: reason = _("Failed to get image size due to " "volume can not be found: %s") % self.volume_id LOG.error(reason) raise exception.NotFound(reason) except Exception as e: LOG.exception(_("Failed to get image size due to " "internal error: %s") % e) return 0
|