Public Member Functions
def	__init__ (self, url, debug=False)

def	columns (self, workspace, table)

def	count (self, workspace, table, filter=None, query=None, tag=None)

def	data (self, workspace, table, template, columns=None, filter=None, query=None, order=None, tag=None)

def	dprint (self, args)

def	get (self, parts, data=None)

def	report (self, workspace, report)

def	reports (self, workspace)

def	tables (self, workspace)

def	tags (self)

def	templates (self, workspace, table)

def	workspaces (self)

Public Attributes
	app

	debug

	url

Detailed Description

RR API object

Definition at line 46 of file rrapi.py.

Constructor & Destructor Documentation

def rrapi.RRApi.__init__	(	self,
		url,
		debug = `False`
	)

Construct API object.
url: URL to RRv3 API, i.e. http://localhost:8080/rr_user
debug: should debug messages be printed out? Verbose!

Definition at line 51 of file rrapi.py.

     def __init__(self, url, debug = False):
         """
         Construct API object.
         url: URL to RRv3 API, i.e. http://localhost:8080/rr_user
         debug: should debug messages be printed out? Verbose!
         """
         self.debug = debug
         self.url = re.sub("/*$", "/api/", url)
         self.app = self.get(["app"])
         self.dprint("app = ", self.app)
 

Member Function Documentation

def rrapi.RRApi.columns	(	self,
		workspace,
		table
	)

Get columns for table for workspace (all apps)

Definition at line 139 of file rrapi.py.

     def columns(self, workspace, table):
         """
         Get columns for table for workspace (all apps)
         """
         return self.get([workspace, table, "columns"])
 

def rrapi.RRApi.count	(	self,
		workspace,
		table,
		filter = `None`,
		query = `None`,
		tag = `None`
	)

Get number of rows for table for workspace with filter, query (all apps) or tag (USER app only)

Definition at line 151 of file rrapi.py.

     def count(self, workspace, table, filter = None, query = None, tag = None):
         """
         Get number of rows for table for workspace with filter, query (all apps) or tag (USER app only)
         """
 
         #
         # Constructing request path
         #
 
         req = [ workspace, table ]
         if tag != None:
             if self.app != "user":
                 raise RRApiError("Tags are possible only in user app")
             else:
                 req.append(tag)
         req.append("count")
 
         #
         # Constructing filter/query payload
         #
 
         filters = {}
         if filter != None:
             filters['filter'] = filter
         if query != None:
             filters['query'] = query
 
         return int(self.get(req, filters))
 

def rrapi.RRApi.data	(	self,
		workspace,
		table,
		template,
		columns = `None`,
		filter = `None`,
		query = `None`,
		order = `None`,
		tag = `None`
	)

Get data for table for workspace with filter, query (all apps) or tag (USER app only)

Definition at line 180 of file rrapi.py.

     def data(self, workspace, table, template, columns = None, filter = None, query = None, order = None, tag = None):
         """
         Get data for table for workspace with filter, query (all apps) or tag (USER app only)
         """
 
         #
         # Check req parameters
         #
 
         if type(workspace) != str:
             raise RRApiError("workspace parameter must be str")
 
         #
         # Constructing request path
         #
 
         req = [ workspace, table, template ]
         if columns != None:
             req.append(",".join(columns))
         else:
             req.append("all")
         if order != None:
             req.append(",".join(order))
         else:
             req.append("none")
         if tag != None:
             if self.app != "user":
                 raise RRApiError("Tags are possible only in user app")
             else:
                 req.append(tag)
         req.append("data")
 
         #
         # Constructing filter/query payload
         #
 
         filters = {}
         if filter != None:
             filters['filter'] = filter
         if query != None:
             filters['query'] = query
 
         return self.get(req, filters)
 

def rrapi.RRApi.dprint	(	self,
		args
	)

Print debug information

Definition at line 62 of file rrapi.py.

References DTDigiToRawModule.debug, CSCRPCData.debug, CSCDCCUnpacker.debug, CSCTMBScope.debug, ALIUtils.debug, DTDigiToRaw.debug, EgammaProbeSelector.debug, HiggsToZZ4LeptonsSkimEff.debug, DTTTrigCorrectionFirst.debug, HiggsTo2GammaSkim.debug, HiggsToZZ4LeptonsPreFilter.debug, DTSegmentsTask.debug, pkg.AbstractPkg.debug, HiggsToZZ4LeptonsSkim.debug, DTTPDeadWriter.debug, CSCDCCEventData.debug, IsolatedParticlesGeneratedJets.debug, DTTTrigWriter.debug, SiPixelDigiToRaw.debug, SiPixelRawToDigi.debug, DTDDUUnpacker.debug, DTT0Calibration.debug, DTT0CalibrationNew.debug, DTOccupancyPoint.debug, util.rrapi.RRApi.debug, rrapi.RRApi.debug, DTNoiseComputation.debug, DTROS25Unpacker.debug, HeavyChHiggsToTauNuSkim.debug, DTTTrigSyncT0Only.debug, DTTTrigCalibration.debug, DTEfficiencyTask.debug, CSCDDUEventData.debug, DTRunConditionVar.debug, HCALResponse.debug, DTChamberEfficiencyTask.debug, DTTMax.debug, DTChamberEfficiency.debug, CSCCLCTData.debug, PythiaFilterEMJetHeep.debug, DTVDriftCalibration.debug, PixelDataFormatter.debug, DTTTrigSyncFromDB.debug, CSCTMBData.debug, DTTTrigSyncTOFCorr.debug, BaseParticlePropagator.debug, RPCEfficiency.debug, CSCEventData.debug, CSCTMBHeader.debug, CSCALCTTrailer.debug, CSCALCTHeader.debug, and HltDiff.debug.

Referenced by rrapi.RRApi.get().

     def dprint(self, *args):
         """
         Print debug information
         """
         if self.debug: 
             print "RRAPI:",
             for arg in args:
                 print arg, 
             print
 

def rrapi.RRApi.get	(	self,
		parts,
		data = `None`
	)

General API call (do not use it directly!)

Definition at line 72 of file rrapi.py.

References DTDigiToRawModule.debug, CSCRPCData.debug, CSCDCCUnpacker.debug, ALIUtils.debug, CSCTMBScope.debug, DTDigiToRaw.debug, EgammaProbeSelector.debug, HiggsToZZ4LeptonsSkimEff.debug, DTTTrigCorrectionFirst.debug, HiggsTo2GammaSkim.debug, HiggsToZZ4LeptonsPreFilter.debug, DTSegmentsTask.debug, pkg.AbstractPkg.debug, HiggsToZZ4LeptonsSkim.debug, CSCDCCEventData.debug, IsolatedParticlesGeneratedJets.debug, DTTPDeadWriter.debug, DTTTrigWriter.debug, SiPixelRawToDigi.debug, SiPixelDigiToRaw.debug, DTDDUUnpacker.debug, DTT0Calibration.debug, DTT0CalibrationNew.debug, DTOccupancyPoint.debug, rrapi.RRApi.debug, util.rrapi.RRApi.debug, DTNoiseComputation.debug, DTROS25Unpacker.debug, HeavyChHiggsToTauNuSkim.debug, DTTTrigSyncT0Only.debug, DTTTrigCalibration.debug, DTEfficiencyTask.debug, CSCDDUEventData.debug, DTRunConditionVar.debug, HCALResponse.debug, DTChamberEfficiencyTask.debug, DTTMax.debug, DTChamberEfficiency.debug, CSCCLCTData.debug, DTVDriftCalibration.debug, PythiaFilterEMJetHeep.debug, PixelDataFormatter.debug, DTTTrigSyncFromDB.debug, CSCTMBData.debug, DTTTrigSyncTOFCorr.debug, BaseParticlePropagator.debug, RPCEfficiency.debug, CSCEventData.debug, CSCTMBHeader.debug, CSCALCTTrailer.debug, CSCALCTHeader.debug, HltDiff.debug, dir, rrapi.RRApi.dprint(), util.rrapi.RRApi.dprint(), join(), split, harvestTrackValidationPlots.str, util.rrapi.RRApiError.url, rrapi.RRApiError.url, LumiList.LumiList.url, util.rrapi.RRApi.url, and rrapi.RRApi.url.

Referenced by Options.Options.__getitem__(), betterConfigParser.BetterConfigParser.__updateDict(), rrapi.RRApi.columns(), rrapi.RRApi.count(), rrapi.RRApi.data(), betterConfigParser.BetterConfigParser.getCompares(), betterConfigParser.BetterConfigParser.getGeneral(), betterConfigParser.BetterConfigParser.getResultingSection(), rrapi.RRApi.report(), rrapi.RRApi.reports(), rrapi.RRApi.tables(), rrapi.RRApi.tags(), rrapi.RRApi.templates(), and rrapi.RRApi.workspaces().

     def get(self, parts, data = None):
         """
         General API call (do not use it directly!)
         """
 
         #
         # Constructing request path
         #
 
         callurl = self.url + "/".join(urllib.quote(p) for p in parts)
 
         #
         # Constructing data payload
         #
 
         sdata = None
         if data != None:
             sdata = json.dumps(data)
 
         #
         # Do the query and respond
         #
 
         self.dprint(callurl, "with payload", sdata)
 
         resp = urllib.urlopen(callurl, sdata)
 
         has_getcode = "getcode" in dir(resp)
         if self.debug: 
             if has_getcode:
                 self.dprint("Response", resp.getcode(), " ".join(str(resp.info()).split("\r\n")))
             else:
                 self.dprint("Response", " ".join(str(resp.info()).split("\r\n")))
 
         if not has_getcode or resp.getcode() == 200:
             rdata = resp.read()
             if re.search("json", resp.info().gettype()):
                 try:
                     return json.loads(rdata)
                 except TypeError as e:
                     self.dprint(e)
                     return rdata
             else:
                 return rdata
         else:
             raise RRApiError(resp)
 

def rrapi.RRApi.report	(	self,
		workspace,
		report
	)

Get report data (USER app only)

Definition at line 232 of file rrapi.py.

     def report(self, workspace, report):
         """
         Get report data (USER app only)
         """
         if self.app != "user":
             raise RRApiError("Reports available only in user app")
         return self.get([workspace, report, "data"])
 
 

def rrapi.RRApi.reports	(	self,
		workspace
	)

Get available reports (USER app only)

Definition at line 224 of file rrapi.py.

     def reports(self, workspace):
         """
         Get available reports (USER app only)
         """
         if self.app != "user":
             raise RRApiError("Reports available only in user app")
         return self.get([workspace, "reports"])
     

def rrapi.RRApi.tables	(	self,
		workspace
	)

Get tables for workspace (all apps)

Definition at line 133 of file rrapi.py.

     def tables(self, workspace):
         """
         Get tables for workspace (all apps)
         """
         return self.get([workspace, "tables"])
 

def rrapi.RRApi.tags ( self )

Get version tags (USER app only)

Definition at line 119 of file rrapi.py.

     def tags(self):
         """
         Get version tags (USER app only)
         """
         if self.app != "user":
             raise RRApiError("Tags call is possible only in user app")
         return self.get(["tags"])
 

def rrapi.RRApi.templates	(	self,
		workspace,
		table
	)

Get output templates for table for workspace (all apps)

Definition at line 145 of file rrapi.py.

     def templates(self, workspace, table):
         """
         Get output templates for table for workspace (all apps)
         """
         return self.get([workspace, table, "templates"])
 

def rrapi.RRApi.workspaces ( self )

Get workspaces (all apps)

Definition at line 127 of file rrapi.py.

     def workspaces(self):
         """
         Get workspaces (all apps)
         """
         return self.get(["workspaces"])
 

Member Data Documentation

rrapi.RRApi.app

Definition at line 59 of file rrapi.py.

Referenced by rrapi.RRApi.count(), rrapi.RRApi.data(), rrapi.RRApi.report(), rrapi.RRApi.reports(), and rrapi.RRApi.tags().

rrapi.RRApi.debug

Definition at line 57 of file rrapi.py.

Referenced by rrapi.RRApi.dprint(), and rrapi.RRApi.get().

rrapi.RRApi.url

Definition at line 58 of file rrapi.py.

Referenced by rrapi.RRApi.get().

Public Member Functions

Public Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation