COOLRates.COOLQueryWorker Class Reference

Inheritance diagram for COOLRates.COOLQueryWorker:

Collaboration diagram for COOLRates.COOLQueryWorker:

Public Member Functions
	__init__ (self, timeConverter={})
	getdb (self, dbName)
	getFolder (self, folderName)
	getdbName (self, folderName)
	convertTime (self, timeStart, timeEnd, timeConverter)
	processQuery (self, queryBundle)
	close (self)
	__call__ (self, queueIn, queueOut)

Public Attributes
	db_svc = cool.DatabaseSvcFactory.databaseService()
	timeConverter = timeConverter
dict	db = {}
dict	folder = {}

Detailed Description

Definition at line 71 of file COOLRates.py.

Constructor & Destructor Documentation

__init__()

COOLRates.COOLQueryWorker.__init__	(		self,
			timeConverter = {} )

Definition at line 72 of file COOLRates.py.

    def __init__(self,timeConverter = {}):
        self.db_svc = cool.DatabaseSvcFactory.databaseService()
        self.timeConverter=timeConverter
        self.db = {}
        self.folder = {}
 

Member Function Documentation

__call__()

COOLRates.COOLQueryWorker.__call__	(		self,
			queueIn,
			queueOut )

Definition at line 133 of file COOLRates.py.

    def __call__(self,queueIn,queueOut):
        signal.signal(signal.SIGINT, signal.SIG_IGN)
        try:
            while True:
                try:
                    queryBundle = queueIn.get(False,.001)
                except Empty:
                    sleep(.001)
                    continue
                if queryBundle is True:
                    break
                resultBundle = self.processQuery(queryBundle)
                queueOut.put(resultBundle)
        except Exception as exception:
            logger.critical(exception)
        
        self.close()
        queueOut.put(True)
        return
 
#====================================================================================================================       
 

close()

COOLRates.COOLQueryWorker.close

(

self

)

Definition at line 130 of file COOLRates.py.

    def close(self):
        for db in self.db.values(): db.closeDatabase()
    

convertTime()

COOLRates.COOLQueryWorker.convertTime	(		self,
			timeStart,
			timeEnd,
			timeConverter )

Definition at line 98 of file COOLRates.py.

    def convertTime(self,timeStart,timeEnd,timeConverter):
        validRunLbs = [runLb for runLb,time in timeConverter.items() if timeStart<=time<=timeEnd]
        return validRunLbs
 

getdb()

COOLRates.COOLQueryWorker.getdb	(		self,
			dbName )

Definition at line 78 of file COOLRates.py.

    def getdb(self,dbName):
        if dbName not in self.db:
            self.db[dbName] = self.db_svc.openDatabase(dbName,True)
        return self.db.get(dbName)
    

getdbName()

COOLRates.COOLQueryWorker.getdbName	(		self,
			folderName )

Definition at line 90 of file COOLRates.py.

    def getdbName(self,folderName):
        if folderName.startswith('/LHC/DCS/'):
            return 'oracle://ATLAS_COOLPROD;schema=ATLAS_COOLOFL_DCS;dbname=COMP200;'
        if folderName.startswith('/TRIGGER/HLT/') and 'Rates' in folderName:
            return "oracle://ATLAS_COOLPROD;schema=ATLAS_COOLONL_TRIGGER;dbname=MONP200;"
        if not folderName.startswith('/'): folderName = '/'+folderName
        return "oracle://ATLAS_COOLPROD;schema=ATLAS_COOLONL_{0};dbname=COMP200;".format(folderName.split("/")[1])
 

getFolder()

COOLRates.COOLQueryWorker.getFolder	(		self,
			folderName )

Definition at line 83 of file COOLRates.py.

    def getFolder(self,folderName):
        if folderName not in self.folder:
            dbName = self.getdbName(folderName)
            db = self.getdb(dbName)
            self.folder[folderName] = db.getFolder(folderName)
        return self.folder.get(folderName)
        

processQuery()

COOLRates.COOLQueryWorker.processQuery	(		self,
			queryBundle )

Reimplemented in COOLRates.RateQueryWorker.

Definition at line 102 of file COOLRates.py.

    def processQuery(self,queryBundle):
        folder = self.getFolder(queryBundle.folderName)
        folder.setPrefetchAll(False)
        result = {}     
        for payloadName,payloadAlias,cast in queryBundle.payloadRequests: result[payloadAlias]={}
        folderIterator = folder.browseObjects(queryBundle.IoVStart,queryBundle.IoVEnd,queryBundle.channelSelection)
        if queryBundle.timeBased:
            while folderIterator.goToNext():
                currentSlice = folderIterator.currentRef()
                for payloadName,payloadAlias,cast in queryBundle.payloadRequests:
                    payload = cast(currentSlice.payloadValue(payloadName))              
                    if payloadName in queryBundle.payloadRequirements:
                        if not eval(queryBundle.payloadRequirements[payloadName].format(repr(payload))): continue
                    runLbs = self.convertTime(int(currentSlice.since()),int(currentSlice.until()),queryBundle.timeConverter)        
                    result[payloadAlias].update(dict.fromkeys(runLbs,payload))
        else:
            while folderIterator.goToNext():
                currentSlice = folderIterator.currentRef()
                for payloadName,payloadAlias,cast in queryBundle.payloadRequests:
                    payload = cast(currentSlice.payloadValue(payloadName))
                    if payloadName in queryBundle.payloadRequirements:
                        if not eval(queryBundle.payloadRequirements['payloadName'].format(repr(payload))): continue
                    runLbs = range(max(currentSlice.since(),queryBundle.IoVStart),min(currentSlice.until(),queryBundle.IoVEnd))
                    result[payloadAlias].update(dict.fromkeys(runLbs,payload))
 
        folderIterator.close()
        return result
    

Member Data Documentation

db

dict COOLRates.COOLQueryWorker.db = {}

Definition at line 75 of file COOLRates.py.

db_svc

COOLRates.COOLQueryWorker.db_svc = cool.DatabaseSvcFactory.databaseService()

Definition at line 73 of file COOLRates.py.

folder

dict COOLRates.COOLQueryWorker.folder = {}

Definition at line 76 of file COOLRates.py.

timeConverter

COOLRates.COOLQueryWorker.timeConverter = timeConverter

Definition at line 74 of file COOLRates.py.

---

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

• COOLRates.py