1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
|
# ============LICENSE_START=======================================================
# Copyright (C) 2020 Orange
# ================================================================================
# 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.
#
# ============LICENSE_END=========================================================
import logging
import os
from uuid import uuid4
from config import Config
from k8s_client import K8sClient
from so_db_adapter import SoDBUpdate
from onapsdk.aai.business import Customer
from onapsdk.aai.cloud_infrastructure import Complex, CloudRegion
from onapsdk.msb.k8s import ConnectivityInfo
from onapsdk.exceptions import ResourceNotFound
logger = logging.getLogger("")
logger.setLevel(logging.DEBUG)
fh = logging.StreamHandler()
fh_formatter = logging.Formatter('%(asctime)s %(levelname)s %(lineno)d:%(filename)s(%(process)d) - %(message)s')
fh.setFormatter(fh_formatter)
logger.addHandler(fh)
MYPATH = os.path.dirname(os.path.realpath(__file__))
#### Create complex if not exists ####
logger.info("******** Complex *******")
try:
complex = list(Complex.get_all(physical_location_id=Config.COMPLEX_ID))[0]
logger.info("Complex exists")
except (IndexError, ResourceNotFound):
logger.info("Complex does not exists")
complex = Complex.create(physical_location_id=Config.COMPLEX_ID,
name=Config.COMPLEX_ID,
physical_location_type="office",
street1="DummyStreet 1",
city="DummyCity",
postal_code="00-000",
country="DummyCountry",
region="DummyRegion")
logger.info("Complex created")
#### Create cloud region if not exists ####
logger.info("******** Cloud Region *******")
try:
cloud_region = list(CloudRegion.get_all(cloud_owner=Config.CLOUD_OWNER, cloud_region_id=Config.CLOUD_REGION))[0]
logger.info("Cloud region exists")
except (IndexError, ResourceNotFound):
logger.info("Cloud region does not exists")
cloud_region = CloudRegion.create(cloud_owner=Config.CLOUD_OWNER,
cloud_region_id=Config.CLOUD_REGION,
cloud_type="k8s",
owner_defined_type="t1",
cloud_region_version="1.0",
complex_name=complex.physical_location_id,
cloud_zone="CloudZone",
sriov_automation="false",
orchestration_disabled=False,
in_maint=False)
logger.info("Cloud region created")
logger.info("******** Cloud regiongion <-> Complex *******")
cloud_region.link_to_complex(complex)
logger.info("******** Availability zone *******")
try:
az = cloud_region.get_availability_zone_by_name(Config.AVAILABILITY_ZONE_NAME)
logger.info("Availability zone exists")
except ResourceNotFound:
logger.info("Availability zone does not exist")
cloud_region.add_availability_zone(availability_zone_name=Config.AVAILABILITY_ZONE_NAME,
availability_zone_hypervisor_type=Config.HYPERVISOR_TYPE)
logger.info("Availability zone added to region")
logger.info("******** Tenant *******")
try:
next(_tenant for _tenant in cloud_region.tenants if _tenant.name == Config.TENANT_NAME)
logger.info("Tenant exists")
except (StopIteration, ResourceNotFound):
tenant_id = str(uuid4())
logger.info("Tenant does not exist")
cloud_region.add_tenant(tenant_id=tenant_id,
tenant_name=Config.TENANT_NAME)
logger.info(f"Tenant {Config.TENANT_NAME} added to region")
#### Update or create connectivity info ####
logger.info("******** Connectivity Info *******")
with open(os.path.join(MYPATH, Config.CLUSTER_KUBECONFIG_PATH), 'rb') as kubeconfig_file:
kubeconfig = kubeconfig_file.read()
try:
connectivity_info = ConnectivityInfo.get_connectivity_info_by_region_id(cloud_region_id=Config.CLOUD_REGION)
logger.info("Connectivity Info exists ")
logger.info("Delete Connectivity Info ")
connectivity_info.delete()
connectivity_info = ConnectivityInfo.create(cloud_region_id=Config.CLOUD_REGION,
cloud_owner=Config.CLOUD_OWNER,
kubeconfig=kubeconfig)
logger.info("Connectivity Info created ")
except:
logger.info("Connectivity Info does not exists ")
connectivity_info = ConnectivityInfo.create(cloud_region_id=Config.CLOUD_REGION,
cloud_owner=Config.CLOUD_OWNER,
kubeconfig=kubeconfig)
logger.info("Connectivity Info created ")
#### Add Custom Resource Definitions ####
k8s_client = K8sClient(kubeconfig_path=Config.CLUSTER_KUBECONFIG_PATH)
for crd in Config.CUSTOMER_RESOURCE_DEFINITIONS:
k8s_client.create_custom_object(crd)
#### Create customer if not exists ####
logger.info("******** Customer *******")
try:
customer = Customer.get_by_global_customer_id(Config.GLOBAL_CUSTOMER_ID)
logger.info("Customer exists")
except:
logger.info("Customer exists")
customer = Customer.create(Config.GLOBAL_CUSTOMER_ID, Config.GLOBAL_CUSTOMER_ID, "INFRA")
logger.info("Customer created")
#### Add region to SO db ####
logger.info("******** SO Database *******")
result = SoDBUpdate.add_region_to_so_db(cloud_region_id=Config.CLOUD_REGION,
complex_id=Config.COMPLEX_ID)
if result.status_code == 201:
logger.info("Region in SO db created successfully")
else:
logger.error("Creating region in SO db failed")
|
