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

def AlCaHLTBitMon_QueryRunRegistry.DBSquery	(	dataset,
		site,
		run
	)

file dbs

Definition at line 58 of file AlCaHLTBitMon_QueryRunRegistry.py.

References lineno(), and edm.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
 

def AlCaHLTBitMon_QueryRunRegistry.defineOptions ( )

Definition at line 123 of file AlCaHLTBitMon_QueryRunRegistry.py.

References edm.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
 
 

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)
 

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
 

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

Definition at line 185 of file AlCaHLTBitMon_QueryRunRegistry.py.

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

Referenced by extractData(), HcalTBWriter.extractEventInfo(), edm::EventSetup.getData(), and HcalTBSource.produce().

 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)
                   ###dbs file
                 if lumirun:
                     file = DBSquery(dataset,site,str(printObj(run,'NUMBER')))                    

def AlCaHLTBitMon_QueryRunRegistry.getElement	(	obj,
		name
	)

Definition at line 178 of file AlCaHLTBitMon_QueryRunRegistry.py.

Referenced by getData(), printObj(), DQMStore::IGetter.removeElement(), and CSCBaseElectronicsSim.simulate().

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

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
 

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
 

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

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

def AlCaHLTBitMon_QueryRunRegistry.printLumi	(	file,
		namefile
	)

lumiCalc

Definition at line 46 of file AlCaHLTBitMon_QueryRunRegistry.py.

References filesize1(), and edm.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
 

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)

def AlCaHLTBitMon_QueryRunRegistry.serverQuery	(	workspaceName,
		regexp
	)

Definition at line 160 of file AlCaHLTBitMon_QueryRunRegistry.py.

References lineno(), and edm.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
 
 #----------------------------------------------------
 