Changeset 8258
- Timestamp:
- 19/04/12 11:56:51 (9 years ago)
- Location:
- mauRepo/MolesManager/trunk/src/libs/migration
- Files:
-
- 5 edited
Legend:
- Unmodified
- Added
- Removed
-
mauRepo/MolesManager/trunk/src/libs/migration/exception/exceptions.py
r8254 r8258 5 5 ''' 6 6 7 def _migrationObjectDescription(migrationObject):7 def migrationObjectDescription(migrationObject): 8 8 try: 9 9 return "%s %s %s" % (migrationObject.doc_status, migrationObject.doc_owner, migrationObject.doc_name) … … 48 48 self.comment = comment 49 49 def __str__(self): 50 return "Error on migration object %s " % ( _migrationObjectDescription(self.migrationObject))50 return "Error on migration object %s " % (migrationObjectDescription(self.migrationObject)) 51 51 52 52 class NoAssociatedAuthor(MigrationObjectException): … … 58 58 super(NoAssociatedAuthor, self).__init__(migrationObject, comment = '') 59 59 def __str__(self): 60 return "The MigrationObject %s has no author mapping for %s" % ( _migrationObjectDescription(self.migrationObject), self.author)60 return "The MigrationObject %s has no author mapping for %s" % (migrationObjectDescription(self.migrationObject), self.author) 61 61 62 62 class NoAssociatedDeployments(Exception): … … 71 71 def __str__(self): 72 72 if self._deploymentName: 73 return "The DataEntity %s has no associated deployment named %s" % ( _migrationObjectDescription(self.migrationObject), self._deploymentName)73 return "The DataEntity %s has no associated deployment named %s" % (migrationObjectDescription(self.migrationObject), self._deploymentName) 74 74 else: 75 return "The DataEntity %s has no associated deployment" % ( _migrationObjectDescription(self.migrationObject))75 return "The DataEntity %s has no associated deployment" % (migrationObjectDescription(self.migrationObject)) 76 76 77 77 class NoDataLineage(MigrationObjectException): -
mauRepo/MolesManager/trunk/src/libs/migration/processor/commons.py
r8254 r8258 446 446 dpt.append(linkName) 447 447 except Exception as ex: 448 print ex448 print "WARN - Cannot extractLinksByMarker %s" % (link) 449 449 return dpt 450 450 -
mauRepo/MolesManager/trunk/src/libs/migration/processor/dataEntity.py
r8254 r8258 10 10 from libs.migration.MigrationEPB import MigrationEPB 11 11 from libs.migration.exception.exceptions import MigrationObjectException, NoAssociatedAuthor,\ 12 _migrationObjectDescription, NoAssociatedDeployments12 migrationObjectDescription, NoAssociatedDeployments 13 13 from libs.migration.processor.commons import findDeploymentsInDE,\ 14 14 createMD_Identifier, extractContent, MD_CODE_MOLES2_CITATION,\ … … 46 46 contentDict = extractContent(self._dataEntityMigration) 47 47 if not contentDict.has_key('citation'): 48 DataEntityProcessor.log.info("The migration object "+ _migrationObjectDescription(self._dataEntityMigration) \48 DataEntityProcessor.log.info("The migration object "+ migrationObjectDescription(self._dataEntityMigration) \ 49 49 + " has not associated cedacat:citation") 50 50 else: -
mauRepo/MolesManager/trunk/src/libs/migration/processor/deployment.py
r8256 r8258 48 48 from ea_model.iso_19115_2006_metadata_corrigendum.citation_and_responsible_party_information.ci_rolecode import CI_RoleCode 49 49 from ea_model.iso_19115_2006_metadata_corrigendum.maintenance_information.md_maintenancefrequencycode import MD_MaintenanceFrequencyCode 50 from ea_model.ceda_metadatamodel.ceda_result.ceda_curationvalue import CEDA_CurationValue 50 51 51 52 class DeploymentProcessor(object): … … 274 275 self._deploymentMigration.ceda_observation_id) 275 276 return ceda_observation 276 277 def _getcurationcategory(self, curationcategory):278 """279 Returns a CEDA_CurationValue code if the parameter match any CEDA_CurationValue code280 @param curationcategory: a String281 """282 if curationcategory is None:283 return None284 285 for code in ceda_curationvalue.CEDA_CurationValue.__dict__:286 if code.startswith('cl_'):287 if code.lower() == curationcategory.lower():288 return code289 return None290 277 291 278 … … 310 297 function = CI_OnLineFunctionCode.cl_download, \ 311 298 description = int_description, applicationProfile = int_applicationProfile) 312 dataentity_id = '%s__ATOM__%s' % (self._dataEntityMigration.doc_owner, self._dataEntityMigration.doc_name)313 dataentity_id = dataentity_id.replace('.atom', '')314 infodb_de = InfodbEPB.getCedaInfoApp_dataentityByDE_ID(dataentity_id)315 i_logical_path = '/dummy'316 if infodb_de['logical_path']:317 i_logical_path = infodb_de['logical_path']318 319 i_category = ceda_curationvalue.CEDA_CurationValue.cl_a320 if infodb_de['category']:321 i_category = self._getcurationcategory(infodb_de['category'])322 323 299 300 dataentity_id = '%s__ATOM__%s' % (self._dataEntityMigration.doc_owner, self._dataEntityMigration.doc_name) 301 dataentity_id = dataentity_id.replace('.atom', '') 302 infodb_de = InfodbEPB.getCedaInfoApp_dataentityByDE_ID(dataentity_id) 303 i_logical_path = '/dummy' 304 if infodb_de['logical_path']: 305 i_logical_path = infodb_de['logical_path'] 306 307 i_category = ceda_curationvalue.CEDA_CurationValue.cl_a 308 if infodb_de['category']: 309 i_category = CEDA_CurationValue.from_string(infodb_de['category'].lower()) #self._getcurationcategory(infodb_de['category']) 310 observation.result = createCEDA_Result(i_category, i_logical_path, source = [i_source]) 324 311 325 312 -
mauRepo/MolesManager/trunk/src/libs/migration/processor/migrationProcess.py
r8147 r8258 10 10 import logging 11 11 from logging import StreamHandler 12 from libs.migration.exception.exceptions import migrationObjectDescription 12 13 13 14 class MigrationProcess(): … … 45 46 46 47 #loops over the data entities 47 for dataEntityMigration in [f for f in data_ents if f != None]: 48 dep = DataEntityProcessor(dataEntityMigration, self.migrationSessions) 48 for dataEntityMigration in [f for f in data_ents if f != None]: 49 MigrationProcess.log.info("Start processing dataEntity %s" % (migrationObjectDescription(dataEntityMigration))) 50 dep = DataEntityProcessor(dataEntityMigration, self.migrationSessions) 49 51 exs.extend(dep.process()) 52 MigrationProcess.log.info("Done") 50 53 return exs 51 54
Note: See TracChangeset
for help on using the changeset viewer.