X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=planetstack%2Fopenstack_observer%2Fsteps%2Fsync_slivers.py;h=8155c10300f7253da13293472616d0c11074a6d4;hb=ac5578b11e845c752b83f44371c8e1dd58f7e22b;hp=6f61f5337914dba283de5fce15c5b37e10005a32;hpb=e03406ba1e1aa6290547a8a8fe6622875117d715;p=plstackapi.git diff --git a/planetstack/openstack_observer/steps/sync_slivers.py b/planetstack/openstack_observer/steps/sync_slivers.py index 6f61f53..8155c10 100644 --- a/planetstack/openstack_observer/steps/sync_slivers.py +++ b/planetstack/openstack_observer/steps/sync_slivers.py @@ -4,11 +4,10 @@ from django.db.models import F, Q from planetstack.config import Config from observer.openstacksyncstep import OpenStackSyncStep from core.models.sliver import Sliver -from core.models.slice import Slice, SlicePrivilege, ControllerSlices -from core.models.network import Network, NetworkSlice, ControllerNetworks +from core.models.slice import Slice, SlicePrivilege, ControllerSlice +from core.models.network import Network, NetworkSlice, ControllerNetwork from util.logger import Logger, logging from observer.ansible import * -import pdb logger = Logger(level=logging.INFO) @@ -46,7 +45,7 @@ class SyncSlivers(OpenStackSyncStep): nics = [] networks = [ns.network for ns in NetworkSlice.objects.filter(slice=sliver.slice)] - controller_networks = ControllerNetworks.objects.filter(network__in=networks, + controller_networks = ControllerNetwork.objects.filter(network__in=networks, controller=sliver.node.site_deployment.controller) for controller_network in controller_networks: @@ -55,11 +54,11 @@ class SyncSlivers(OpenStackSyncStep): nics.append(controller_network.net_id) # now include network template - network_templates = [network.template.sharedNetworkName for network in networks \ - if network.template.sharedNetworkName] + network_templates = [network.template.shared_network_name for network in networks \ + if network.template.shared_network_name] #driver = self.driver.client_driver(caller=sliver.creator, tenant=sliver.slice.name, controller=sliver.controllerNetwork) - driver = self.driver.admin_driver(tenant='admin', controller=sliver.controllerNetwork) + driver = self.driver.admin_driver(tenant='admin', controller=sliver.node.site_deployment.controller) nets = driver.shell.quantum.list_networks()['networks'] for net in nets: if net['name'] in network_templates: @@ -71,7 +70,7 @@ class SyncSlivers(OpenStackSyncStep): nics.append(net['id']) # look up image id - controller_driver = self.driver.admin_driver(controller=sliver.controllerNetwork) + controller_driver = self.driver.admin_driver(controller=sliver.node.site_deployment.controller) image_id = None images = controller_driver.shell.glanceclient.images.list() for image in images: @@ -94,7 +93,7 @@ class SyncSlivers(OpenStackSyncStep): if (legacy): host_filter = sliver.node.name.split('.',1)[0] else: - host_filter = sliver.node.name + host_filter = sliver.node.name.strip() availability_zone_filter = 'nova:%s'%host_filter sliver_name = '%s-%d'%(sliver.slice.name,sliver.id) @@ -103,10 +102,10 @@ class SyncSlivers(OpenStackSyncStep): if sliver.userData: userData = sliver.userData - controller = sliver.controllerNetwork + controller = sliver.node.site_deployment.controller tenant_fields = {'endpoint':controller.auth_url, - 'admin_user': sliver.creator.username, - 'admin_password': sliver.creator.password, + 'admin_user': sliver.creator.email, + 'admin_password': sliver.creator.remote_password, 'admin_tenant': sliver.slice.name, 'tenant': sliver.slice.name, 'tenant_description': sliver.slice.description, @@ -115,7 +114,7 @@ class SyncSlivers(OpenStackSyncStep): 'availability_zone': availability_zone_filter, 'image_id':image_id, 'key_name':keyname, - 'flavor_id':3, + 'flavor_id':sliver.flavor.id, 'nics':nics, 'meta':metadata_update, 'key':key_fields, @@ -125,9 +124,18 @@ class SyncSlivers(OpenStackSyncStep): if (len(res)!=2): raise Exception('Could not sync sliver %s'%sliver.slice.name) else: - sliver_id = res[1]['id'] # 0 is for the key + sliver_id = res[1]['info']['OS-EXT-SRV-ATTR:instance_name'] # 0 is for the key + sliver_uuid = res[1]['id'] # 0 is for the key + + try: + hostname = res[1]['info']['OS-EXT-SRV-ATTR:hypervisor_hostname'] + ip = socket.gethostbyname(hostname) + sliver.ip = ip + except: + pass sliver.instance_id = sliver_id + sliver.instance_uuid = sliver_uuid sliver.instance_name = sliver_name sliver.save()