python.utils.AtlRunQueryTriggerUtils Namespace Reference

Classes
class	TriggerChain

Functions
def	isTriggerRun2 (run_number=None, smk=None, isRun2=None)
def	triggerDBAlias (run_number=None, smk=None, lhcRun=None)
def	FindFile (filename, pathlist, access)
def	_getFileLocalOrPath (filename, pathenv)
def	_getConnectionServicesForAlias (alias)
def	_readAuthentication ()
def	_getConnectionParameters (connection)
def	interpretConnection (connection, debug=False, resolveAlias=True)
def	_get_sqlite_cursor (filename)
def	_get_oracle_cursor (tns, user, passwd="")
def	_get_mysql_cursor (host, db, user, passwd="")
def	getTriggerDBCursorForAlias (dbAlias)
def	getTriggerDBCursor (run_number=None, smk=None, lhcRun=None)
def	getUsedTables (output, condition, schemaname, tables)
def	executeQuery (cursor, output, condition, schemaname, tables, bindvars=())
def	getL1PskNames (psk, dbAlias=None, run_number=None, smk=None, lhcRun=None)
def	getHLTPskNames (psk, dbAlias=None, run_number=None, smk=None, lhcRun=None)
def	getSmkNames (smks, dbAlias)
def	getHLTMenu (smk)
def	getL1Menu (smk)
def	getL1Prescales (l1prescalekey, run_number)
def	getHLTPrescales (hltprescalekey, run_number)
def	getRandom (smk, lhcRun)

Variables
dictionary	__cursor_schema = {}
	log = logging.getLogger( __name__ )
	authDict = None

Function Documentation

_get_mysql_cursor()

def python.utils.AtlRunQueryTriggerUtils._get_mysql_cursor (   host,   db,   user,   passwd = ""  )

private

Definition at line 343 of file AtlRunQueryTriggerUtils.py.

def _get_mysql_cursor (host, db, user, passwd=""):
    if passwd=="":
        from getpass import getpass
        passwd = getpass("[MySQL] `%s' database password for %s@%s: " % (db, user, host))
    try:
        from MySQLdb import connect
    except ImportError:
        raise RuntimeError ("ERROR: Can't import MySQLdb")
    connection = connect(host=host, user=user, passwd=passwd, db=db, connect_timeout=10)
    return connection.cursor()
 
 

_get_oracle_cursor()

def python.utils.AtlRunQueryTriggerUtils._get_oracle_cursor (   tns,   user,   passwd = ""  )

private

Definition at line 331 of file AtlRunQueryTriggerUtils.py.

def _get_oracle_cursor (tns, user, passwd=""):
    if passwd=="":
        from getpass import getpass
        passwd = getpass("[Oracle] database password for %s@%s: " % (user, tns))
    try:
        from cx_Oracle import connect
    except ImportError:
        raise RuntimeError ("ERROR: Can't import cx_Oracle?")
    connection = connect (user, passwd, tns, threaded=True)
    return connection.cursor()
 
 

_get_sqlite_cursor()

def python.utils.AtlRunQueryTriggerUtils._get_sqlite_cursor (   filename )

private

Definition at line 322 of file AtlRunQueryTriggerUtils.py.

def _get_sqlite_cursor (filename):
    try:
        import sqlite3
    except ImportError:
        raise RuntimeError ("ERROR: Can't import sqlite3?")
    os.lstat(filename)
    connection = sqlite3.connect(filename)
    return connection.cursor()
 

_getConnectionParameters()

def python.utils.AtlRunQueryTriggerUtils._getConnectionParameters (   connection )

private

Definition at line 170 of file AtlRunQueryTriggerUtils.py.

def _getConnectionParameters(connection):
    log = logging.getLogger( "TrigConfigSvcUtils.py" )
    connection = str(connection)
    connectionParameters = {}
 
    if connection.startswith("sqlite_file:"):
        filename = connection[connection.find(':')+1:]
        connectionParameters["techno"] = "sqlite"
        connectionParameters["filename"] = filename if os.path.exists(filename) else None
        
    elif connection.startswith("oracle://"):
        if connection.count(';') == 2:
            pattern = "(.*)://(.*)/(.*);username=(.*);password=(.*)"
            m = re.match(pattern,connection)
            #print ('Groups ', m)
            if not m:
                log.fatal("connection string '%s' doesn't match the pattern '%s'?" % (connection,pattern))
            (techno, server, schema, user, passwd) = m.groups()
            #print ((techno, server, schema, user, passwd))
        else:
            global authDict
            if not authDict:
                authDict = _readAuthentication()
            pattern = "oracle://(.*)/(.*)"
            m = re.match(pattern,connection)
            if not m:
                log.fatal("connection string '%s' doesn't match the pattern '%s'?" % (connection,pattern))
            (server, schema) = m.groups()
            (user,passwd) = authDict[connection]
        #info from auth file also unicode
        connectionParameters["techno"] = 'oracle'
        connectionParameters["server"] = str(server)
        connectionParameters["schema"] = str(schema)
        connectionParameters["user"  ] = str(user)
        connectionParameters["passwd"] = str(passwd)
 
    elif connection.startswith("mysql://"):
        pattern = "mysql://(.*);dbname=(.*);user=(.*);passwd=(.*);"
        m = re.match(pattern,connection)
        if not m:
            log.fatal("connection string '%s' doesn't match the pattern '%s'?" % (connection,pattern) )
        (server, dbname, user, passwd) = m.groups()
        connectionParameters["techno"] = 'mysql'
        connectionParameters["server"] = server
        connectionParameters["dbname"] = dbname
        connectionParameters["user"  ] = user
        connectionParameters["passwd"] = passwd
 
    elif connection.startswith("frontier://"):
        pattern = r"frontier://ATLF/\‍(\‍)/(.*)"
        m = re.match(pattern,connection)
        if not m:
            log.fatal("connection string '%s' doesn't match the pattern '%s'?" % (connection,pattern) )
        (schema, ) = m.groups()
        connectionParameters["techno"] = 'frontier'
        connectionParameters["schema"] = schema
 
    return connectionParameters
 

_getConnectionServicesForAlias()

def python.utils.AtlRunQueryTriggerUtils._getConnectionServicesForAlias (   alias )

private

Definition at line 122 of file AtlRunQueryTriggerUtils.py.

def _getConnectionServicesForAlias(alias):
    log = logging.getLogger( "TrigConfigSvcUtils.py" )
 
    connectionServices = None # list of services
 
    dblookupfilename = _getFileLocalOrPath('dblookup.xml','CORAL_DBLOOKUP_PATH')
    if dblookupfilename is None:
        return None
 
    doc = minidom.parse(dblookupfilename)
    for ls in doc.getElementsByTagName('logicalservice'):
        if ls.attributes['name'].value != alias:
            continue
        connectionServices = [str(s.attributes['name'].value) for s in ls.getElementsByTagName('service')]
    doc.unlink()
 
    log.info( "For alias '%s' found list of connections %r", alias, connectionServices )
    if connectionServices is None:
        print("ERROR: Trigger connection alias '%s' is not defined in %s" % (alias,dblookupfilename))
    return connectionServices
 
 

_getFileLocalOrPath()

def python.utils.AtlRunQueryTriggerUtils._getFileLocalOrPath (   filename,   pathenv  )

private

looks for filename in local directory and then in all paths specified in environment variable 'pathenv'
returns path/filename if existing, otherwise None

Definition at line 104 of file AtlRunQueryTriggerUtils.py.

def _getFileLocalOrPath(filename, pathenv):
    """looks for filename in local directory and then in all paths specified in environment variable 'pathenv'
    returns path/filename if existing, otherwise None
    """
    log = logging.getLogger( "TrigConfigSvcUtils.py" )
    if os.path.exists(filename):
        log.info( "Using local file %s", filename)
        return filename
 
    pathlist = os.getenv(pathenv,'').split(os.pathsep)
    resolvedfilename = FindFile(filename, pathlist, os.R_OK)
    if resolvedfilename:
        return resolvedfilename
 
    log.fatal("No file %s found locally nor in %s" % (filename, os.getenv('CORAL_DBLOOKUP_PATH')) )
    return None
 
 

_readAuthentication()

def python.utils.AtlRunQueryTriggerUtils._readAuthentication ( )

private

read authentication.xml, first from local directory, then from all paths specified in CORAL_AUTH_PATH
returns dictionary d with d[connection] -> (user,pw)

Definition at line 144 of file AtlRunQueryTriggerUtils.py.

def _readAuthentication():
    """ read authentication.xml, first from local directory, then from all paths specified in CORAL_AUTH_PATH
    returns dictionary d with d[connection] -> (user,pw)
    """
 
    authDict = {}
    dbauthfilename = _getFileLocalOrPath('authentication.xml','CORAL_AUTH_PATH')
    if dbauthfilename is None:
        return authDict
 
    doc = minidom.parse(dbauthfilename)        
    for cn in doc.getElementsByTagName('connection'):
        user = ""
        pw = ""
        svc = cn.attributes['name'].value
        for p in cn.getElementsByTagName('parameter'):
            if p.attributes['name'].value == 'user':
                user = p.attributes['value'].value
            elif p.attributes['name'].value == 'password':
                pw = p.attributes['value'].value
        authDict[svc] = (user,pw)
    doc.unlink()
    return authDict
 

executeQuery()

def python.utils.AtlRunQueryTriggerUtils.executeQuery	(		cursor,
			output,
			condition,
			schemaname,
			tables,
			bindvars = ()
	)

Definition at line 403 of file AtlRunQueryTriggerUtils.py.

def executeQuery(cursor, output, condition, schemaname, tables, bindvars=()):
    query = 'select distinct %s from %s where %s' % (
        ', '.join(output),
        ', '.join(getUsedTables(output, condition, schemaname, tables)),
        ' and '.join(condition)
        )
    if len(bindvars)==0:
        cursor.execute(str(query))
    else:
        cursor.execute(str(query),bindvars)
 
    return cursor.fetchall()
 
 

FindFile()

def python.utils.AtlRunQueryTriggerUtils.FindFile	(		filename,
			pathlist,
			access
	)

Find <filename> with rights <access> through <pathlist>.

Definition at line 85 of file AtlRunQueryTriggerUtils.py.

def FindFile( filename, pathlist, access ):
    """Find <filename> with rights <access> through <pathlist>."""
 
    # special case for those filenames that already contain a path
    if os.path.dirname( filename ):
        if os.access( filename, access ):
            return filename
 
    # test the file name in all possible paths until first found
    for path in pathlist:
        f = os.path.join( path, filename )
        if os.access( f, access ):
            return f
 
    # no such accessible file avalailable
    return None
 
 
 

getHLTMenu()

def python.utils.AtlRunQueryTriggerUtils.getHLTMenu

(

smk

)

Definition at line 487 of file AtlRunQueryTriggerUtils.py.

def getHLTMenu(smk):
    if smk is None or smk==0:
        return [],[]
 
    if isTriggerRun2(smk):
        output = ['TC.HTC_NAME', 'TC.HTC_CHAIN_COUNTER', 'TC.HTC_LOWER_CHAIN_NAME' ]
    else:
        output = ['TC.HTC_NAME', 'TC.HTC_CHAIN_COUNTER', 'TC.HTC_LOWER_CHAIN_NAME', 'TC.HTC_L2_OR_EF' ]
    
    tables = {
        'SM'  : 'SUPER_MASTER_TABLE',
        'HM'  : 'HLT_MASTER_TABLE',
        'M2C' : 'HLT_TM_TO_TC',
        'TC'  : 'HLT_TRIGGER_CHAIN'
        }
    condition = [
        'SM.SMT_ID = :smk',
        'SM.SMT_HLT_MASTER_TABLE_ID = HM.HMT_ID',
        'HM.HMT_TRIGGER_MENU_ID = M2C.HTM2TC_TRIGGER_MENU_ID',
        'M2C.HTM2TC_TRIGGER_CHAIN_ID = TC.HTC_ID'
        ]
    bindvars = { "smk": smk }
    
    cursor,schema = getTriggerDBCursor(smk)
    res = executeQuery( cursor, output, condition, schema, tables, bindvars)
 
    l2chains = []
    efchains = []
 
    for r in res:
        if len(r)==4 and r[3]=='L2':
            l2chains += [TriggerChain(r[0],r[1],r[2], level=2)]
        else:
            efchains += [TriggerChain(r[0],r[1],r[2], level=3)]
 
    return l2chains, efchains
 
 
 
 

getHLTPrescales()

def python.utils.AtlRunQueryTriggerUtils.getHLTPrescales	(		hltprescalekey,
			run_number
	)

Definition at line 575 of file AtlRunQueryTriggerUtils.py.

def getHLTPrescales(hltprescalekey, run_number):
 
    l2ps = {}
    efps = {}
 
    if isTriggerRun2( run_number = run_number ):
        return l2ps,efps
    
    tables = {
        'H' : 'HLT_PRESCALE_SET',
        'P' : 'HLT_PRESCALE'
        }
    output = [
        'P.HPR_L2_OR_EF',
        'P.HPR_CHAIN_COUNTER',
        'P.HPR_PRESCALE',
        'P.HPR_PASS_THROUGH_RATE'
        ]
    condition = [
        "P.HPR_PRESCALE_SET_ID = :psk",
        "P.HPR_L2_OR_EF not like 'express'"
        ]
    bindvars = { "psk": hltprescalekey }
 
    cursor,schema = getTriggerDBCursor(isRun2 = True)
    res = executeQuery(cursor, output, condition, schema, tables, bindvars)
 
    for r in res:
        if r[0]=='L2':
            l2ps[r[1]] = ( float(r[2]), float(r[3]) )
        elif (r[0]=='EF' or r[0]=='HLT' or r[0]=='HL'):
            efps[r[1]] = ( float(r[2]), float(r[3]) )
 
    return l2ps, efps
 
 

getHLTPskNames()

def python.utils.AtlRunQueryTriggerUtils.getHLTPskNames	(		psk,
			dbAlias = None,
			run_number = None,
			smk = None,
			lhcRun = None
	)

Definition at line 441 of file AtlRunQueryTriggerUtils.py.

def getHLTPskNames(psk, dbAlias = None, run_number = None , smk = None , lhcRun = None ):
    if not isinstance(psk, Iterable):
        psk = [psk]
 
    keyslist = ','.join([str(k) for k in psk if k])
    if keyslist=="":
        return {}
 
    tables = { 'L' : 'HLT_PRESCALE_SET' }
    output = ['L.HPS_ID', 'L.HPS_NAME']
    condition = [ "L.HPS_ID in (%s)" % keyslist ]
 
    if dbAlias is not None:
        cursor, schema = getTriggerDBCursorForAlias(dbAlias)
    else:
        cursor,schema = getTriggerDBCursor(run_number = run_number, smk = smk, lhcRun = lhcRun )
 
    res = executeQuery( cursor, output, condition, schema, tables)
 
    return dict(res)
 
 

getL1Menu()

def python.utils.AtlRunQueryTriggerUtils.getL1Menu

(

smk

)

Definition at line 527 of file AtlRunQueryTriggerUtils.py.

def getL1Menu(smk):
    if smk is None or smk==0:
        return []
    output = [
        'TI.L1TI_NAME',
        'TI.L1TI_CTP_ID'
        ]
    tables = {
        'SM'  : 'SUPER_MASTER_TABLE',
        'M'   : 'L1_MASTER_TABLE',
        'M2I' : 'L1_TM_TO_TI',
        'TI'  : 'L1_TRIGGER_ITEM'
        }
    condition = [
        "SM.SMT_ID = :smk",
        'SM.SMT_L1_MASTER_TABLE_ID = M.L1MT_ID',
        'M.L1MT_TRIGGER_MENU_ID = M2I.L1TM2TI_TRIGGER_MENU_ID',
        'M2I.L1TM2TI_TRIGGER_ITEM_ID = TI.L1TI_ID'
        ]
    bindvars = { "smk": smk }
 
    cursor,schema = getTriggerDBCursor(smk = smk)
    res = executeQuery( cursor, output, condition, schema, tables, bindvars)
 
    maxNumberItems = 512 if isTriggerRun2(smk=smk) else 256
    items = maxNumberItems*[None]
 
    for r in res:
        items[r[1]] = TriggerChain(r[0],r[1])
    return items
 
 
 

getL1Prescales()

def python.utils.AtlRunQueryTriggerUtils.getL1Prescales	(		l1prescalekey,
			run_number
	)

Definition at line 560 of file AtlRunQueryTriggerUtils.py.

def getL1Prescales(l1prescalekey, run_number):
 
    maxNumberItems = 512 if isTriggerRun2( run_number = run_number ) else 256
 
    tables = { 'L' : 'L1_PRESCALE_SET' }
    output = ['L.L1PS_VAL%i' % i for i in range( 1, maxNumberItems + 1)]
    condition = [ "L.L1PS_ID = :psk" ]
    bindvars = { "psk": l1prescalekey }
 
    cursor,schema = getTriggerDBCursor( run_number = run_number )
    res = executeQuery(cursor, output, condition, schema, tables, bindvars)
    
    return res[0][0:maxNumberItems]
 
 

getL1PskNames()

def python.utils.AtlRunQueryTriggerUtils.getL1PskNames	(		psk,
			dbAlias = None,
			run_number = None,
			smk = None,
			lhcRun = None
	)

Definition at line 417 of file AtlRunQueryTriggerUtils.py.

def getL1PskNames(psk, dbAlias = None, run_number = None , smk = None , lhcRun = None ):
    if not isinstance(psk, Iterable):
        psk = [psk]
 
    keyslist = ','.join([str(k) for k in psk if k])
 
    if keyslist=="":
        return {}
 
    tables = { 'L' : 'L1_PRESCALE_SET' }
    output = [ 'L.L1PS_ID', 'L.L1PS_NAME' ]
    condition = [ "L.L1PS_ID in (%s)" % keyslist ]
 
    if dbAlias is not None:
        cursor, schema = getTriggerDBCursorForAlias(dbAlias)
    else:
        cursor, schema = getTriggerDBCursor(run_number = run_number, smk = smk, lhcRun = lhcRun )
 
    res = executeQuery(cursor, output, condition, schema, tables)
 
    return dict(res)
 
 
 

getRandom()

def python.utils.AtlRunQueryTriggerUtils.getRandom	(		smk,
			lhcRun
	)

Definition at line 611 of file AtlRunQueryTriggerUtils.py.

def getRandom(smk, lhcRun):
    # does not work for Run 3
    if lhcRun >= 3:
        return (1,1,1,1)
 
    if smk=='n.a.':
        return ('n.a.','n.a.')
 
    tables = {
        'S' : 'SUPER_MASTER_TABLE',
        'M' : 'L1_MASTER_TABLE',
        'R' : 'L1_RANDOM'
        }
    if lhcRun == 2:
        output = [ 'R.L1R_CUT0', 'R.L1R_CUT1', 'R.L1R_CUT2', 'R.L1R_CUT3' ]
    else:
        output = [ 'R.L1R_RATE1', 'R.L1R_RATE2' ]
    
    condition = [ "S.SMT_ID=:smk", "S.SMT_L1_MASTER_TABLE_ID=M.L1MT_ID", "M.L1MT_RANDOM_ID=R.L1R_ID" ]
    
    bindvars = { "smk": smk }
 
    cursor,schema = getTriggerDBCursorForAlias(dbAlias = triggerDBAlias(lhcRun=lhcRun))
    res = executeQuery(cursor, output, condition, schema, tables, bindvars)
    if len(res) > 0:
        return res[0]
    else:
        return [0,0,0,0]
 
 

getSmkNames()

def python.utils.AtlRunQueryTriggerUtils.getSmkNames	(		smks,
			dbAlias
	)

takes a single SMK or a list of SMKs
returns a map from SMK to (name,version,comment)

Definition at line 463 of file AtlRunQueryTriggerUtils.py.

def getSmkNames( smks, dbAlias ):
    """
    takes a single SMK or a list of SMKs
    returns a map from SMK to (name,version,comment)
    """
    if not isinstance(smks, Iterable):
        smks = [smks]
 
    keyslist = ','.join([str(k) for k in smks if k])
    if keyslist=="":
        return {}
 
    tables = { 'S' : 'SUPER_MASTER_TABLE' }
    output = ['S.SMT_ID', 'S.SMT_NAME', 'S.SMT_VERSION', 'S.SMT_COMMENT']
    condition = [ "S.SMT_ID in (%s)" % keyslist ]
 
    cursor, schema = getTriggerDBCursorForAlias(dbAlias)
    res = executeQuery( cursor, output, condition, schema, tables)
 
    return dict([ (r[0],(r[1],r[2],r[3])) for r in res])
 
 
 
 

getTriggerDBCursor()

def python.utils.AtlRunQueryTriggerUtils.getTriggerDBCursor	(		run_number = None,
			smk = None,
			lhcRun = None
	)

Definition at line 385 of file AtlRunQueryTriggerUtils.py.

def getTriggerDBCursor(run_number = None, smk = None, lhcRun = None):
 
    dbAlias = triggerDBAlias(run_number = run_number, smk = smk, lhcRun = lhcRun)
    return getTriggerDBCursorForAlias(dbAlias)
 
 

getTriggerDBCursorForAlias()

def python.utils.AtlRunQueryTriggerUtils.getTriggerDBCursorForAlias

(

dbAlias

)

Definition at line 355 of file AtlRunQueryTriggerUtils.py.

def getTriggerDBCursorForAlias(dbAlias):
 
    if dbAlias in __cursor_schema:
        return __cursor_schema[dbAlias] # return the correct cursor and schema name
 
    connectionParameters = interpretConnection(dbAlias)
    technology = connectionParameters["techno"]
 
    if technology == 'sqlite':
        cursor = _get_sqlite_cursor(connectionParameters["filename"])
        schema = ''
 
    elif technology == 'oracle':
        cursor = _get_oracle_cursor(connectionParameters["server"], connectionParameters["user"], connectionParameters["passwd"])
        schema = connectionParameters["schema"].rstrip('.') + '.'
 
    elif technology == 'frontier':
        from TrigConfigSvc.TrigConfFrontier import getFrontierCursor 
        cursor = getFrontierCursor(connectionParameters["url"], connectionParameters["schema"], logging.getLogger("TrigConfigSvcUtils.py").level)
        schema = connectionParameters["schema"].rstrip('.') + '.'
 
    elif technology == 'mysql':
        cursor = _get_mysql_cursor(connectionParameters["server"], connectionParameters["dbname"], connectionParameters["user"], connectionParameters["passwd"]),''
        schema = ''
 
    __cursor_schema[dbAlias] = (cursor,schema)
 
    return __cursor_schema[dbAlias] # return the correct cursor and schema name
 
 

getUsedTables()

def python.utils.AtlRunQueryTriggerUtils.getUsedTables	(		output,
			condition,
			schemaname,
			tables
	)

Definition at line 391 of file AtlRunQueryTriggerUtils.py.

def getUsedTables(output, condition, schemaname, tables):
    schemaname = schemaname.rstrip('.')+'.'
    usedtables = set()
    for o in output:
        usedtables.add(o.split('.')[0])
    for c in condition:
        for p in c.split():
            if '.' in p and '\'' not in p:
                usedtables.add(p.split('.')[0])
    return ["%s%s %s" % (schemaname,tables[t],t) for t in usedtables]
 
 

interpretConnection()

def python.utils.AtlRunQueryTriggerUtils.interpretConnection	(		connection,
			debug = False,
			resolveAlias = True
	)

Definition at line 229 of file AtlRunQueryTriggerUtils.py.

def interpretConnection(connection, debug=False, resolveAlias=True):
    # connection needs to be of the following format (this is also the order of checking)
    # <ALIAS>                              -- any string without a colon ':' will be checked for in the dblookup.xml file
    # sqlite_file:filename.db              -- an sqlite file, no authentication needed, will be opened in read-only mode
    # oracle://ATLR/ATLAS_CONF_TRIGGER_V2  -- a service description without user and password, requires lookup in authentication.xml
    # oracle://ATLR/ATLAS_CONF_TRIGGER_V2;username=ATLAS_CONF_TRIGGER_V2_R;password=<...>  -- a service description with user and password
 
    log.info("Specified connection string '%s'", connection)
 
    # not needed any longer
    # connection = connection.lstrip("dblookup://")
    # connection = connection.lstrip("dblookup:")
    # connection = connection.rstrip(";")
    #print (connection)
 
    # what to return
    connectionParameters = {}
    connection = str(connection)
 
    # connection explicitly specified (no DB alias)
    if ':' in connection:
        connectionParameters = _getConnectionParameters( connection )
        return connectionParameters
 
    # connection is a DB alias
    connectionParameters["alias"] = connection
    if not resolveAlias:
        return connectionParameters
 
    connectionServices = _getConnectionServicesForAlias( connection ) # alias resolution via dblookup
    if connectionServices is None:
        return connectionParameters
 
    # If ${TRIGGER_USE_FRONTIER} is True then we remove sqlite files
    if os.getenv('TRIGGER_USE_FRONTIER',False):
        connectionServices = filter(lambda conn: not conn.startswith("sqlite_file"), connectionServices)
        if 'ATLAS_TRIGGERDB_FORCESQLITE' in os.environ:
            log.fatal("Inconsistent setup: environment variable ATLAS_TRIGGERDB_FORCESQLITE is defined and use of Frontier is requested" )
 
    # SQLite
    sqliteconnections = [conn for conn in connectionServices if conn.startswith("sqlite_file")]
    if len(sqliteconnections)>0:
        for conn in sqliteconnections:
            connectionParameters = _getConnectionParameters( conn )
            if connectionParameters["filename"] is not None:
                break # stop at the first sqlite file that exists
        if connectionParameters["filename"] is not None:
            log.info("Using sqlite connection %s", connectionParameters)
            return connectionParameters
        else:
            if 'ATLAS_TRIGGERDB_FORCESQLITE' in os.environ:
                log.fatal("environment ATLAS_TRIGGERDB_FORCESQLITE is defined but non of the sqlite files defined in dblookup.xml exists" )
    else:
        if 'ATLAS_TRIGGERDB_FORCESQLITE' in os.environ:
            log.fatal("environment ATLAS_TRIGGERDB_FORCESQLITE is defined but no sqlite connection defined in dblookup.xml" )
 
    from CoolConvUtilities.AtlCoolLib import replicaList
    serverlist=['ATLAS_CONFIG' if s=='ATLAS_COOLPROD' else s for s in replicaList()]  # replicaList is for COOL, I need ATLAS_CONFIG instead of ATLAS_COOLPROD
    log.info("Trying these servers in order %r", serverlist)
    for server in serverlist:
        log.info("Trying server %s", server)
 
        if server=='ATLF':
            if not os.getenv('TRIGGER_USE_FRONTIER',False):
                continue
            frontierconnections = [conn for conn in connectionServices if conn.startswith("frontier")]
            if len(frontierconnections) == 0:
                log.debug("FroNTier connection not defined for alias %s in dblookup", connection )
                continue
            log.info("Environment FRONTIER_SERVER: %s", os.getenv('FRONTIER_SERVER','not defined'))
            frontierServer = os.getenv('FRONTIER_SERVER',None)
            if not frontierServer:
                log.debug("No environment variable FRONTIER_SERVER" )
                continue
            connectionParameters = _getConnectionParameters( frontierconnections[0] )
            connectionParameters['url'] = frontierServer
            log.info("Using frontier connection %s", frontierconnections[0])
            #connstr='frontier://ATLF/%s;schema=%s;dbname=TRIGCONF' % (connectionParameters['url'],connectionParameters["schema"])
            break
        elif server=='atlas_dd':
            continue
        else:
            oracleconnections = [conn for conn in connectionServices if conn.startswith("oracle://%s/" % server)]
            if len(oracleconnections) == 0:
                log.debug("Oracle connection not defined for server %s in dblookup", server )
                continue
            connectionParameters = _getConnectionParameters( oracleconnections[0] )
            log.info("Using oracle connection %s", oracleconnections[0])
            break
 
    return connectionParameters
 
 

isTriggerRun2()

def python.utils.AtlRunQueryTriggerUtils.isTriggerRun2	(		run_number = None,
			smk = None,
			isRun2 = None
	)

Definition at line 20 of file AtlRunQueryTriggerUtils.py.

def isTriggerRun2(run_number = None , smk = None , isRun2 = None ):
    if run_number is None and smk is None and isRun2 is None:
        raise RuntimeError("Cannot determine if trigger db is run 1 or 2")
 
    if smk is not None :
        return smk >= 2000 and smk<3000
    elif run_number is not None :
        return run_number > 249000
    else:
        return isRun2
 
 

triggerDBAlias()

def python.utils.AtlRunQueryTriggerUtils.triggerDBAlias	(		run_number = None,
			smk = None,
			lhcRun = None
	)

Definition at line 32 of file AtlRunQueryTriggerUtils.py.

def triggerDBAlias(run_number = None , smk = None, lhcRun = None ):
    if run_number is None and smk is None and lhcRun is None:
        raise RuntimeError("Cannot determine the triggerDBAlias as no info is given")
 
    # lhcRun given
    if lhcRun==1 or lhcRun==2:
        return f"TRIGGERDB_RUN{lhcRun}"
    if lhcRun==3:
        return "TRIGGERDBDEV1_I8" if (smk is not None and smk<3000) else "TRIGGERDB_RUN3"
 
    # smk given
    if smk is not None:
        if smk<2000:
            return "TRIGGERDB_RUN1"
        elif smk<3000:
            # note that this causes problems for the runs taken during the LS2 Pilot beam test
            return "TRIGGERDB_RUN2"
        else:
            return "TRIGGERDB_RUN3"
 
    # run number given (should not be used, as the run should know the lhcRun)
    # see AtlRunQueryRun.py
    if run_number > 405800:
        return "TRIGGERDB_RUN3"
    if run_number > 378000:
        return "TRIGGERDBDEV1_I8"
    elif run_number > 249000:
        return "TRIGGERDB_RUN2"
    else:
        return "TRIGGERDB_RUN1"
 
 
 

Variable Documentation

__cursor_schema

dictionary python.utils.AtlRunQueryTriggerUtils.__cursor_schema = {}

private

Definition at line 17 of file AtlRunQueryTriggerUtils.py.

authDict

python.utils.AtlRunQueryTriggerUtils.authDict = None

Definition at line 168 of file AtlRunQueryTriggerUtils.py.

log

python.utils.AtlRunQueryTriggerUtils.log = logging.getLogger( __name__ )

Definition at line 67 of file AtlRunQueryTriggerUtils.py.