python.TrigConfFrontier Namespace Reference

Classes
class	FrontierCursor

Functions
	getServerUrls (frontier_servers)
	resolveUrl (url)
	getFrontierCursor (urls, schema, loglevel=logging.INFO)
	replacebindvars (query, bindvars)
	testQuery (query, bindvars)

Variables
	log = logging.getLogger( "TrigConfFrontier.py" )
str	dbalias = "TRIGGERDBMC"
str	query = "select distinct HPS.HPS_NAME from ATLAS_CONF_TRIGGER_RUN2_MC.HLT_PRESCALE_SET HPS where HPS.HPS_ID = :psk"
dict	bindvars = { "psk": 260 }
	res = testQuery(query, bindvars)

Function Documentation

getFrontierCursor()

python.TrigConfFrontier.getFrontierCursor	(		urls,
			schema,
			loglevel = logging.INFO )

Definition at line 33 of file TrigConfFrontier.py.

def getFrontierCursor(urls, schema, loglevel = logging.INFO):
    log.setLevel(loglevel)
    url_list = resolveUrl(urls)
    if len(url_list) == 0:
        log.warning("Cannot find a valid frontier connection, will not return a Frontier cursor")
        return None
    else:
        log.info(f"Will use Frontier server at {urls}")
 
    return FrontierCursor( urls = url_list, schema = schema)
        
 
# used by FrontierCursor

getServerUrls()

python.TrigConfFrontier.getServerUrls

(

frontier_servers

)

turns
'(serverurl=http://atlasfrontier-local.cern.ch:8000/atlr)(serverurl=http://atlasfrontier-ai.cern.ch:8000/atlr)'
into
['http://atlasfrontier-local.cern.ch:8000/atlr','http://atlasfrontier-ai.cern.ch:8000/atlr']

Definition at line 10 of file TrigConfFrontier.py.

def getServerUrls(frontier_servers):
    """
    turns
    '(serverurl=http://atlasfrontier-local.cern.ch:8000/atlr)(serverurl=http://atlasfrontier-ai.cern.ch:8000/atlr)'
    into
    ['http://atlasfrontier-local.cern.ch:8000/atlr','http://atlasfrontier-ai.cern.ch:8000/atlr']
    """
    from re import findall
    return findall(r'\‍(serverurl=(.*?)\‍)',frontier_servers)
 
 

replacebindvars()

python.TrigConfFrontier.replacebindvars	(		query,
			bindvars )

Replaces the bound variables with the specified values,
disables variable binding

Definition at line 46 of file TrigConfFrontier.py.

def replacebindvars(query, bindvars):
    """Replaces the bound variables with the specified values,
    disables variable binding
    """
    for var,val in list(bindvars.items()):
        if query.find(":%s" % var)<0:
            raise NameError("variable '%s' is not a bound variable in this query: %s" % (var, query) )
        if isinstance (val, int):
            query = query.replace(":%s" % var,"%s" % val)
        else:
            query = query.replace(":%s" % var,"%r" % val)
        log.debug("Resolving bound variable '%s' with %r", var,val)
    log.debug("Resolved query: %s", query)
    return query
 
 

resolveUrl()

python.TrigConfFrontier.resolveUrl

(

url

)

Expects input string to be a URL or $FRONTIER_SERVER
Returns an accessible URL or None

Definition at line 21 of file TrigConfFrontier.py.

def resolveUrl(url):
    """
    Expects input string to be a URL or $FRONTIER_SERVER
    Returns an accessible URL or None"""
    import re
    if re.match("http://",url): # simple URL specification http://...
        return [url]
 
    if re.match(r'\‍(serverurl=(.*?)\‍)',url): # syntax of FRONTIER_SERVER
        return getServerUrls(url)
 
 

testQuery()

python.TrigConfFrontier.testQuery	(		query,
			bindvars )

Definition at line 228 of file TrigConfFrontier.py.

def testQuery(query, bindvars):
    from TrigConfigSvc.TrigConfigSvcUtils import interpretConnection
    connectionParameters = interpretConnection("TRIGGERDBMC")
    cursor = getFrontierCursor( urls = connectionParameters['url'], schema = connectionParameters['schema'])
    cursor.execute(query, bindvars)
    log.info("Raw response:")
    log.info(cursor.result)
    cursor.decodeResult()
    log.info("Decoded response:")
    log.info(cursor.result[0][0])        
    if cursor.result[0][0] != 'MC_pp_v7':
        return 1
    return 0
 
    

Variable Documentation

bindvars

dict python.TrigConfFrontier.bindvars = { "psk": 260 }

Definition at line 249 of file TrigConfFrontier.py.

dbalias

str python.TrigConfFrontier.dbalias = "TRIGGERDBMC"

Definition at line 247 of file TrigConfFrontier.py.

log

python.TrigConfFrontier.log = logging.getLogger( "TrigConfFrontier.py" )

Definition at line 8 of file TrigConfFrontier.py.

query

str python.TrigConfFrontier.query = "select distinct HPS.HPS_NAME from ATLAS_CONF_TRIGGER_RUN2_MC.HLT_PRESCALE_SET HPS where HPS.HPS_ID = :psk"

Definition at line 248 of file TrigConfFrontier.py.

res

python.TrigConfFrontier.res = testQuery(query, bindvars)

Definition at line 251 of file TrigConfFrontier.py.