dumpWBM Namespace Reference

Classes
class	constants

Functions
def	bitzeroForRun
def	deadcountForRun
def	main

Variables
string	VERSION = '1.02'

Function Documentation

def dumpWBM.bitzeroForRun	(		dbsession,
			c,
			runnum
	)

  select LUMISEGMENTNR,GTALGOCOUNTS from CMS_WBM.LEVEL1_TRIGGER_ALGO_CONDITIONS where RUNNUMBER=:runnumber and BIT=0 order by LUMISEGMENTNR

Definition at line 17 of file dumpWBM.py.

References AlCaHLTBitMon_QueryRunRegistry.data, and GetRecoTauVFromDQM_MC_cff.next.

Referenced by main().

def bitzeroForRun(dbsession,c,runnum):
    '''
      select LUMISEGMENTNR,GTALGOCOUNTS from CMS_WBM.LEVEL1_TRIGGER_ALGO_CONDITIONS where RUNNUMBER=:runnumber and BIT=0 order by LUMISEGMENTNR
    '''
    result={}
    try:
        dbsession.transaction().start(True)
        schema=dbsession.schema(c.wbmschema)
        if not schema:
            raise Exception('cannot connect to schema'+c.wbmschema)
        if not schema.existsTable(c.algotable):
            raise Exception('non-existing view'+c.algotable)
        
        query=schema.newQuery()
        algoBindVarList=coral.AttributeList()
        algoBindVarList.extend("runnumber","unsigned int")
        algoBindVarList.extend("bitnumber","unsigned int")
        algoBindVarList["runnumber"].setData(int(runnum))
        algoBindVarList["bitnumber"].setData(int(0))
        query.addToTableList(c.algotable)
        query.addToOutputList("LUMISEGMENTNR","lsnr")
        query.addToOutputList('GTALGOCOUNTS','bitcount')
        query.setCondition('RUNNUMBER=:runnumber AND BIT=:bitnumber',algoBindVarList)
        query.addToOrderList('LUMISEGMENTNR')

        bitzeroOutput=coral.AttributeList()
        bitzeroOutput.extend("lsnr","unsigned int")
        bitzeroOutput.extend('bitcount','unsigned int')
        
        query.defineOutput(bitzeroOutput)
        cursor=query.execute()
        while next(cursor):
            cmslsnum=cursor.currentRow()['lsnr'].data()
            bitcount=cursor.currentRow()['bitcount'].data()
            result[cmslsnum]=bitcount
        del query
        dbsession.transaction().commit()
        return result
    except Exception as e:
        print str(e)
        dbsession.transaction().rollback()
        del dbsession