COOLRates.RateQueryWorker Class Reference

Inheritance diagram for COOLRates.RateQueryWorker:

Collaboration diagram for COOLRates.RateQueryWorker:

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

Public Attributes
	db_svc
	timeConverter
	db
	folder

Detailed Description

Definition at line 423 of file COOLRates.py.

Constructor & Destructor Documentation

__init__()

def COOLRates.RateQueryWorker.__init__

(

self

)

Definition at line 424 of file COOLRates.py.

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

Member Function Documentation

__call__()

def 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()

def 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()

def 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()

def 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()

def 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()

def 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()

def 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

COOLRates.COOLQueryWorker.db

inherited

Definition at line 75 of file COOLRates.py.

db_svc

COOLRates.COOLQueryWorker.db_svc

inherited

Definition at line 73 of file COOLRates.py.

folder

COOLRates.COOLQueryWorker.folder

inherited

Definition at line 76 of file COOLRates.py.

timeConverter

COOLRates.COOLQueryWorker.timeConverter

inherited

Definition at line 74 of file COOLRates.py.

---

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

• COOLRates.py