python.TriggerConfigAccessBase.ConfigCrestLoader Class Reference

Inheritance diagram for python.TriggerConfigAccessBase.ConfigCrestLoader:

Collaboration diagram for python.TriggerConfigAccessBase.ConfigCrestLoader:

Public Member Functions
def	__init__ (self, *configType, dbalias, dbkey, crestServer)
def	setQuery (self, query)
dict	load (self)
def	getWriteFilename (self)
def	confirmConfigType (self, config)

Public Attributes
	crestServer
	dbalias
	dbkey
	schema
	configType

Private Member Functions
dict	_get_payload (self, str hash)

Static Private Member Functions
str	_getDBSchemaName (dbalias)

Detailed Description

Definition at line 340 of file TriggerConfigAccessBase.py.

Constructor & Destructor Documentation

__init__()

def python.TriggerConfigAccessBase.ConfigCrestLoader.__init__	(		self,
		*	configType,
			dbalias,
			dbkey,
			crestServer
	)

Definition at line 341 of file TriggerConfigAccessBase.py.

    def __init__(self, *, configType, dbalias, dbkey, crestServer):
        super().__init__(configType)
        self.crestServer = crestServer
        self.dbalias = dbalias
        self.dbkey = dbkey
        self.schema = ""
 

Member Function Documentation

_get_payload()

dict python.TriggerConfigAccessBase.ConfigCrestLoader._get_payload (   self, str  hash  )

private

get payload from crest server using request library

Args:
    hash (str): the query part of the url as required by the REST api

Raises:
    RuntimeError: when connection or query failed

Returns:
    dict: the json content

Definition at line 354 of file TriggerConfigAccessBase.py.

    def _get_payload(self, hash: str) -> dict:
        """get payload from crest server using request library
 
        Args:
            hash (str): the query part of the url as required by the REST api
 
        Raises:
            RuntimeError: when connection or query failed
 
        Returns:
            dict: the json content
        """
        import requests
 
        url = f"{self.crestServer}/payloads/data"
        params = {
            "format": "BLOB", 
            "hash": hash
            }
        preq = requests.Request(method='GET', url=url, params=params).prepare()
        with requests.Session() as session:
            try:
                resp = session.send(preq)
            except requests.ConnectionError as exc:
                log.error(f"Could not connect to crest server {self.crestServer} ({exc})")
                raise RuntimeError(f"Could not connect to CREST server {self.crestServer}")
        
        if resp.status_code != 200:
            log.error(f"Error: HTTP GET request '{preq.url}' failed")
            raise RuntimeError(f"Query {hash} to crest failed with status code {resp.status_code}")
        
        config = json.loads(resp.content)
        self.confirmConfigType(config)
        return config
 

_getDBSchemaName()

str python.TriggerConfigAccessBase.ConfigCrestLoader._getDBSchemaName (   dbalias )

staticprivate

Definition at line 390 of file TriggerConfigAccessBase.py.

    def _getDBSchemaName(dbalias) -> str:
        dblookupFile = ConfigDBLoader.getResolvedFileName("dblookup.xml", "CORAL_DBLOOKUP_PATH")
        dbp = ET.parse(dblookupFile)
        for logSvc in dbp.iter("logicalservice"):
            if logSvc.attrib["name"] != dbalias:
                continue
            oracleServer = ""
            for serv in logSvc.iter("service"):
                if serv.attrib["name"].startswith("oracle://"):
                    oracleService = serv.attrib["name"]
                    oracleServer = oracleService.split('/')[3]
                    return oracleServer
            raise RuntimeError(f"DB {dbalias} has no oracle services listed in {dblookupFile}")
        raise RuntimeError(f"DB {dbalias} is not listed in {dblookupFile}")
 

confirmConfigType()

def python.TriggerConfigAccessBase.ConfigLoader.confirmConfigType (   self,   config  )

inherited

checks that the in-file specification of the configuration type matches the expected type

Definition at line 49 of file TriggerConfigAccessBase.py.

    def confirmConfigType(self,config):
        """
        checks that the in-file specification of the configuration type matches the expected type
        """
        if config['filetype'] != self.configType:
            raise RuntimeError("Can not load file with filetype '%s' when expecting '%s'" % (config['filetype'], self.configType.filetype))
 

getWriteFilename()

def python.TriggerConfigAccessBase.ConfigCrestLoader.getWriteFilename

(

self

)

Definition at line 420 of file TriggerConfigAccessBase.py.

    def getWriteFilename(self):
        return "{basename}_{schema}_{dbkey}.json".format(basename = self.configType.basename, schema = self.schema, dbkey = self.dbkey)
 

load()

dict python.TriggerConfigAccessBase.ConfigCrestLoader.load

(

self

)

Definition at line 405 of file TriggerConfigAccessBase.py.

    def load(self) -> dict:
        # see SCHEMA_MAP in https://gitlab.cern.ch/crest-db/crest/-/blob/master/src/main/java/hep/crest/server/repositories/triggerdb/TriggerDb.java
        self.schema = ConfigCrestLoader._getDBSchemaName(self.dbalias)
        url_schema = {
            "ATLAS_CONF_TRIGGER_RUN3": "CONF_DATA_RUN3",
            "ATLAS_CONF_TRIGGER_MC_RUN3": "CONF_MC_RUN3",
            "ATLAS_CONF_TRIGGER_REPR_RUN3": "CONF_REPR_RUN3", 
        }.get(self.schema)
        if url_schema is None:
            raise RuntimeError(f"Oracle server {self.schema} is not implemented in the crest server {self.crestServer}")
        hash = f"triggerdb://{url_schema}/{self.configType.crestkey}/{self.dbkey}"
        config = self._get_payload(hash=hash)
        return config
 

setQuery()

def python.TriggerConfigAccessBase.ConfigCrestLoader.setQuery	(		self,
			query
	)

With CREST all queries are defined in the CREST server

Definition at line 348 of file TriggerConfigAccessBase.py.

    def setQuery(self, query):
        """
        With CREST all queries are defined in the CREST server
        """
        pass
 

Member Data Documentation

configType

python.TriggerConfigAccessBase.ConfigLoader.configType

inherited

Definition at line 48 of file TriggerConfigAccessBase.py.

crestServer

python.TriggerConfigAccessBase.ConfigCrestLoader.crestServer

Definition at line 343 of file TriggerConfigAccessBase.py.

dbalias

python.TriggerConfigAccessBase.ConfigCrestLoader.dbalias

Definition at line 344 of file TriggerConfigAccessBase.py.

dbkey

python.TriggerConfigAccessBase.ConfigCrestLoader.dbkey

Definition at line 345 of file TriggerConfigAccessBase.py.

schema

python.TriggerConfigAccessBase.ConfigCrestLoader.schema

Definition at line 346 of file TriggerConfigAccessBase.py.

---

The documentation for this class was generated from the following file:

• TriggerConfigAccessBase.py