python.TriggerConfigAccessBase.ConfigCrestLoader Class Reference

Inheritance diagram for python.TriggerConfigAccessBase.ConfigCrestLoader:

Collaboration diagram for python.TriggerConfigAccessBase.ConfigCrestLoader:

Public Member Functions
def	__init__ (self, *ConfigType configType, str dbname, int dbkey, str crestServer)
def	setQuery (self, query)
dict[str, Any]	load (self)
def	getWriteFilename (self)
def	confirmConfigType (self, config)

Public Attributes
	crestServer
	dbname
	dbkey
	schema

Private Member Functions
dict	_get_payload (self, str hash)

Detailed Description

Definition at line 356 of file TriggerConfigAccessBase.py.

Constructor & Destructor Documentation

__init__()

def python.TriggerConfigAccessBase.ConfigCrestLoader.__init__	(		self,
		*ConfigType	configType,
		str	dbname,
		int	dbkey,
		str	crestServer
	)

Definition at line 357 of file TriggerConfigAccessBase.py.

    def __init__(self, *, configType: ConfigType, dbname: str, dbkey: int, crestServer: str):
        super().__init__(configType)
        self.crestServer = crestServer
        self.dbname = dbname
        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 370 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
 

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 51 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

)

Reimplemented from python.TriggerConfigAccessBase.ConfigLoader.

Definition at line 415 of file TriggerConfigAccessBase.py.

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

load()

dict[str, Any] python.TriggerConfigAccessBase.ConfigCrestLoader.load

(

self

)

Reimplemented from python.TriggerConfigAccessBase.ConfigLoader.

Definition at line 405 of file TriggerConfigAccessBase.py.

    def load(self) -> dict[str, Any]:
        # see SCHEMA_MAP in https://gitlab.cern.ch/crest-db/crest/-/blob/master/src/main/java/hep/crest/server/repositories/triggerdb/TriggerDb.java
        crest_conn = TriggerCrestUtil.getCrestConnection(self.dbname)
        if crest_conn is None:
            raise RuntimeError(f"Cannot resolve CREST connection for dbname {self.dbname}")
        hash = f"triggerdb://{crest_conn}/{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

Reimplemented from python.TriggerConfigAccessBase.ConfigLoader.

Definition at line 364 of file TriggerConfigAccessBase.py.

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

Member Data Documentation

crestServer

python.TriggerConfigAccessBase.ConfigCrestLoader.crestServer

Definition at line 359 of file TriggerConfigAccessBase.py.

dbkey

python.TriggerConfigAccessBase.ConfigCrestLoader.dbkey

Definition at line 361 of file TriggerConfigAccessBase.py.

dbname

python.TriggerConfigAccessBase.ConfigCrestLoader.dbname

Definition at line 360 of file TriggerConfigAccessBase.py.

schema

python.TriggerConfigAccessBase.ConfigCrestLoader.schema

Definition at line 362 of file TriggerConfigAccessBase.py.

---

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

• TriggerConfigAccessBase.py