popcon2dropbox Namespace Reference

Functions
def	checkFile (dbName)
def	copy (args, dbName)
def	run (args)
def	saveFileForImportErrors (datef, dbName, withMetadata=False)
def	upload (args, dbName)

Function Documentation

checkFile()

def popcon2dropbox.checkFile

(

dbName

)

Definition at line 32 of file popcon2dropbox.py.

def checkFile( dbName ):
    dbFileName = '%s.db' %dbName
    # check if the expected input file is there... 
    # exit code < 0 => error
    # exit code = 0 => skip
    # exit code = 1 => import                                                                                                                             
    if not os.path.exists( dbFileName ):
       logger.error('The file generated by PopCon with the data to be imported %s has not been found.'%dbFileName )
       return -1
 
    empty = True
    try:
       dbcon = sqlite3.connect( dbFileName )
       dbcur = dbcon.cursor()
       dbcur.execute("SELECT name FROM sqlite_master WHERE type='table' AND name='IOV'");
       if dbcur.fetchone() is None:
           logger.error('The condition database with the data to be imported has not been found in the file generated by PopCon: %s'%dbFileName )
           return -1
       dbcur.execute('SELECT * FROM IOV')
       rows = dbcur.fetchall()
       for r in rows:
          empty = False
       dbcon.close()
       if empty:
           logger.warning('The data set generated by PopCon contains no data to be imported. The import will be skipped.')
           return 0
       return 1
    except Exception as e:
       logger.error('Check on input data failed: %s' %str(e))
       return -2
 

References str.

Referenced by run().

copy()

def popcon2dropbox.copy	(		args,
			dbName
	)

Definition at line 126 of file popcon2dropbox.py.

def copy( args, dbName ):
    dbFileName = '%s.db' %dbName
    destDb = args.destDb
    destTag = args.destTag
    comment = args.comment
 
    datef = datetime.now()
    destMap = { "oracle://cms_orcoff_prep/cms_conditions": "oradev", "oracle://cms_orcon_prod/cms_conditions": "onlineorapro"  }
    if destDb.lower() in destMap.keys():
        destDb = destMap[destDb.lower()]
    else:
        if destDb.startswith('sqlite'):
            destDb = destDb.split(':')[1]
        else:
            logger.error( 'Destination connection %s is not supported.' %destDb )
            return 
    # run the copy
    note = '"Importing data with O2O execution"'
    commandOptions = '--force --yes --db %s copy %s %s --destdb %s --synchronize --note %s' %(dbFileName,destTag,destTag,destDb,note)
    copyCommand = 'conddb %s' %commandOptions
    logger.info( 'Executing command: %s' %copyCommand )
    try:
        pipe = subprocess.Popen( copyCommand, shell=True, stdout=subprocess.PIPE, stderr=subprocess.STDOUT )
        stdout = pipe.communicate()[0]
        print(stdout)
        retCode = pipe.returncode
        if retCode != 0:
            saveFileForImportErrors( datef, dbName )
        ret = retCode
    except Exception as e:
        ret = 1
        logger.error( str(e) )
    return ret
 

References print(), saveFileForImportErrors(), and str.

Referenced by run().

run()

def popcon2dropbox.run

(

args

)

Definition at line 160 of file popcon2dropbox.py.

def run( args ):
    
    dbName = datetime.utcnow().strftime('%Y-%m-%d_%H-%M-%S-%f')
    dbFileName = '%s.db' %dbName
 
    if args.auth is not None and not args.auth=='':
        if auth_path_key in os.environ:
            logger.warning("Cannot set authentication path to %s in the environment, since it is already set." %args.auth)
        else:
            logger.info("Setting the authentication path to %s in the environment." %args.auth)
            os.environ[auth_path_key]=args.auth
    if os.path.exists( '%s.db' %dbName ):
       logger.info("Removing files with name %s" %dbName )
       os.remove( '%s.db' %dbName )
    if os.path.exists( '%s.txt' %dbName ):
       os.remove( '%s.txt' %dbName )
    command = 'cmsRun %s ' %args.job_file
    command += ' targetFile=%s' %dbFileName
    command += ' destinationDatabase=%s' %args.destDb
    command += ' destinationTag=%s' %args.destTag
    command += ' 2>&1'
    logger.info( 'Executing command: %s' %command )
    pipe = subprocess.Popen( command, shell=True, stdout=subprocess.PIPE, stderr=subprocess.STDOUT )
    stdout = pipe.communicate()[0]
    retCode = pipe.returncode
    print(stdout)
    logger.info('PopCon Analyzer return code is: %s' %retCode )
    if retCode!=0:
       logger.error( 'O2O job failed. Skipping upload.' )
       return retCode
 
    ret = checkFile( dbName )
    if ret > 0:
        if args.copy:
            ret = copy( args, dbName )
        else:
            ret = upload( args, dbName )
    if ret >=0:
        logger.info('Deleting local file %s.db' %dbName ) 
        os.remove( '%s.db' %dbName )
    return ret

References checkFile(), copy(), print(), and upload().

saveFileForImportErrors()

def popcon2dropbox.saveFileForImportErrors	(		datef,
			dbName,
			withMetadata = False
	)

Definition at line 63 of file popcon2dropbox.py.

def saveFileForImportErrors( datef, dbName, withMetadata=False ):
    # save a copy of the files in case of upload failure...
    leafFolderName = datef.strftime(dateformatForFolder)
    fileFolder = os.path.join( errorInImportFileFolder, leafFolderName)
    if not os.path.exists(fileFolder):
        os.makedirs(fileFolder)
    df= '%s.db' %dbName
    dataDestFile = os.path.join( fileFolder, df)
    if not os.path.exists(dataDestFile):
        shutil.copy2(df, dataDestFile)
    if withMetadata:
        mf= '%s.txt' %dbName
        metadataDestFile = os.path.join( fileFolder, mf )
        if not os.path.exists(metadataDestFile):
            shutil.copy2(df, metadataDestFile)
    logger.error("Upload failed. Data file and metadata saved in folder '%s'" %os.path.abspath(fileFolder))
    

Referenced by copy(), and upload().

upload()

def popcon2dropbox.upload	(		args,
			dbName
	)

Definition at line 80 of file popcon2dropbox.py.

def upload( args, dbName ):
    destDb = args.destDb
    destTag = args.destTag
    comment = args.comment
 
    datef = datetime.now()
 
    # first remove any existing metadata file...                                                                                                                                
    if os.path.exists( '%s.txt' %dbName ):
       logger.debug('Removing already existing file %s' %dbName)
       os.remove( '%s.txt' %dbName )
    
    # dump Metadata for the Upload
    uploadMd = {}
    uploadMd['destinationDatabase'] = destDb
    tags = {}
    tagInfo = {}
    tags[ destTag ] = tagInfo
    uploadMd['destinationTags'] = tags
    uploadMd['inputTag'] = destTag
    uploadMd['since'] = None
    datelabel = datef.strftime(dateformatForLabel)
    commentStr = ''
    if not comment is None:
       commentStr = comment
    uploadMd['userText'] = '%s : %s' %(datelabel,commentStr)
    with open( '%s.txt' %dbName, 'wb') as jf:
       jf.write( json.dumps( uploadMd, sort_keys=True, indent = 2 ) )
       jf.write('\n')
 
    # run the upload
    uploadCommand = 'uploadConditions.py %s' %dbName
    ret = 0
    try:
       pipe = subprocess.Popen( uploadCommand, shell=True, stdout=subprocess.PIPE, stderr=subprocess.STDOUT )
       stdout = pipe.communicate()[0]
       print(stdout)
       retCode = pipe.returncode
       if retCode != 0:
           saveFileForImportErrors( datef, dbName, True )
       ret |= retCode
    except Exception as e:
       ret |= 1
       logger.error(str(e))
    return ret
 

References print(), saveFileForImportErrors(), and str.

Referenced by run().