planetstack/openstack_observer/steps/sync_slivers.py

   1 import os
   2 import base64
   3 from django.db.models import F, Q
   4 from planetstack.config import Config
   5 from observer.openstacksyncstep import OpenStackSyncStep
   6 from core.models.sliver import Sliver
   7 from core.models.slice import Slice, SlicePrivilege, SliceDeployments
   8 from core.models.network import Network, NetworkSlice, NetworkDeployments
   9 from util.logger import Logger, logging
  10
  11 logger = Logger(level=logging.INFO)
  12
  13 class SyncSlivers(OpenStackSyncStep):
  14     provides=[Sliver]
  15     requested_interval=0
  16
  17     def sync_record(self, sliver):
  18         logger.info("sync'ing sliver:%s deployment:%s " % (sliver, sliver.node.deployment))
  19         metadata_update = {}
  20         if ("numberCores" in sliver.changed_fields):
  21             metadata_update["cpu_cores"] = str(sliver.numberCores)
  22
  23         for tag in sliver.slice.tags.all():
  24             if tag.name.startswith("sysctl-"):
  25                 metadata_update[tag.name] = tag.value
  26
  27         if not sliver.instance_id:
  28             driver = self.driver.client_driver(caller=sliver.creator, tenant=sliver.slice.name, deployment=sliver.deploymentNetwork.name)
  29             # public keys
  30             slice_memberships = SlicePrivilege.objects.filter(slice=sliver.slice)
  31             pubkeys = [sm.user.public_key for sm in slice_memberships if sm.user.public_key]
  32             if sliver.creator.public_key:
  33                 pubkeys.append(sliver.creator.public_key)
  34             if sliver.slice.creator.public_key:
  35                 pubkeys.append(sliver.slice.creator.public_key)
  36             # netowrks
  37             # include all networks available to the slice and/or associated network templates
  38             nics = []
  39             networks = [ns.network for ns in NetworkSlice.objects.filter(slice=sliver.slice)]
  40             network_deployments = NetworkDeployments.objects.filter(network__in=networks,
  41                                                                     deployment=sliver.node.deployment)
  42             # Gather private networks first. This includes networks with a template that has
  43             # visibility = private and translation = none
  44             for network_deployment in network_deployments:
  45                 if network_deployment.network.template.visibility == 'private' and \
  46                    network_deployment.network.template.translation == 'none':
  47                     nics.append({'net-id': network_deployment.net_id})
  48
  49             # now include network template
  50             network_templates = [network.template.sharedNetworkName for network in networks \
  51                                  if network.template.sharedNetworkName]
  52             #logger.info("%s %s %s %s" % (driver.shell.quantum.username, driver.shell.quantum.password, driver.shell.quantum.tenant, driver.shell.quantum.url))
  53             for net in driver.shell.quantum.list_networks()['networks']:
  54                 if net['name'] in network_templates:
  55                     nics.append({'net-id': net['id']})
  56
  57             # look up image id
  58             deployment_driver = self.driver.admin_driver(deployment=sliver.deploymentNetwork.name)
  59             image_id = None
  60             images = deployment_driver.shell.glance.get_images()
  61             for image in images:
  62                 if image['name'] == sliver.image.name:
  63                     image_id = image['id']
  64
  65             # look up key name at the deployment
  66             # create/fetch keypair
  67             keyname = None
  68             if sliver.creator.public_key:
  69                 keyname = sliver.creator.email.lower().replace('@', 'AT').replace('.', '') +\
  70                           sliver.slice.name
  71                 key_fields =  {'name': keyname,
  72                                'public_key': sliver.creator.public_key}
  73                 driver.create_keypair(**key_fields)
  74
  75             instance = driver.spawn_instance(name=sliver.name,
  76                                 key_name = keyname,
  77                                 image_id = image_id,
  78                                 hostname = sliver.node.name,
  79                                 pubkeys = pubkeys,
  80                                 nics = nics,
  81                                 userdata = sliver.userData )
  82             sliver.instance_id = instance.id
  83             sliver.instance_name = getattr(instance, 'OS-EXT-SRV-ATTR:instance_name')
  84             sliver.save()
  85
  86         if sliver.instance_id and metadata_update:
  87             driver.update_instance_metadata(sliver.instance_id, metadata_update)
  88
  89     def delete_record(self, sliver):
  90         if sliver.instance_id:
  91             driver = self.driver.client_driver(caller=sliver.creator,
  92                                                tenant=sliver.slice.name,
  93                                                deployment=sliver.deploymentNetwork.name)
  94             driver.destroy_instance(sliver.instance_id)