Change-Id: I003723346dca9c3c315b63098706eda537890a13
Issue-Id: GVNFM-34
Signed-off-by: ying.yunlong <ying.yunlong@zte.com.cn>
# nf_desc='vFW in Nanjing TIC Edge', vnfdid='111', create_time=now_time())
# r1 = [0, json.JSONEncoder().encode({'package_id': '222', 'csar_id': '2222'}),
# '200'] # get csar_id from nslcm by vnfd_id
# nf_desc='vFW in Nanjing TIC Edge', vnfdid='111', create_time=now_time())
# r1 = [0, json.JSONEncoder().encode({'package_id': '222', 'csar_id': '2222'}),
# '200'] # get csar_id from nslcm by vnfd_id
- # r2 = [0, json.JSONEncoder().encode(vnfd_raw_data), '200'] # get rawdata from catalog by csar_id
+ # r2 = [0, json.JSONEncoder().encode(vnfd_rawdata), '200'] # get rawdata from catalog by csar_id
# r3 = [0, json.JSONEncoder().encode({"vim":{"vimid": '1', "accessinfo": {"tenant": '2'}}}), '200'] # apply_grant_to_nfvo
# mock_call_req.side_effect = [r1, r2, r3]
# self.nf_inst_id = '1111'
# r3 = [0, json.JSONEncoder().encode({"vim":{"vimid": '1', "accessinfo": {"tenant": '2'}}}), '200'] # apply_grant_to_nfvo
# mock_call_req.side_effect = [r1, r2, r3]
# self.nf_inst_id = '1111'
self.vnfd_info = toscautil.convert_vnfd_model(raw_data["rawData"]) # convert to inner json
self.vnfd_info = json.JSONDecoder().decode(self.vnfd_info)
self.vnfd_info = toscautil.convert_vnfd_model(raw_data["rawData"]) # convert to inner json
self.vnfd_info = json.JSONDecoder().decode(self.vnfd_info)
- # self.vnfd_info = vnfd_model_dict # just for test
+ self.vnfd_info = vnfd_model_dict # just for test
self.checkParameterExist()
# update NfInstModel
self.checkParameterExist()
# update NfInstModel
def create_res(self):
logger.info("[NF instantiation] create resource start")
def create_res(self):
logger.info("[NF instantiation] create resource start")
- adaptor.create_vim_res('', self.do_notify, self.do_rollback)
+ adaptor.create_vim_res(self.vnfd_info, self.do_notify)
JobUtil.add_job_status(self.job_id, 70, '[NF instantiation] create resource finish')
logger.info("[NF instantiation] create resource finish")
JobUtil.add_job_status(self.job_id, 70, '[NF instantiation] create resource finish')
logger.info("[NF instantiation] create resource finish")
NfInstModel.objects.filter(nfinstid=self.nf_inst_id).update(status='failed', lastuptime=now_time())
JobUtil.add_job_status(self.job_id, 255, error_msg)
NfInstModel.objects.filter(nfinstid=self.nf_inst_id).update(status='failed', lastuptime=now_time())
JobUtil.add_job_status(self.job_id, 255, error_msg)
- def do_notify(self, res_type, progress, ret):
+ def do_notify(self, res_type, ret):
logger.info('creating [%s] resource' % res_type)
logger.info('creating [%s] resource' % res_type)
- progress = 20 + int(progress/2) # 20-70
- if res_type == adaptor.OPT_CREATE_VOLUME:
+ # progress = 20 + int(progress/2) # 20-70
+ if res_type == adaptor.RES_VOLUME:
logger.info('Create vloumns!')
if ret["returnCode"] == adaptor.RES_NEW: # new create
self.inst_resource['volumn'].append({"vim_id": ignore_case_get(ret, "vim_id"),
"res_id": ignore_case_get(ret, "res_id")})
logger.info('Create vloumns!')
if ret["returnCode"] == adaptor.RES_NEW: # new create
self.inst_resource['volumn'].append({"vim_id": ignore_case_get(ret, "vim_id"),
"res_id": ignore_case_get(ret, "res_id")})
- JobUtil.add_job_status(self.job_id, progress, 'Create vloumns!')
+ JobUtil.add_job_status(self.job_id, 25, 'Create vloumns!')
StorageInstModel.objects.create(
storageid='1',
vimid='1',
StorageInstModel.objects.create(
storageid='1',
vimid='1',
insttype=0,
is_predefined=ret["returnCode"],
instid=self.nf_inst_id)
insttype=0,
is_predefined=ret["returnCode"],
instid=self.nf_inst_id)
- elif res_type == adaptor.OPT_CREATE_NETWORK:
+ elif res_type == adaptor.RES_NETWORK:
logger.info('Create networks!')
if ret["returnCode"] == adaptor.RES_NEW:
self.inst_resource['network'].append({"vim_id": ignore_case_get(ret, "vim_id"),
"res_id": ignore_case_get(ret, "res_id")})
# self.inst_resource['network'].append({"vim_id": "1"}, {"res_id": "2"})
logger.info('Create networks!')
if ret["returnCode"] == adaptor.RES_NEW:
self.inst_resource['network'].append({"vim_id": ignore_case_get(ret, "vim_id"),
"res_id": ignore_case_get(ret, "res_id")})
# self.inst_resource['network'].append({"vim_id": "1"}, {"res_id": "2"})
- JobUtil.add_job_status(self.job_id, progress, 'Create networks!')
+ JobUtil.add_job_status(self.job_id, 35, 'Create networks!')
NetworkInstModel.objects.create(
networkid='1',
vimid='1',
NetworkInstModel.objects.create(
networkid='1',
vimid='1',
insttype=0,
is_predefined=ret["returnCode"],
instid=self.nf_inst_id)
insttype=0,
is_predefined=ret["returnCode"],
instid=self.nf_inst_id)
- elif res_type == adaptor.OPT_CREATE_SUBNET:
+ elif res_type == adaptor.RES_SUBNET:
logger.info('Create subnets!')
if ret["returnCode"] == adaptor.RES_NEW:
self.inst_resource['subnet'].append({"vim_id": ignore_case_get(ret, "vim_id"),
"res_id": ignore_case_get(ret, "res_id")})
# self.inst_resource['subnet'].append({"vim_id": "1"}, {"res_id": "2"})
logger.info('Create subnets!')
if ret["returnCode"] == adaptor.RES_NEW:
self.inst_resource['subnet'].append({"vim_id": ignore_case_get(ret, "vim_id"),
"res_id": ignore_case_get(ret, "res_id")})
# self.inst_resource['subnet'].append({"vim_id": "1"}, {"res_id": "2"})
- JobUtil.add_job_status(self.job_id, progress, 'Create subnets!')
+ JobUtil.add_job_status(self.job_id, 40, 'Create subnets!')
SubNetworkInstModel.objects.create(
subnetworkid='1',
vimid='1',
SubNetworkInstModel.objects.create(
subnetworkid='1',
vimid='1',
insttype=0,
is_predefined=ret["returnCode"],
instid=self.nf_inst_id)
insttype=0,
is_predefined=ret["returnCode"],
instid=self.nf_inst_id)
- elif res_type == adaptor.OPT_CREATE_PORT:
+ elif res_type == adaptor.RES_PORT:
logger.info('Create ports!')
if ret["returnCode"] == adaptor.RES_NEW:
self.inst_resource['port'].append({"vim_id": ignore_case_get(ret, "vim_id"),
"res_id": ignore_case_get(ret, "res_id")})
# self.inst_resource['port'].append({"vim_id": "1"}, {"res_id": "2"})
logger.info('Create ports!')
if ret["returnCode"] == adaptor.RES_NEW:
self.inst_resource['port'].append({"vim_id": ignore_case_get(ret, "vim_id"),
"res_id": ignore_case_get(ret, "res_id")})
# self.inst_resource['port'].append({"vim_id": "1"}, {"res_id": "2"})
- JobUtil.add_job_status(self.job_id, progress, 'Create ports!')
+ JobUtil.add_job_status(self.job_id, 50, 'Create ports!')
PortInstModel.objects.create(
portid='1',
networkid='1',
PortInstModel.objects.create(
portid='1',
networkid='1',
name='aaa_pnet_cp',
tenant='admin',
insttype=0,
name='aaa_pnet_cp',
tenant='admin',
insttype=0,
- is_predefined=ret["returnCode"],
- elif res_type == adaptor.OPT_CREATE_FLAVOR:
+ elif res_type == adaptor.RES_FLAVOR:
logger.info('Create flavors!')
if ret["returnCode"] == adaptor.RES_NEW:
self.inst_resource['flavor'].append({"vim_id": ignore_case_get(ret, "vim_id"),
"res_id": ignore_case_get(ret, "res_id")})
# self.inst_resource['flavor'].append({"vim_id": "1"}, {"res_id": "2"})
logger.info('Create flavors!')
if ret["returnCode"] == adaptor.RES_NEW:
self.inst_resource['flavor'].append({"vim_id": ignore_case_get(ret, "vim_id"),
"res_id": ignore_case_get(ret, "res_id")})
# self.inst_resource['flavor'].append({"vim_id": "1"}, {"res_id": "2"})
- JobUtil.add_job_status(self.job_id, progress, 'Create flavors!')
+ JobUtil.add_job_status(self.job_id, 60, 'Create flavors!')
FlavourInstModel.objects.create(
falavourid='1',
name='1',
vcpu='1',
extraspecs='1',
FlavourInstModel.objects.create(
falavourid='1',
name='1',
vcpu='1',
extraspecs='1',
- is_predefined=ret["returnCode"],
- elif res_type == adaptor.OPT_CREATE_VM:
+ elif res_type == adaptor.RES_VM:
logger.info('Create vms!')
if ret["returnCode"] == adaptor.RES_NEW:
self.inst_resource['vm'].append({"vim_id": ignore_case_get(ret, "vim_id"),
"res_id": ignore_case_get(ret, "res_id")})
# self.inst_resource['vm'].append({"vim_id": "1"}, {"res_id": "2"})
logger.info('Create vms!')
if ret["returnCode"] == adaptor.RES_NEW:
self.inst_resource['vm'].append({"vim_id": ignore_case_get(ret, "vim_id"),
"res_id": ignore_case_get(ret, "res_id")})
# self.inst_resource['vm'].append({"vim_id": "1"}, {"res_id": "2"})
- JobUtil.add_job_status(self.job_id, progress, 'Create vms!')
+ JobUtil.add_job_status(self.job_id, 70, 'Create vms!')
VmInstModel.objects.create(
vmid="1",
vimid="1",
VmInstModel.objects.create(
vmid="1",
vimid="1",
memory = models.CharField(db_column='MEMORY', max_length=255)
extraspecs = models.CharField(db_column='EXTRASPECS', max_length=255)
instid = models.CharField(db_column='INSTID', max_length=255)
memory = models.CharField(db_column='MEMORY', max_length=255)
extraspecs = models.CharField(db_column='EXTRASPECS', max_length=255)
instid = models.CharField(db_column='INSTID', max_length=255)
- is_predefined = models.IntegerField(db_column='ISPREDEFINED', default=0, null=True)
+ tenant = models.CharField(db_column='TENANT', max_length=255, null=True)
class NetworkInstModel(models.Model):
class Meta:
class NetworkInstModel(models.Model):
class Meta:
tenant = models.CharField(db_column='TENANT', max_length=255, null=True)
interfacename = models.CharField(db_column='INTERFACENAME', max_length=255, blank=True, null=True)
vmid = models.CharField(db_column='VMID', max_length=255, blank=True, null=True)
tenant = models.CharField(db_column='TENANT', max_length=255, null=True)
interfacename = models.CharField(db_column='INTERFACENAME', max_length=255, blank=True, null=True)
vmid = models.CharField(db_column='VMID', max_length=255, blank=True, null=True)
- is_predefined = models.IntegerField(db_column='ISPREDEFINED', default=0, null=True)
class CPInstModel(models.Model):
class Meta:
class CPInstModel(models.Model):
class Meta: