DataIntegrityHandler

mod

DataIntegrityHandler

class DIRAC.DataManagementSystem.Service.DataIntegrityHandler.DataIntegrityHandler(handlerInitDict, trid)

Bases: RequestHandler

class DataIntegrityHandler

Implementation of the Data Integrity service in the DISET framework.

__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_changeProblematicPrognosis(fileID, newPrognosis)

Change the prognosis for the supplied file

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

Get a list of the distinct prognosis from the IntegrityDB

export_getProblematic()

Get the next problematic to resolve from the IntegrityDB

export_getProblematicsSummary()

Get a summary from the Problematics table from the IntegrityDB

export_getPrognosisProblematics(prognosis)

Get problematic files from the problematics table of the IntegrityDB

export_getTransformationProblematics(transID)

Get the problematics for a given transformation

export_incrementProblematicRetry(fileID)

Update the retry count for supplied file ID.

export_insertProblematic(source, fileMetadata)

Insert problematic files into the problematics table of the IntegrityDB

export_ping()

static export_refreshConfiguration(fromMaster)

Force refreshing the configuration data

Parameters

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

export_removeProblematic(fileID)

Remove the file with the supplied FileID from the database

export_setProblematicStatus(fileID, status)

Update the status of the problematics with the provided fileID

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)

classmethod initializeHandler(serviceInfoDict)

Initialization of DB object

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)

types_changeProblematicPrognosis = []

types_echo = [(<class 'str'>,)]

types_getDistinctPrognosis = []

types_getProblematic = []

types_getProblematicsSummary = []

types_getPrognosisProblematics = [[<class 'str'>]]

types_getTransformationProblematics = [[<class 'int'>]]

types_incrementProblematicRetry = [[<class 'int'>]]

types_insertProblematic = [[<class 'str'>], <class 'dict'>]

types_ping = []

types_refreshConfiguration = [<class 'bool'>]

types_removeProblematic = [[<class 'int'>, <class 'list'>]]

types_setProblematicStatus = [[<class 'int'>], [<class 'str'>]]

types_whoami = []