python.CoolDataReader.CoolDataReader Class Reference

Collaboration diagram for python.CoolDataReader.CoolDataReader:

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

Public Attributes
	verbose
	dbstr
	folderstr
	channelIdList
	tag
	iovstart
	iovend
	folder
	data

Detailed Description

Definition at line 34 of file CoolDataReader.py.

Constructor & Destructor Documentation

__init__()

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

Definition at line 36 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()

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

Definition at line 142 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()

def python.CoolDataReader.CoolDataReader.readData

(

self

)

Definition at line 88 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()

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

Definition at line 68 of file CoolDataReader.py.

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

setChannelAll()

def python.CoolDataReader.CoolDataReader.setChannelAll

(

self

)

Definition at line 71 of file CoolDataReader.py.

    def setChannelAll(self):
        self.setChannel()
 

setChannelId()

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

Definition at line 74 of file CoolDataReader.py.

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

setFolder()

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

Definition at line 57 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()

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

Definition at line 77 of file CoolDataReader.py.

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

setIOVRangeFromRun()

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

Definition at line 81 of file CoolDataReader.py.

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

setTag()

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

Definition at line 65 of file CoolDataReader.py.

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

Member Data Documentation

channelIdList

python.CoolDataReader.CoolDataReader.channelIdList

Definition at line 43 of file CoolDataReader.py.

data

python.CoolDataReader.CoolDataReader.data

Definition at line 49 of file CoolDataReader.py.

dbstr

python.CoolDataReader.CoolDataReader.dbstr

Definition at line 41 of file CoolDataReader.py.

folder

python.CoolDataReader.CoolDataReader.folder

Definition at line 48 of file CoolDataReader.py.

folderstr

python.CoolDataReader.CoolDataReader.folderstr

Definition at line 42 of file CoolDataReader.py.

iovend

python.CoolDataReader.CoolDataReader.iovend

Definition at line 46 of file CoolDataReader.py.

iovstart

python.CoolDataReader.CoolDataReader.iovstart

Definition at line 45 of file CoolDataReader.py.

tag

python.CoolDataReader.CoolDataReader.tag

Definition at line 44 of file CoolDataReader.py.

verbose

python.CoolDataReader.CoolDataReader.verbose

Definition at line 38 of file CoolDataReader.py.

---

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

• CoolDataReader.py