heat/vFW_CNF_CDS/automation/instantiate.py

   1 # ============LICENSE_START=======================================================
   2 # Copyright (C) 2020 Orange
   3 # ================================================================================
   4 # Licensed under the Apache License, Version 2.0 (the "License");
   5 # you may not use this file except in compliance with the License.
   6 # You may obtain a copy of the License at
   7 #
   8 #      http://www.apache.org/licenses/LICENSE-2.0
   9 #
  10 # Unless required by applicable law or agreed to in writing, software
  11 # distributed under the License is distributed on an "AS IS" BASIS,
  12 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13 # See the License for the specific language governing permissions and
  14 # limitations under the License.
  15 #
  16 # ============LICENSE_END=========================================================
  17
  18 import logging
  19 import zipfile
  20 from io import BytesIO
  21 from time import sleep
  22 from uuid import uuid4
  23
  24 import oyaml as yaml
  25
  26 from config import Config
  27 from onapsdk.aai.cloud_infrastructure import (
  28     CloudRegion,
  29 )
  30 from onapsdk.aai.business import (
  31     Customer,
  32     OwningEntity as AaiOwningEntity
  33 )
  34 from onapsdk.msb.k8s import Definition
  35
  36 from onapsdk.so.instantiation import (
  37     ServiceInstantiation,
  38     InstantiationParameter, VnfParameters, VfmoduleParameters)
  39 from onapsdk.sdc.service import Service
  40 from onapsdk.vid import LineOfBusiness, OwningEntity, Platform, Project
  41 from onapsdk.so.so_element import OrchestrationRequest
  42
  43 logger = logging.getLogger("")
  44 logger.setLevel(logging.DEBUG)
  45 fh = logging.StreamHandler()
  46 fh_formatter = logging.Formatter('%(asctime)s %(levelname)s %(lineno)d:%(filename)s(%(process)d) - %(message)s')
  47 fh.setFormatter(fh_formatter)
  48 logger.addHandler(fh)
  49
  50 logger.info("*******************************")
  51 logger.info("**** SERVICE INSTANTIATION ****")
  52 logger.info("*******************************")
  53
  54 logger.info("******** Create Customer *******")
  55 customer = None
  56 for found_customer in list(Customer.get_all()):
  57     logger.debug("Customer %s found", found_customer.subscriber_name)
  58     if found_customer.subscriber_name == Config.GLOBAL_CUSTOMER_ID:
  59         logger.info("Customer %s found", found_customer.subscriber_name)
  60         customer = found_customer
  61         break
  62 if not customer:
  63     customer = Customer.create(Config.GLOBAL_CUSTOMER_ID, Config.GLOBAL_CUSTOMER_ID, "INFRA")
  64
  65 logger.info("******** Find Service in SDC *******")
  66 service = None
  67 services = Service.get_all()
  68 for found_service in services:
  69     logger.debug("Service %s is found, distribution %s", found_service.name, found_service.distribution_status)
  70     if found_service.name == Config.SERVICENAME:
  71         logger.info("Found Service %s in SDC", found_service.name)
  72         service = found_service
  73         break
  74
  75 if not service:
  76     logger.error("Service %s not found in SDC", Config.SERVICENAME)
  77     exit(1)
  78
  79 logger.info("******** Check Service Subscription *******")
  80 service_subscription = None
  81 for service_sub in customer.service_subscriptions:
  82     logger.debug("Service subscription %s is found", service_sub.service_type)
  83     if service_sub.service_type == Config.SERVICENAME:
  84         logger.info("Service %s subscribed", Config.SERVICENAME)
  85         service_subscription = service_sub
  86         break
  87
  88 if not service_subscription:
  89     logger.info("******** Subscribe Service *******")
  90     customer.subscribe_service(service)
  91
  92 logger.info("******** Get Tenant *******")
  93 cloud_region = CloudRegion(cloud_owner=Config.CLOUD_OWNER, cloud_region_id=Config.CLOUD_REGION,
  94                            orchestration_disabled=True, in_maint=False)
  95 tenant = None
  96 for found_tenant in cloud_region.tenants:
  97     logger.debug("Tenant %s found in %s_%s", found_tenant.name, cloud_region.cloud_owner, cloud_region.cloud_region_id)
  98     if found_tenant.name == Config.TENANT_NAME:
  99         logger.info("Found my Tenant %s", found_tenant.name)
 100         tenant = found_tenant
 101         break
 102
 103 if not tenant:
 104     logger.error("tenant %s not found", Config.TENANT_NAME)
 105     exit(1)
 106
 107 logger.info("******** Connect Service to Tenant *******")
 108 service_subscription = None
 109 for service_sub in customer.service_subscriptions:
 110     logger.debug("Service subscription %s is found", service_sub.service_type)
 111     if service_sub.service_type == Config.SERVICENAME:
 112         logger.info("Service %s subscribed", Config.SERVICENAME)
 113         service_subscription = service_sub
 114         break
 115
 116 if not service_subscription:
 117     logger.error("Service subscription %s is not found", Config.SERVICENAME)
 118     exit(1)
 119
 120 service_subscription.link_to_cloud_region_and_tenant(cloud_region, tenant)
 121
 122 logger.info("******** Add Business Objects (OE, P, Pl, LoB) in VID *******")
 123 vid_owning_entity = OwningEntity.create(Config.OWNING_ENTITY)
 124 vid_project = Project.create(Config.PROJECT)
 125 vid_platform = Platform.create(Config.PLATFORM)
 126 vid_line_of_business = LineOfBusiness.create(Config.LINE_OF_BUSINESS)
 127
 128 logger.info("******** Add Owning Entity in AAI *******")
 129 owning_entity = None
 130 for oe in AaiOwningEntity.get_all():
 131     if oe.name == vid_owning_entity.name:
 132         owning_entity = oe
 133         break
 134 if not owning_entity:
 135     logger.info("******** Owning Entity not existing: create *******")
 136     owning_entity = AaiOwningEntity.create(vid_owning_entity.name, str(uuid4()))
 137
 138 logger.info("******** Delete old profiles ********")
 139 for vnf in service.vnfs:
 140     for vf_module in vnf.vf_modules:
 141         definition = Definition.get_definition_by_name_version(vf_module.metadata["vfModuleModelInvariantUUID"],
 142                                                                vf_module.metadata["vfModuleModelUUID"])
 143         vf_module_label = vf_module.properties["vf_module_label"]
 144         if vf_module_label == "base_template_dummy_ignore":
 145             continue
 146         profile_name = Config.VF_MODULE_PARAM_LIST[vf_module_label]["k8s-rb-profile-name"]
 147         try:
 148             profile = definition.get_profile_by_name(profile_name)
 149             if profile.namespace != Config.VF_MODULE_PARAM_LIST[vf_module_label]["k8s-rb-profile-namespace"]:
 150                 profile.delete()
 151                 logger.info("Profile: " + profile_name + " for " + vf_module.name + " deleted")
 152             else:
 153                 logger.info("No need to delete Profile " + profile_name +
 154                             " for " + vf_module.name + ". Namespace is fine")
 155         except ValueError:
 156             logger.info("Profile: " + profile_name + " for " + vf_module.name + " not found")
 157
 158
 159 # Read SDNC MODEL NAME and VERSION from CBA.zip
 160 logger.info("*******************************")
 161 logger.info("Retrieving SDNC MODEL NAME and VERSION")
 162 logger.info("*******************************")
 163 with zipfile.ZipFile(Config.VSPFILE, 'r') as package:
 164     cba_io = BytesIO(package.read("CBA.zip"))
 165     with zipfile.ZipFile(cba_io) as cba:
 166         with cba.open('TOSCA-Metadata/TOSCA.meta') as meta_file:
 167             tosca_meta = yaml.load(meta_file, Loader=yaml.FullLoader)
 168             SDNC_MODEL_NAME = tosca_meta.get("Template-Name")
 169             SDNC_MODEL_VERSION = tosca_meta.get("Template-Version")
 170
 171 logger.info("******** Instantiate Service *******")
 172 service_instance = None
 173 service_instantiation = None
 174 for se in service_subscription.service_instances:
 175     if se.instance_name == Config.SERVICE_INSTANCE_NAME:
 176         service_instance = se
 177         break
 178 if not service_instance:
 179     logger.info("******** Service Instance not existing: Instantiate *******")
 180     # Instantiate service
 181     vfmodules_list = Config.VF_MODULE_PARAM_LIST
 182     vnf_param_list = Config.VNF_PARAM_LIST
 183
 184     vnf_param = [
 185         InstantiationParameter(name="sdnc_model_name", value=SDNC_MODEL_NAME),
 186         InstantiationParameter(name="sdnc_model_version", value=SDNC_MODEL_VERSION),
 187         InstantiationParameter(name="sdnc_artifact_name", value=Config.SDNC_ARTIFACT_NAME)]
 188
 189     for vnf_param_name, vnf_param_value in vnf_param_list.items():
 190         vnf_param.append(
 191             InstantiationParameter(name=vnf_param_name, value=vnf_param_value)
 192         )
 193
 194     vfmodules_param = []
 195     for vfmodule in vfmodules_list:
 196         params = [
 197             InstantiationParameter(name="sdnc_model_name", value=SDNC_MODEL_NAME),
 198             InstantiationParameter(name="sdnc_model_version", value=SDNC_MODEL_VERSION),
 199             InstantiationParameter(name="vf_module_label", value=vfmodule)]
 200
 201         for vfmodule_param_name, vfmodule_param_value in vfmodules_list[vfmodule].items():
 202             params.append(
 203                 InstantiationParameter(name=vfmodule_param_name, value=vfmodule_param_value)
 204             )
 205
 206         vfmodules_param.append(VfmoduleParameters(vfmodule, params))
 207
 208     vnf_params = VnfParameters(name=Config.VFNAME, vnf_parameters=vnf_param, vfmodule_parameters=vfmodules_param)
 209
 210     service_instantiation = ServiceInstantiation.instantiate_macro(
 211         sdc_service=service,
 212         cloud_region=cloud_region,
 213         tenant=tenant,
 214         customer=customer,
 215         owning_entity=owning_entity,
 216         project=vid_project,
 217         line_of_business=vid_line_of_business,
 218         platform=vid_platform,
 219         service_instance_name=Config.SERVICE_INSTANCE_NAME,
 220         vnf_parameters=[vnf_params]
 221     )
 222     status = None
 223     while not (status == OrchestrationRequest.StatusEnum.COMPLETED
 224                or status == OrchestrationRequest.StatusEnum.FAILED):
 225         sleep(10)
 226         status = service_instantiation.status
 227         logger.info(f"Orchestration status is: {status.value}")