dumpRunInfo.py

Go to the documentation of this file.

#!/usr/bin/env python
VERSION='1.02'
import os,sys
import re
import coral
from RecoLuminosity.LumiDB import argparse

class constants(object):
    def __init__(self):
        self.debug=False
        self.runinfodb=''
        self.runinfoschema='CMS_RUNINFO'
        self.runsessionparameterTable='RUNSESSION_PARAMETER'
        self.hltconfname='CMS.LVL0:HLT_KEY_DESCRIPTION'
        self.tsckeyname='CMS.TRG:TSC_KEY'
        self.fillnumname='CMS.SCAL:FILLN'
def fillnumForRun(dbsession,c,runnum):
    '''select string_value from cms_runinfo.runsession_parameter where runnumber=129265 and name='CMS.SCAL:FILLN' and rownum<=1;
    
    '''
    result=''
    try:
        dbsession.transaction().start(True)
        schema=dbsession.schema(c.runinfoschema)
        if not schema:
            raise Exception('cannot connect to schema '+c.runinfoschema)
        if not schema.existsTable(c.runsessionparameterTable):
            raise Exception('non-existing table '+c.runsessionparameterTable)

        fillOutput=coral.AttributeList()
        fillOutput.extend("fillnum","string")
        
        bindVarList=coral.AttributeList()
        bindVarList.extend("name","string")
        bindVarList.extend("runnumber","unsigned int")

        bindVarList["name"].setData(c.fillnumname)
        bindVarList["runnumber"].setData(int(runnum))
        
        query=schema.newQuery()
        query.addToTableList(c.runsessionparameterTable)
        query.addToOutputList('STRING_VALUE','value')
        query.setCondition('NAME=:name AND RUNNUMBER=:runnumber',bindVarList)
        query.limitReturnedRows(1)
        query.defineOutput(fillOutput)
        
        cursor=query.execute()
        while next(cursor):
            result=cursor.currentRow()['fillnum'].data()
        del query
        dbsession.transaction().commit()
        #print result
        return result
    except Exception as e:
        print str(e)
        dbsession.transaction().rollback()
        del dbsession
        
def hltkeyForRun(dbsession,c,runnum):
    '''
    select runnumber,string_value from cms_runinfo.runsession_parameter where name=:runsessionparametername and runnumber=:runnum 
    '''
    result={}
    try:
        dbsession.transaction().start(True)
        schema=dbsession.schema(c.runinfoschema)
        if not schema:
            raise Exception('cannot connect to schema '+c.runinfoschema)
        if not schema.existsTable(c.runsessionparameterTable):
            raise Exception('non-existing table '+c.runsessionparameterTable)

        hltkeyOutput=coral.AttributeList()
        hltkeyOutput.extend("runnum","unsigned int")
        hltkeyOutput.extend("hltkey","string")
        
        bindVarList=coral.AttributeList()
        bindVarList.extend("name","string")
        bindVarList.extend("runnumber","unsigned int")

        bindVarList["name"].setData(c.hltconfname)
        bindVarList["runnumber"].setData(int(runnum))
        
        query=schema.newQuery()
        query.addToTableList(c.runsessionparameterTable)
        query.addToOutputList('RUNNUMBER','runnumber')
        query.addToOutputList('STRING_VALUE','value')
        query.setCondition('NAME=:name AND RUNNUMBER=:runnumber',bindVarList)
        query.defineOutput(hltkeyOutput)
        
        cursor=query.execute()
        while next(cursor):
            runnum=cursor.currentRow()['runnum'].data()
            hltkey=cursor.currentRow()['hltkey'].data()
            result[runnum]=hltkey
        del query
        dbsession.transaction().commit()
        #print result
        return result
    except Exception as e:
        print str(e)
        dbsession.transaction().rollback()
        del dbsession
        
def l1keyForRun(dbsession,c,runnum):
    '''
    select runnumber,string_value from cms_runinfo.runsession_parameter where name=:runsessionparametername and runnumber=:runnum 
    '''
    result={}
    try:
        dbsession.transaction().start(True)
        schema=dbsession.schema(c.runinfoschema)
        if not schema:
            raise Exception('cannot connect to schema '+c.runinfoschema)
        if not schema.existsTable(c.runsessionparameterTable):
            raise Exception('non-existing table '+c.runsessionparameterTable)

        l1keyOutput=coral.AttributeList()
        l1keyOutput.extend("runnum","unsigned int")
        l1keyOutput.extend("l1key","string")
        
        bindVarList=coral.AttributeList()
        bindVarList.extend("name","string")
        bindVarList.extend("runnumber","unsigned int")

        bindVarList["name"].setData(c.tsckeyname)
        bindVarList["runnumber"].setData(int(runnum))
        
        query=schema.newQuery()
        query.addToTableList(c.runsessionparameterTable)
        query.addToOutputList('RUNNUMBER','runnumber')
        query.addToOutputList('STRING_VALUE','value')
        query.setCondition('NAME=:name AND RUNNUMBER=:runnumber',bindVarList)
        query.defineOutput(l1keyOutput)
        
        cursor=query.execute()
        while next(cursor):
            runnum=cursor.currentRow()['runnum'].data()
            l1key=cursor.currentRow()['l1key'].data()
            result[runnum]=l1key
        del query
        dbsession.transaction().commit()
        #print result
        return result
    except Exception as e:
        print str(e)
        dbsession.transaction().rollback()
        del dbsession
        
def main():
    c=constants()
    parser = argparse.ArgumentParser(prog=os.path.basename(sys.argv[0]),description="Dump Run info")
    parser.add_argument('-c',dest='connect',action='store',required=True,help='connect string to trigger DB(required)')
    parser.add_argument('-P',dest='authpath',action='store',required=True,help='path to authentication file')
    parser.add_argument('-r',dest='runnumber',action='store',required=True,help='run number')
    parser.add_argument('action',choices=['hltkey','l1key','fill'],help='information to show')
    parser.add_argument('--debug',dest='debug',action='store_true',help='debug')
    parser.add_argument('--collision-only',dest='collisiononly',action='store_true',help='return only collision runs')
    args=parser.parse_args()
    runnumber=args.runnumber
    c.runinfodb=args.connect
    if args.authpath and len(args.authpath)!=0:
        os.environ['CORAL_AUTH_PATH']=args.authpath
    svc=coral.ConnectionService()
    session=svc.connect(c.runinfodb,accessMode=coral.access_ReadOnly)
    session.typeConverter().setCppTypeForSqlType("unsigned int","NUMBER(10)")
    session.typeConverter().setCppTypeForSqlType("unsigned long long","NUMBER(20)")
    if args.debug:
        msg=coral.MessageStream('')
        msg.setMsgVerbosity(coral.message_Level_Debug)
    
    if args.action == 'hltkey':
        p=re.compile(r'^/cdaq/physics/.+')
        result=hltkeyForRun(session,c,runnumber)
        print 'runnumber hltkey'
        for runnum,hltkey in result.items():
            if not args.collisiononly:
                print runnum,hltkey
            if args.collisiononly and re.match(p,hltkey):
                fillnum=fillnumForRun(session,c,runnumber)
                if len(fillnum)!=0:
                    print runnum,hltkey
    if args.action == 'l1key':
        p=re.compile(r'^TSC_.+_collisions_.+')
        result=l1keyForRun(session,c,runnumber)
        print 'runnumber tsc_key'
        for runnum,l1key in result.items():
            if not args.collisiononly:
                print runnum,l1key
            if args.collisiononly and re.match(p,l1key):
                fillnum=fillnumForRun(session,c,runnumber)
                if len(fillnum)!=0:
                    print runnum,l1key
    if args.action == 'fill':
        result=fillnumForRun(session,c,runnumber)
        print 'runnumber fill'
        if not args.collisiononly:
            print runnumber,result
        else:
            if len(result)!=0:
                print runnumber,result
    del session
    del svc
        
if __name__=='__main__':
    main()