DataStoreClient

Module that holds the DataStore Client class

class DIRAC.AccountingSystem.Client.DataStoreClient.DataStoreClient(setup=False, retryGraceTime=0)

Bases: object

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__(setup=False, retryGraceTime=0)

x.__init__(…) initializes x; see help(type(x)) for signature

addRegister(register)

Add a register to the list to be sent

commit()

Send the registers in a bundle mode

delayedCommit()

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

disableFailover()
ping()

Ping the DataStore service

remove(register)

Remove a Register from the Accounting DataStore

setRetryGraceTime(retryGraceTime)

Set Timeout to send failing records to Failover if enabled