util.getRunInfo Namespace Reference

Functions
def	dasQuery (queryString, entryTitle)
def	dasRunQueryToDict (querystring)
def	day (string)
def	daysAgo (n)
def	getFilesForRun (run, dataset)
def	getRunsForDate (date, minlumis=10)
def	getRunsNewer (run, minlumis=10, source='RunRegistry')
def	runGetDatasetsAvailable (run)
def	today ()

Function Documentation

dasQuery()

def util.getRunInfo.dasQuery	(		queryString,
			entryTitle
	)

Definition at line 74 of file getRunInfo.py.

def dasQuery(queryString, entryTitle) :
    dasinfo = das_client.get_data('https://cmsweb.cern.ch', queryString, 0, 0, False)
    if dasinfo['status'] != 'ok' :
        raise Exception('DAS query failed.\nQuery: %s\nDAS Status returned: %s' % (queryString, dasinfo['status']))
 
    if len(dasinfo['data']) > 0 :
        for entry in dasinfo['data'] :
            if entryTitle in entry and len(entry[entryTitle]) > 0 :
                yield entry[entryTitle][0]

References das_client.get_data().

Referenced by util.getRunInfo.dasRunQueryToDict(), util.getRunInfo.getFilesForRun(), and util.getRunInfo.runGetDatasetsAvailable().

dasRunQueryToDict()

def util.getRunInfo.dasRunQueryToDict

(

querystring

)

Definition at line 66 of file getRunInfo.py.

def dasRunQueryToDict(querystring) :
    runs = {}
    for runDict in dasQuery(querystring, 'run') :
        runNo = int(runDict['run_number'])
        runDict['date'] = datestring
        runs[runNo] = runDict
    return runs
 

References util.getRunInfo.dasQuery(), and createfilelist.int.

Referenced by util.getRunInfo.getRunsForDate(), and util.getRunInfo.getRunsNewer().

day()

def util.getRunInfo.day

(

string

)

Definition at line 11 of file getRunInfo.py.

def day(string) :
    return datetime.datetime.strptime(string, "%Y%m%d").date()
 

Referenced by RunDCSHVDat.fillTheMapByTime(), LMFRunIOV.getParameters(), LMFLmrSubIOV.getParameters(), CSCTFConfigOnlineProd.newObject(), RunSummaryRead.readData(), L1TriggerScalerRead.readData(), SiStripDetVOffBuilder.readLastValueFromFile(), and RPCFw.UTtoT().

daysAgo()

def util.getRunInfo.daysAgo

(

n

)

Definition at line 7 of file getRunInfo.py.

def daysAgo(n) :
    date = today()
    return date - datetime.timedelta(days=n)
 

References util.getRunInfo.today().

getFilesForRun()

def util.getRunInfo.getFilesForRun	(		run,
			dataset
	)

    run : int
    dataset : string dataset to find files in, e.g.
        /ExpressCosmics/Run2015A-Express-v1/FEVT
        /ExpressPhysics/Run2015A-Express-v1/FEVT

Definition at line 47 of file getRunInfo.py.

def getFilesForRun(run, dataset) :
    '''
        run : int
        dataset : string dataset to find files in, e.g.
            /ExpressCosmics/Run2015A-Express-v1/FEVT
            /ExpressPhysics/Run2015A-Express-v1/FEVT
    '''
    querystring = "file dataset={dataset} run={run}".format(dataset=dataset, run=run)
 
    files = []
    for fileDict in dasQuery(querystring, 'file') :
        # cmsRun will not like unicode
        files.append(fileDict['name'].encode('ascii','replace'))
 
    return files
 
 
# -------------------- DAS convert tools
 

References util.getRunInfo.dasQuery(), and alcaDQMUpload.encode().

getRunsForDate()

def util.getRunInfo.getRunsForDate	(		date,
			minlumis = 10
	)

    date: expected to be datetime.datetime object

Definition at line 14 of file getRunInfo.py.

def getRunsForDate(date, minlumis=10) :
    '''
        date: expected to be datetime.datetime object
    '''
    datestring = date.strftime('%Y%m%d')
    querystring = "run date={date} | grep run.nlumis>{minlumis}".format(date=datestring, minlumis=minlumis)
    return dasRunQueryToDict(querystring)
 

References util.getRunInfo.dasRunQueryToDict().

getRunsNewer()

def util.getRunInfo.getRunsNewer	(		run,
			minlumis = 10,
			source = 'RunRegistry'
	)

    run: run number int
    source: Either RunRegistry or DAS

Definition at line 22 of file getRunInfo.py.

def getRunsNewer(run, minlumis=10, source='RunRegistry') :
    '''
        run: run number int
        source: Either RunRegistry or DAS
    '''
    if source == 'RunRegistry' :
        return rrClient.getRunsNewer(run, minlumis)
    elif source == 'DAS' :
        querystring = "run | grep run.nlumis>{minlumis}, run.runnumber>{run}".format(run=run, minlumis=minlumis)
        return dasRunQueryToDict(querystring)
 

References util.getRunInfo.dasRunQueryToDict().

runGetDatasetsAvailable()

def util.getRunInfo.runGetDatasetsAvailable

(

run

)

    run : int
    Will return a list of datasets in DAS that have the run in them

Definition at line 33 of file getRunInfo.py.

def runGetDatasetsAvailable(run) :
    '''
        run : int
        Will return a list of datasets in DAS that have the run in them
    '''
    querystring = "dataset run={run}".format(run=run)
 
    datasets = []
    for datasetDict in dasQuery(querystring, 'dataset') :
        # cmsRun will not like unicode
        datasets.append(datasetDict['name'].encode('ascii','replace'))
 
    return datasets
 

References util.getRunInfo.dasQuery(), and alcaDQMUpload.encode().

today()

def util.getRunInfo.today

(

)

Definition at line 4 of file getRunInfo.py.

def today() :
    return datetime.datetime.now().date()
 

Referenced by util.getRunInfo.daysAgo().