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 17 of file dumpRunInfo.py.

References data, createfilelist.int, GetRecoTauVFromDQM_MC_cff.next, 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 59 of file dumpRunInfo.py.

References data, createfilelist.int, GetRecoTauVFromDQM_MC_cff.next, 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 104 of file dumpRunInfo.py.

References data, createfilelist.int, GetRecoTauVFromDQM_MC_cff.next, 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 149 of file dumpRunInfo.py.

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

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 2 of file dumpRunInfo.py.