MonitoringHandler

Commits monitoring information using gServiceInterface singleton

class DIRAC.FrameworkSystem.Service.MonitoringHandler.MonitoringHandler(handlerInitDict, trid)

Bases: DIRAC.Core.DISET.RequestHandler.RequestHandler

This class is inherited from the RequestHandler class which is the base required for running any kind of services in DIRAC.

__init__(handlerInitDict, trid)

Constructor

Parameters

  • handlerInitDict (dictionary) – Information vars for the service

  • trid (object) – Transport to use

auth_ping = ['all']
auth_refreshConfiguration = ['CSAdministrator']
auth_whoami = ['all']
export_commitMarks(sourceId, activitiesDict, componentExtraInfo={})

Adds marks for activities

Parameters

  • sourceId (int) – component id

  • activitiesDict (dict) –

    the key is the metrice, the value is a dictionary with timestamp and value for example:

    {u'CPU': {1583244000: 10.6055594906},
 u'Iteration': {1583244420: 1,
                1583244480: 1,
                1583244540: 1,
                1583244600: 1,
                1583244660: 1},
 u'MEM': {1583244000: 49.03515625},
 u'Processed': {1583244420: 5,
                1583244480: 5,
                1583244540: 5,
                1583244600: 5,
                1583244660: 6}}

  • componentExtraInfo (dict) – extra information

export_deleteActivities(deletionList)

Deletes a list of activities

export_deleteActivity(sourceId, activityId)

Deletes an activity

export_deleteView(viewId)

Deletes a view

export_deleteViews(viewList)

Deletes a view

static export_echo(data)

This method is used for testing performance of the service

Parameters

data (str) – data to be sent back to the caller

Returns

S_OK, Value is the input data

export_getActivities()

Returns a list of defined activities

export_getActivitiesContents(selDict, sortList, start, limit)

Retrieve the contents of the activity db

export_getComponentsStatus(condDict)

Shows the status of the components.

export_getViews(onlyStatic=True)

Returns a list of stored views

export_ping()
export_plotView(viewRequest)

Generates plots for a view

export_queryField(field, definedFields)

Returns available values for a field., given a set of fields and values,

static export_refreshConfiguration(fromMaster)

Force refreshing the configuration data

Parameters

fromMaster (bool) – flag to refresh from the master configuration service

export_registerActivities(sourceDict, activitiesDict, componentExtraInfo={})

Registers new activities

export_saveView(viewName, viewDescriptionStub)

Saves a view

export_tryView(fromSecs, toSecs, viewDescriptionStub)

Generates plots based on a DEncoded view description

export_whoami()

A simple whoami, returns all credential dictionary, except certificate chain object.

classmethod getCSOption(optionName, defaultValue=False)

Get an option from the CS section of the services

Returns

Value for serviceSection/optionName in the CS being defaultValue the default

getRemoteAddress()

Get the address of the remote peer.

Returns

Address of remote peer.

getRemoteCredentials()

Get the credentials of the remote peer.

Returns

Credentials dictionary of remote peer.

initialize()

Initialize this instance of the handler (to be overwritten)

srv_disconnect(trid=None)
classmethod srv_disconnectClient(trid)
srv_getActionTuple()
classmethod srv_getCSOption(optionName, defaultValue=False)

Get an option from the CS section of the services

Returns

Value for serviceSection/optionName in the CS being defaultValue the default

srv_getClientSetup()
srv_getClientVO()
srv_getClientVersion()
srv_getFormattedRemoteCredentials()
classmethod srv_getMonitor()
srv_getRemoteAddress()

Get the address of the remote peer.

Returns

Address of remote peer.

srv_getRemoteCredentials()

Get the credentials of the remote peer.

Returns

Credentials dictionary of remote peer.

classmethod srv_getServiceName()
srv_getTransportID()
classmethod srv_getURL()
classmethod srv_msgCreate(msgName)
srv_msgReply(msgObj)
classmethod srv_msgSend(trid, msgObj)
transfer_bulkFromClient(bulkId, token, bulkSize, fileHelper)
transfer_bulkToClient(bulkId, token, fileHelper)
transfer_fromClient(fileId, token, fileSize, fileHelper)
transfer_listBulk(bulkId, token, fileHelper)
transfer_toClient(fileId, token, fileHelper)

Transfers files

types_commitMarks = [<class 'int'>, <class 'dict'>]
types_deleteActivities = [<class 'list'>]
types_deleteActivity = [<class 'int'>, <class 'int'>]
types_deleteView = [<class 'int'>]
types_deleteViews = [<class 'list'>]
types_echo = [(<class 'str'>,)]
types_getActivities = []
types_getActivitiesContents = [<class 'dict'>, (<class 'list'>, <class 'tuple'>), (<class 'int'>,), (<class 'int'>,)]
types_getComponentsStatus = [<class 'dict'>]
types_getViews = []
types_ping = []
types_plotView = [<class 'dict'>]
types_queryField = [(<class 'str'>,), <class 'dict'>]
types_refreshConfiguration = [<class 'bool'>]
types_registerActivities = [<class 'dict'>, <class 'dict'>]
types_saveView = [(<class 'str'>,), (<class 'str'>,)]
types_tryView = [<class 'int'>, <class 'int'>, (<class 'str'>,)]
types_whoami = []
DIRAC.FrameworkSystem.Service.MonitoringHandler.initializeMonitoringHandler(serviceInfo)