DataStoreClient

Module that holds the DataStore Client class

class DIRAC.AccountingSystem.Client.DataStoreClient.DataStoreClient(retryGraceTime=0, **kwargs)

Bases: DIRAC.Core.Base.Client.Client

Class providing front end access to DIRAC Accounting DataStore Service

  • It allows to reduce the interactions with the server by building and list of

pending Registers to be sent that are sent in a bundle using the commit method.

  • In case the DataStore is down Registers are sent as DISET requests.

__init__(retryGraceTime=0, **kwargs)

Simple constructor

Params int retryGraceTime

the seconds to wait before sending records to the failover

addRegister(register)

Add a register to the list to be sent

Params BaseAccountingType register

the accounting record to send.

property call

To be removed once we’re sure self.call has been removed

Type

Deprecated

commit()

Send the registers in a bundle mode

commitRegisters(self, entriesList, **kwargs)

Add a record for a type

Automatically created for the service function export_commitRegisters()

Parameters

entriesList – entriesList

compactDB(self, **kwargs)

Compact the db by grouping buckets

Automatically created for the service function export_compactDB()

delayedCommit()

If needed start a timer that will run the commit later allowing to send more registers at once (reduces overheads).

deleteType(self, typeName, **kwargs)

Delete accounting type and ALL its contents. VERY DANGEROUS! (Only for all powerful admins) (Bow before me for I am admin! :)

Automatically created for the service function export_deleteType()

Parameters

typeName – typeName

disableFailover()
executeRPC(*parms, **kws)

This method extracts some parameters from kwargs that are used as parameter of the constructor or RPCClient. Unfortunately, only a few of all the available parameters of BaseClient are exposed.

Parameters

  • rpc – if an RPC client is passed, use that one

  • timeout – we can change the timeout on a per call bases. Default is self.timeout

  • url – We can specify which url to use

getClientKWArgs()

Returns a copy of the connection arguments

getRegisteredTypes(self, **kwargs)

Get a list of registered types (Only for all powerful admins) (Bow before me for I am admin! :)

Automatically created for the service function export_getRegisteredTypes()

getServer()

Getter for the server url. Useful ?

httpsClient

alias of DIRAC.Core.Tornado.Client.TornadoClient.TornadoClient

regenerateBuckets(self, typeName, **kwargs)

Recalculate buckets. (Only for all powerful admins) (Bow before me for I am admin! :)

Automatically created for the service function export_regenerateBuckets()

Parameters

typeName – typeName

registerType(self, typeName, definitionKeyFields, definitionAccountingFields, bucketsLength, **kwargs)

Register a new type. (Only for all powerful admins) (Bow before me for I am admin! :)

Automatically created for the service function export_registerType()

Parameters

  • typeName – typeName

  • definitionKeyFields – definitionKeyFields

  • definitionAccountingFields – definitionAccountingFields

  • bucketsLength – bucketsLength

remove(register)

Remove a Register from the Accounting DataStore

removeRegisters(self, entriesList, **kwargs)

Remove a record for a type

Automatically created for the service function export_removeRegisters()

Parameters

entriesList – entriesList

setBucketsLength(self, typeName, bucketsLength, **kwargs)

Change the buckets Length. (Only for all powerful admins) (Bow before me for I am admin! :)

Automatically created for the service function export_setBucketsLength()

Parameters

  • typeName – typeName

  • bucketsLength – bucketsLength

setServer(url)

Set the server URL used by default

Parameters

url – url of the service