python.CaloCondTools.CaloBlobReader Class Reference

Inheritance diagram for python.CaloCondTools.CaloBlobReader:

Collaboration diagram for python.CaloCondTools.CaloBlobReader:

Public Member Functions
	__init__ (self, db, folder, tag="")
	getCells (self, systemId, pointInTime)
	getDBobjsWithinRange (self, chan, point1inTime=(0, 0), point2inTime=(2147483647, 4294967295), printError=True)
	folderIsMultiVersion (self)

Private Attributes
	__db = db
	__folder = self.__db.getFolder(folder)
	__folderType = getAthenaFolderType(folderDescr)
	__tag = tag
dict	__objDict = {}

Detailed Description

CaloBlobReader is a helper class, managing the details of COOL interactions

Definition at line 279 of file CaloCondTools.py.

Constructor & Destructor Documentation

__init__()

python.CaloCondTools.CaloBlobReader.__init__	(		self,
			db,
			folder,
			tag = "" )

Input:
- db    : db should be an open database connection 
- folder: full folder path
- tag   : The folder tag, e.g. \"000-00\"

Definition at line 285 of file CaloCondTools.py.

    def __init__(self, db, folder, tag=""):
        """
        Input:
        - db    : db should be an open database connection 
        - folder: full folder path
        - tag   : The folder tag, e.g. \"000-00\"
        """
        #=== initialize base class
        CaloCondLogger.__init__(self,"CaloBlobReader")
 
        #=== try to open db
        try:
            self.__db  = db
            self.__folder = self.__db.getFolder(folder)
        except Exception as e:
            self.log().critical( e )
            raise
 
        #=== determine if "run-lumi" or "time" folder
        validFolderTypes = ("run-lumi","time")
        folderDescr = self.__folder.description()
        self.__folderType = getAthenaFolderType(folderDescr)
        if self.__folderType not in validFolderTypes:
            raise Exception("Invalid folder type found: \'%s\'" % self.__folderType)
 
        #=== use camelized full folder path only if tag is given
        self.__tag = tag
 
        #=== initialize dictionary to keep reference to DB object
        #=== and timestamp, so they do not go out of scope
        self.__objDict = {}
 

Member Function Documentation

folderIsMultiVersion()

python.CaloCondTools.CaloBlobReader.folderIsMultiVersion

(

self

)

Returns true if MultiVersion folder is connected

Definition at line 373 of file CaloCondTools.py.

    def folderIsMultiVersion(self):
        """
        Returns true if MultiVersion folder is connected
        """
        if self.__folder.versioningMode()==cool.FolderVersioning.MULTI_VERSION:
            return True
        else:
            return False
 
 
#======================================================================
#===
#=== CaloBlobWriter 
#===
#======================================================================
 
#
#______________________________________________________________________

getCells()

python.CaloCondTools.CaloBlobReader.getCells	(		self,
			systemId,
			pointInTime )

Returns a CaloCondBlob object for the given system.

Definition at line 318 of file CaloCondTools.py.

    def getCells(self, systemId, pointInTime):
        """
        Returns a CaloCondBlob object for the given system.
        """
 
        validityKey = getCoolValidityKey(pointInTime)
        self.log().debug("Validity key is %s", validityKey)
        try:
            #=== Have we retrieved data previously?
            key = (systemId,validityKey)
            obj = self.__objDict.get(key)
            #=== ... if not, get it from DB
            if not obj:
                channelId = cool.ChannelId(systemId)
                obj = self.__folder.findObject(validityKey, channelId, self.__tag)
                self.log().debug("Fetching from DB: %s", obj)
                blob = obj.payload()[0]
                self.log().debug("blob size: %d", blob.size())
                #=== store object in dictionary
                self.__objDict[key] = obj
            #=== get blob
            blob = obj.payload()[0]
            self.log().debug("blob size: %d", blob.size())
 
            #=== create CaloCondBlob object
            flt = g.CaloCondBlobFlt.getInstance(blob)
            return flt
        except Exception as e:
            self.log().error("Fetching of systemId=%i failed with exception %s",systemId,e)
            return None
 

getDBobjsWithinRange()

python.CaloCondTools.CaloBlobReader.getDBobjsWithinRange	(		self,
			chan,
			point1inTime = (0,0),
			point2inTime = (2147483647,4294967295),
			printError = True )

Returns all DB objects for the given COOL channel, within given validity range -- default: [0-Infinity)

Definition at line 350 of file CaloCondTools.py.

    def getDBobjsWithinRange(self, chan, point1inTime=(0,0), point2inTime=(2147483647,4294967295), printError=True):
        """
        Returns all DB objects for the given COOL channel, within given validity range -- default: [0-Infinity)
        """
 
        validityKey1 = getCoolValidityKey(point1inTime,True)
        validityKey2 = getCoolValidityKey(point2inTime,False)
 
        #print "Validity keys range is %s - %s" % (validityKey1, validityKey2)
        self.log().debug("Validity key range is %s - %s", validityKey1,validityKey2)
 
        objs = None
        try:
            dbChanSel = cool.ChannelSelection(chan)
            #self.log().debug("Fetching blobs from DB: %s" % obj)
            objs = self.__folder.browseObjects(validityKey1,validityKey2,dbChanSel,self.__tag)
        except Exception as e:
            if printError:
                self.log().error("CaloCondTools.getDBobjsWithinRange(): Fetching of COOL_chan=%i failed with exception %s", chan,e)
 
        return objs
 

Member Data Documentation

__db

python.CaloCondTools.CaloBlobReader.__db = db

private

Definition at line 297 of file CaloCondTools.py.

__folder

python.CaloCondTools.CaloBlobReader.__folder = self.__db.getFolder(folder)

private

Definition at line 298 of file CaloCondTools.py.

__folderType

python.CaloCondTools.CaloBlobReader.__folderType = getAthenaFolderType(folderDescr)

private

Definition at line 306 of file CaloCondTools.py.

__objDict

dict python.CaloCondTools.CaloBlobReader.__objDict = {}

private

Definition at line 315 of file CaloCondTools.py.

__tag

python.CaloCondTools.CaloBlobReader.__tag = tag

private

Definition at line 311 of file CaloCondTools.py.

---

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

• CaloCondTools.py