dumpRunInfo Namespace Reference

Classes
class	constants

Functions
def	fillnumForRun (dbsession, c, runnum)
def	hltkeyForRun (dbsession, c, runnum)
def	l1keyForRun (dbsession, c, runnum)
def	main ()

Variables
	VERSION

Function Documentation

def dumpRunInfo.fillnumForRun	(		dbsession,
			c,
			runnum
	)

select string_value from cms_runinfo.runsession_parameter where runnumber=129265 and name='CMS.SCAL:FILLN' and rownum<=1;

Definition at line 18 of file dumpRunInfo.py.

References data, createfilelist.int, GetRecoTauVFromDQM_MC_cff.next, edm.print(), and str.

Referenced by main().

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 dumpRunInfo.hltkeyForRun	(		dbsession,
			c,
			runnum
	)

select runnumber,string_value from cms_runinfo.runsession_parameter where name=:runsessionparametername and runnumber=:runnum 

Definition at line 60 of file dumpRunInfo.py.

References data, createfilelist.int, GetRecoTauVFromDQM_MC_cff.next, edm.print(), and str.

Referenced by main().

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 dumpRunInfo.l1keyForRun	(		dbsession,
			c,
			runnum
	)

select runnumber,string_value from cms_runinfo.runsession_parameter where name=:runsessionparametername and runnumber=:runnum 

Definition at line 105 of file dumpRunInfo.py.

References data, createfilelist.int, GetRecoTauVFromDQM_MC_cff.next, edm.print(), and str.

Referenced by main().

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 dumpRunInfo.main

(

)

Definition at line 150 of file dumpRunInfo.py.

References fillnumForRun(), hltkeyForRun(), l1keyForRun(), and edm.print().

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
        

Variable Documentation

dumpRunInfo.VERSION

Definition at line 3 of file dumpRunInfo.py.