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
	comp

	data

	DEBUG
	DEBUG. More...

	listaDBS2

	options

	string

	string2

	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.

 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
  

References lineno(), and print().

Referenced by getData().

◆ defineOptions()

def AlCaHLTBitMon_QueryRunRegistry.defineOptions ( )

Definition at line 123 of file AlCaHLTBitMon_QueryRunRegistry.py.

 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
  
  

References print().

◆ extractData()

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

Definition at line 273 of file AlCaHLTBitMon_QueryRunRegistry.py.

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

References getData(), and serverQuery().

◆ filesize1()

def AlCaHLTBitMon_QueryRunRegistry.filesize1 ( n )

Definition at line 40 of file AlCaHLTBitMon_QueryRunRegistry.py.

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

Referenced by printLumi().

◆ getData()

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

Definition at line 185 of file AlCaHLTBitMon_QueryRunRegistry.py.

 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')))                    

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

Referenced by extractData().

◆ getElement()

def AlCaHLTBitMon_QueryRunRegistry.getElement	(	obj,
		name
	)

Definition at line 178 of file AlCaHLTBitMon_QueryRunRegistry.py.

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

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

◆ 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.

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

Referenced by printObj().

◆ lineno()

def AlCaHLTBitMon_QueryRunRegistry.lineno ( )

Returns the current line number in our program.

Definition at line 35 of file AlCaHLTBitMon_QueryRunRegistry.py.

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

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

◆ makecff()

def AlCaHLTBitMon_QueryRunRegistry.makecff	(	file_list,
		namefile
	)

file cff data

Definition at line 83 of file AlCaHLTBitMon_QueryRunRegistry.py.

 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()
  
  

References str.

◆ printLumi()

def AlCaHLTBitMon_QueryRunRegistry.printLumi	(	file,
		namefile
	)

lumiCalc

Definition at line 46 of file AlCaHLTBitMon_QueryRunRegistry.py.

 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
  

References filesize1(), and print().

◆ printObj()

def AlCaHLTBitMon_QueryRunRegistry.printObj	(	obj,
		name
	)

Definition at line 181 of file AlCaHLTBitMon_QueryRunRegistry.py.

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

References getElement(), and getText().

Referenced by getData().

◆ serverQuery()

def AlCaHLTBitMon_QueryRunRegistry.serverQuery	(	workspaceName,
		regexp
	)

Definition at line 160 of file AlCaHLTBitMon_QueryRunRegistry.py.

 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
  
 #----------------------------------------------------
  