python.CoolDataReader.CoolDataReader Class Reference

Collaboration diagram for python.CoolDataReader.CoolDataReader:

Public Member Functions
	__init__ (self, dbstr=None, folderstr=None)
	setFolder (self, dbstr, folderstr)
	setTag (self, tagstr='')
	setChannel (self, channelIdList=[])
	setChannelAll (self)
	setChannelId (self, channelId)
	setIOVRange (self, iovstart=cool.ValidityKeyMin, iovend=cool.ValidityKeyMax)
	setIOVRangeFromRun (self, runnum)
	readData (self)
	readChannelList (self, channels)

Public Attributes
bool	verbose = False
	dbstr = None
	folderstr = None
list	channelIdList = []
str	tag = ''
int	iovstart = None
tuple	iovend = None
	folder = None
list	data = []

Detailed Description

Definition at line 33 of file CoolDataReader.py.

Constructor & Destructor Documentation

__init__()

python.CoolDataReader.CoolDataReader.__init__	(		self,
			dbstr = None,
			folderstr = None )

Definition at line 35 of file CoolDataReader.py.

    def __init__(self, dbstr=None, folderstr=None):
 
        self.verbose = False
 
        # Defined variables
        self.dbstr = None
        self.folderstr = None
        self.channelIdList = []
        self.tag = ''
        self.iovstart = None
        self.iovend = None
 
        self.folder = None
        self.data = []
        
        # Initialize to default values
        self.setChannel()
        self.setTag()
        self.setFolder(dbstr, folderstr)
        self.setIOVRange()
            

Member Function Documentation

readChannelList()

python.CoolDataReader.CoolDataReader.readChannelList	(		self,
			channels )

Definition at line 141 of file CoolDataReader.py.

    def readChannelList(self, channels):
 
        # Open iterator over our defined IOV range
        try:
            itr = self.folder.browseObjects(self.iovstart, self.iovend, channels, self.tag)
        except Exception as e:
            print('CoolDataReader.readData() - exception reading folder:', self.folderstr)
            print(e)
            print('CoolDataReader.readData() - will try to reconnect (once)')
 
            # Force re-opening connection
            dbHandler = LumiDBHandler()
            dbHandler.verbose = True
            self.folder = dbHandler.getFolder(self.dbstr, self.folderstr, force=True)
            
            if self.folder is None:
                print('CoolDataReader.readData() - forced re-opening failed!')
                return self.data
 
            # OK, lets try reading this again
            print('CoolDataReader.readData() - trying to re-read re-opened folder!')
            try:
                itr = self.folder.browseObjects(self.iovstart, self.iovend, channels, self.tag)
            except Exception as e:
                print('CoolDataReader.readData() - exception reading folder:', self.folderstr)
                print(e)
                return self.data
                
        while itr.goToNext():
            obj = itr.currentRef()
            # print obj.payload()
            self.data.append(obj.clone())
            
        itr.close()
 
 
        

readData()

python.CoolDataReader.CoolDataReader.readData

(

self

)

Definition at line 87 of file CoolDataReader.py.

    def readData(self):
 
        self.data = []
 
        # Open the DB connection here if needed
        if self.folder is None:
            dbHandler = LumiDBHandler()
            self.folder = dbHandler.getFolder(self.dbstr, self.folderstr)
            
            if self.folder is None:
                print("Can't access DB", self.dbstr, 'folder', self.folderstr, '!')
                return self.data
 
        # Create the channel list
        if len(self.channelIdList) == 0:
            channels = cool.ChannelSelection.all()
            self.readChannelList(channels)
 
        else:
            # Build the channel list here
            self.channelIdList.sort()  # Must be sorted!
 
            # Must read channels 50 at a time due to COOL limit...
            ichan = 0
            while (ichan < len(self.channelIdList)) :
 
                jchan = 0
                channels = None
                firstChan = True
            
                for channelId in self.channelIdList[ichan:]:
                    jchan += 1
                    if firstChan:
                        firstChan = False
                        channels = cool.ChannelSelection(channelId)
                    else:
                        channels.addChannel(channelId)
                    if jchan == 50: break 
 
                # Remeber how many we have read for next time
                if self.verbose:
                    print('CoolDataReader.readData() - loaded %d channels from %d' % (jchan, ichan))
                ichan += jchan
 
                if self.verbose:
                    print('CoolDataReader.readData() - browsing', self.iovstart, self.iovend, 'with channel', channels, 'and tag', self.tag)
 
                self.readChannelList(channels)
 
            # End of loop building channel list and reading
 
        # End of if statement reading data
        return self.data
 

setChannel()

python.CoolDataReader.CoolDataReader.setChannel	(		self,
			channelIdList = [] )

Definition at line 67 of file CoolDataReader.py.

    def setChannel(self, channelIdList=[]):
        self.channelIdList = channelIdList
        

setChannelAll()

python.CoolDataReader.CoolDataReader.setChannelAll

(

self

)

Definition at line 70 of file CoolDataReader.py.

    def setChannelAll(self):
        self.setChannel()
 

setChannelId()

python.CoolDataReader.CoolDataReader.setChannelId	(		self,
			channelId )

Definition at line 73 of file CoolDataReader.py.

    def setChannelId(self, channelId):
        self.setChannel([channelId])
        

setFolder()

python.CoolDataReader.CoolDataReader.setFolder	(		self,
			dbstr,
			folderstr )

Definition at line 56 of file CoolDataReader.py.

    def setFolder(self, dbstr, folderstr):
        # Force re-opening connection if these are different
        if (dbstr != self.dbstr) or (folderstr != self.folderstr):
            self.folder = None
            
        self.dbstr = dbstr
        self.folderstr = folderstr
 

setIOVRange()

python.CoolDataReader.CoolDataReader.setIOVRange	(		self,
			iovstart = cool.ValidityKeyMin,
			iovend = cool.ValidityKeyMax )

Definition at line 76 of file CoolDataReader.py.

    def setIOVRange(self, iovstart=cool.ValidityKeyMin, iovend=cool.ValidityKeyMax):
        self.iovstart = iovstart
        self.iovend = iovend
 

setIOVRangeFromRun()

python.CoolDataReader.CoolDataReader.setIOVRangeFromRun	(		self,
			runnum )

Definition at line 80 of file CoolDataReader.py.

    def setIOVRangeFromRun(self, runnum):
        self.iovstart = runnum << 32
        self.iovend = ((runnum+1) << 32) - 1
 

setTag()

python.CoolDataReader.CoolDataReader.setTag	(		self,
			tagstr = '' )

Definition at line 64 of file CoolDataReader.py.

    def setTag(self, tagstr=''):
        self.tag = tagstr
 

Member Data Documentation

channelIdList

python.CoolDataReader.CoolDataReader.channelIdList = []

Definition at line 42 of file CoolDataReader.py.

data

list python.CoolDataReader.CoolDataReader.data = []

Definition at line 48 of file CoolDataReader.py.

dbstr

python.CoolDataReader.CoolDataReader.dbstr = None

Definition at line 40 of file CoolDataReader.py.

folder

python.CoolDataReader.CoolDataReader.folder = None

Definition at line 47 of file CoolDataReader.py.

folderstr

python.CoolDataReader.CoolDataReader.folderstr = None

Definition at line 41 of file CoolDataReader.py.

iovend

python.CoolDataReader.CoolDataReader.iovend = None

Definition at line 45 of file CoolDataReader.py.

iovstart

python.CoolDataReader.CoolDataReader.iovstart = None

Definition at line 44 of file CoolDataReader.py.

tag

python.CoolDataReader.CoolDataReader.tag = ''

Definition at line 43 of file CoolDataReader.py.

verbose

bool python.CoolDataReader.CoolDataReader.verbose = False

Definition at line 37 of file CoolDataReader.py.

---

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

• CoolDataReader.py