COOLRates.RateQueryWorker Class Reference

Inheritance diagram for COOLRates.RateQueryWorker:

Collaboration diagram for COOLRates.RateQueryWorker:

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

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

Detailed Description

Definition at line 423 of file COOLRates.py.

Constructor & Destructor Documentation

__init__()

COOLRates.RateQueryWorker.__init__

(

self

)

Definition at line 424 of file COOLRates.py.

    def __init__(self):
        COOLQueryWorker.__init__(self)
 

Member Function Documentation

__call__()

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

inherited

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 )

inherited

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 )

inherited

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 )

inherited

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 )

inherited

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 )

inherited

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.RateQueryWorker.processQuery	(		self,
			rateBundle )

Reimplemented from COOLRates.COOLQueryWorker.

Definition at line 427 of file COOLRates.py.

    def processQuery(self,rateBundle):
        result = {}
        result[rateBundle.alias] = {}
 
        #Get first result
        firstResult = {}
        folder = self.getFolder(rateBundle.folderName)
        folder.setPrefetchAll(False)
        folderIterator = folder.browseObjects(rateBundle.IoVStart,rateBundle.IoVEnd,rateBundle.channelSelection)
        while folderIterator.goToNext():
            currentSlice = folderIterator.currentRef()
            firstResult[currentSlice.since()]=float(currentSlice.payloadValue(rateBundle.payloadName))
        folderIterator.close()
        
        #Get second result (if counts based)
        if rateBundle.turnCountFolderName is not None:
            secondResult = {}
            folder = self.getFolder(rateBundle.turnCountFolderName)
            folder.setPrefetchAll(False)
            folderIterator = folder.browseObjects(rateBundle.IoVStart,rateBundle.IoVEnd,cool.ChannelSelection())
            while folderIterator.goToNext():
                currentSlice = folderIterator.currentRef()
                secondResult[currentSlice.since()]=float(currentSlice.payloadValue(rateBundle.turnCountPayloadName))
            folderIterator.close()
            result[rateBundle.alias].update(dict((key,11246.0*firstResult.get(key)/secondResult.get(key)) for key in commonKeys([firstResult,secondResult])))       
        else: 
            result[rateBundle.alias].update(firstResult)
        return result
 
#====================================================================================================================
 

Member Data Documentation

db

dict COOLRates.COOLQueryWorker.db = {}

inherited

Definition at line 75 of file COOLRates.py.

db_svc

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

inherited

Definition at line 73 of file COOLRates.py.

folder

dict COOLRates.COOLQueryWorker.folder = {}

inherited

Definition at line 76 of file COOLRates.py.

timeConverter

COOLRates.COOLQueryWorker.timeConverter = timeConverter

inherited

Definition at line 74 of file COOLRates.py.

---

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

• COOLRates.py