Functions
def	DBSquery (dataset, site, run)
	file dbs More...

def	defineOptions ()

def	extractData (mode, reg, dataset, site, options)

def	filesize1 (n)

def	getData (doc, options, dataset, site)

def	getElement (obj, name)

def	getRegExp (regexp)

def	getText (nodelist)

def	lineno ()

def	makecff (file_list, namefile)
	file cff data More...

def	printLumi (file, namefile)
	lumiCalc More...

def	printObj (obj, name)

def	serverQuery (workspaceName, regexp)

Variables
string	comp = "{}"

def	data = extractData(options.workspaceName,options.regexp,options.dataset,options.site,options)

int	DEBUG = 0
	DEBUG. More...

list	listaDBS2 = []

def	options = defineOptions()

string	string = ""

string	string2 = ""

dictionary	stringDBS = {}
	if DEBUG: print lineno(), file More...

Function Documentation

◆ DBSquery()

def AlCaHLTBitMon_QueryRunRegistry.DBSquery	(	dataset,
		site,
		run
	)

file dbs

Definition at line 58 of file AlCaHLTBitMon_QueryRunRegistry.py.

References lineno(), and print().

Referenced by getData().

 def DBSquery(dataset,site,run):
 
     url = "http://cmsdbsprod.cern.ch/cms_dbs_prod_global/servlet/DBSServlet"
     if DEBUG:
         print(lineno())
     args = {}
     args['url']     = url
     args['level']   = 'CRITICAL'
     if DEBUG:
         print(lineno())
     api = DBSAPI.dbsApi.DbsApi(args)
     if DEBUG:
         print(lineno())
     try:
         files = api.listFiles(path=dataset,tier_list =site,runNumber=run)
     except DbsApiException as ex:
         print("Caught API Exception %s: %s "  % (ex.getClassName(), ex.getErrorMessage() ))
         files = ""
         if ex.getErrorCode() not in (None, ""):
             print("DBS Exception Error Code: ", ex.getErrorCode())
     if DEBUG:
         print(lineno())
     return files
 

◆ defineOptions()

def AlCaHLTBitMon_QueryRunRegistry.defineOptions ( )

Definition at line 123 of file AlCaHLTBitMon_QueryRunRegistry.py.

References print().

 def defineOptions():
     parser = OptionParser()
     parser.add_option("-w", "--workspace",
                       dest="workspaceName",
                       default="GLOBAL",
                       help="define workspace: GLOBAL TRACKER ")
 
     parser.add_option("-r", "--regexp",
                       dest="regexp",
                       type="string",
                       default='groupName : LIKE %Collisions12% , runNumber : = 190000 ',
                       help=" \"{runNumber} >= 148127 and {runNumber} < 148128 \" ")
 
     parser.add_option("-d", "--datasetPath",
                       dest="dataset", \
                       default="/MinimumBias/Run2010A-TkAlMinBias-Dec22ReReco_v1/ALCARECO",
                       help="For example : --datasetPath /MinimumBias/Run2010A-TkAlMinBias-Dec22ReReco_v1/ALCARECO")
 
     parser.add_option("-s", "--site",
                       dest="site",
                       default="T2_CH_CAF",
                       help="For example : site T2_CH_CAF")                 
 
     parser.add_option("-i", "--info",
                       action="store_true",
                       dest="info",
                       default=False,
                       help="printout the column names on which it's possible to cut")
 
     (options, args) = parser.parse_args()
     if len(sys.argv) == 1:
         print("\nUsage: %s --help"%sys.argv[0])
         sys.exit(0)
 
     return options
 
 

◆ extractData()

def AlCaHLTBitMon_QueryRunRegistry.extractData	(	mode,
		reg,
		dataset,
		site,
		options
	)

Definition at line 273 of file AlCaHLTBitMon_QueryRunRegistry.py.

References getData(), and serverQuery().

 def extractData(mode,reg,dataset,site,options):
     doc = minidom.parseString(serverQuery(mode,reg))
     return getData(doc,options,dataset,site)
 

◆ filesize1()

def AlCaHLTBitMon_QueryRunRegistry.filesize1 ( n )

Definition at line 40 of file AlCaHLTBitMon_QueryRunRegistry.py.

Referenced by printLumi().

 def filesize1(n):    
     info = os.stat(n)
     sz = info[stat.ST_SIZE]
     return sz
 

◆ getData()

def AlCaHLTBitMon_QueryRunRegistry.getData	(	doc,
		options,
		dataset,
		site
	)

Definition at line 185 of file AlCaHLTBitMon_QueryRunRegistry.py.

References DBSquery(), getElement(), createfilelist.int, lineno(), print(), printObj(), FastTimerService_cff.range, and str.

Referenced by extractData().

 def getData(doc,options,dataset,site):
     if DEBUG:
         print(lineno(), 'getData')
     server = xmlrpclib.ServerProxy('http://cms-service-runregistry-api.web.cern.ch/cms-service-runregistry-api/xmlrpc')
     runs = getElement(doc,'RUN')
     txtLongData=""
     txtkey=""
     lista=[]
 
     sep="\t"
 
     for run in runs:
         txtrun=printObj(run,'NUMBER') + sep + printObj(run,'HLTKEY')
         txtLongData+= txtrun + sep + "\n" 
     for run in runs:
         test=printObj(run,'HLTKEY')
         if not (test in lista):
             lista.append(test)
 
         file2=open("lista_key.txt",'w')
         for pkey in range(len(lista)):
             pwkey = lista[pkey] +"\n"
             file2.write(pwkey)
             if DEBUG:
                 print(lineno(),  lista[pkey])
 
         file2.close()
 
     for i in range(len(lista)):
         if DEBUG:
             print(lineno(), lista[i])
         nameDBS=""
         nameDBS=str(i)+".data"
         name=""
         name=str(i)+".json"
         nameLumi=""
         nameLumi=str(i)+".lumi"
         file1 = open( name ,'w')
         listaDBS = []
         if DEBUG:
             print(lineno(), nameDBS)
         for run in runs:
             key=printObj(run,'HLTKEY')
             if (key == lista[i]):
                 print("running......", key)
                 if DEBUG:
                     print(lineno(), printObj(run,'NUMBER'))
                 txtruns = "{runNumber} >= " + printObj(run,'NUMBER') +  " and {runNumber} <= " + str(int(printObj(run,'NUMBER')))
                 txtriv = txtruns + " and {cmpDcsBPix} = 1  and {cmpDcsFPix} = 1 and {cmpDcsTibTid} = 1 and {cmpDcsTob} = 1 and {cmpDcsTecM} = 1 and {cmpDcsTecP} = 1"
                 lumirun = server.RunLumiSectionRangeTable.export('GLOBAL', 'json',txtriv)
                 if DEBUG:
                     print(lineno(), lumirun)
                   
                 if lumirun:
                     file = DBSquery(dataset,site,str(printObj(run,'NUMBER')))                    

◆ getElement()

def AlCaHLTBitMon_QueryRunRegistry.getElement	(	obj,
		name
	)

Definition at line 178 of file AlCaHLTBitMon_QueryRunRegistry.py.

Referenced by getData(), printObj(), and CSCBaseElectronicsSim.simulate().

 def getElement(obj,name):
     return obj.getElementsByTagName(name)
 

◆ getRegExp()

def AlCaHLTBitMon_QueryRunRegistry.getRegExp ( regexp )

Definition at line 277 of file AlCaHLTBitMon_QueryRunRegistry.py.

 def getRegExp(regexp):
     items = regexp.split(',') 
     dd = {}
     for item in items:
         key,value = item.split(':')
         dd[key.replace(' ','')] = value
     return dd
 
 
 #---------------------------------------------MAIN
 

◆ getText()

def AlCaHLTBitMon_QueryRunRegistry.getText ( nodelist )

Definition at line 171 of file AlCaHLTBitMon_QueryRunRegistry.py.

Referenced by printObj().

 def getText(nodelist):
     rc = ""
     for node in nodelist:
         if node.nodeType == node.TEXT_NODE:
             rc = rc + node.data
     return rc
 

◆ lineno()

def AlCaHLTBitMon_QueryRunRegistry.lineno ( )

Returns the current line number in our program.

Definition at line 35 of file AlCaHLTBitMon_QueryRunRegistry.py.

Referenced by DBSquery(), getData(), and serverQuery().

 def lineno():
     """Returns the current line number in our program."""
     return inspect.currentframe().f_back.f_lineno
 
 #size file

◆ makecff()

def AlCaHLTBitMon_QueryRunRegistry.makecff	(	file_list,
		namefile
	)

file cff data

Definition at line 83 of file AlCaHLTBitMon_QueryRunRegistry.py.

References str.

 def makecff(file_list,namefile):
     file1 = open(namefile ,'w')
     stringS  =           "process.maxEvents = cms.untracked.PSet( input = cms.untracked.int32(-1) )\n"
     stringS  = stringS + "readFiles = cms.untracked.vstring()\n"
     stringS  = stringS + "secFiles = cms.untracked.vstring()\n"
     stringS  = stringS + "\n"
     file1.write(stringS)
 
     filecount = 0
     extendOpen = 0
     for filename in file_list:
 
         if extendOpen == 0:
             stringS  = "readFiles.extend([\n"
             file1.write(stringS)
             extendOpen = 1
 
         stringS  =           "     '"
         stringS  = stringS + str(filename)
         stringS  = stringS + "',\n"
         file1.write(stringS)
         filecount = filecount + 1
         if filecount == 50:
             stringS  = "])\n\n"
             file1.write(stringS)
             filecount = 0
             extendOpen = 0
 
     if extendOpen == 1:
         stringS  =           "])\n\n"
         file1.write(stringS)
 
     stringS  =           "process.source = cms.Source(\"PoolSource\",\n"
     stringS  = stringS + "         fileNames = readFiles,\n"
     stringS  = stringS + "         secondaryFileNames = secFiles\n"
     stringS  = stringS + ")\n"
     file1.write(stringS)
     file1.close()
 
 

◆ printLumi()

def AlCaHLTBitMon_QueryRunRegistry.printLumi	(	file,
		namefile
	)

lumiCalc

Definition at line 46 of file AlCaHLTBitMon_QueryRunRegistry.py.

References filesize1(), ALPAKA_ACCELERATOR_NAMESPACE::caPixelDoublets.if(), and print().

 def printLumi(file,namefile):
     if(filesize1(file) != 0):
         string= "lumiCalc2.py -c frontier://LumiCalc/CMS_LUMI_PROD -i "
         string1= " --nowarning overview >"
         string2= string + file + string1 + namefile
         data = os.system(string2)
     else:
         data = ""
         print("0 lumi are not avaible")
     return data
 

◆ printObj()

def AlCaHLTBitMon_QueryRunRegistry.printObj	(	obj,
		name
	)

Definition at line 181 of file AlCaHLTBitMon_QueryRunRegistry.py.

References getElement(), and getText().

Referenced by getData().

 def printObj(obj,name):
     return getText(getElement(obj,name)[0].childNodes)

◆ serverQuery()

def AlCaHLTBitMon_QueryRunRegistry.serverQuery	(	workspaceName,
		regexp
	)

Definition at line 160 of file AlCaHLTBitMon_QueryRunRegistry.py.

References lineno(), and print().

Referenced by extractData().

 def serverQuery(workspaceName,regexp):
 
     # get handler to RR XML-RPC server
     server = xmlrpclib.ServerProxy('http://cms-service-runregistry-api.web.cern.ch/cms-service-runregistry-api/xmlrpc')
     if DEBUG:
         print(lineno(), regexp)
     data = server.RunDatasetTable.export(workspaceName,'xml_all' ,regexp)
     return data
 
 #----------------------------------------------------
 