TransferClient
This is for transfers what RPCClient is for RPC calls
- class DIRAC.Core.DISET.TransferClient.TransferClient(serviceName, **kwargs)
Bases:
BaseClient
- KW_DELEGATED_DN = 'delegatedDN'
- KW_DELEGATED_GROUP = 'delegatedGroup'
- KW_EXTRA_CREDENTIALS = 'extraCredentials'
- KW_IGNORE_GATEWAYS = 'ignoreGateways'
- KW_KEEP_ALIVE_LAPSE = 'keepAliveLapse'
- KW_PROXY_CHAIN = 'proxyChain'
- KW_PROXY_LOCATION = 'proxyLocation'
- KW_PROXY_STRING = 'proxyString'
- KW_SETUP = 'setup'
- KW_SKIP_CA_CHECK = 'skipCACheck'
- KW_TIMEOUT = 'timeout'
- KW_USE_CERTIFICATES = 'useCertificates'
- KW_VO = 'VO'
- VAL_EXTRA_CREDENTIALS_HOST = 'hosts'
- __init__(serviceName, **kwargs)
Constructor
- Parameters:
serviceName – URL of the service (proper uri or just System/Component)
useCertificates – If set to True, use the server certificate
extraCredentials
timeout – Timeout of the call (default 600 s)
setup – Specify the Setup
VO – Specify the VO
delegatedDN – Not clear what it can be used for.
delegatedGroup – Not clear what it can be used for.
ignoreGateways – Ignore the DIRAC Gatways settings
proxyLocation – Specify the location of the proxy
proxyString – Specify the proxy string
proxyChain – Specify the proxy chain
skipCACheck – Do not check the CA
keepAliveLapse – Duration for keepAliveLapse (heartbeat like)
- getDestinationService()
Return service destination
- Returns:
str
- getServiceName()
Return service name
- Returns:
str
- listBulk(bulkId, token='', compress=True)
List the contents of a bulk
- Parameters:
bulkId (any) – Identification of the bulk to list
token (string) – Token for the bulk
compress (boolean) – Enable compression for the bulk. By default its True
- Returns:
S_OK/S_ERROR
- receiveBulk(destDir, bulkId, token='', compress=True)
Receive a bulk of files from server
- Parameters:
destDir (list of ( string / file descriptor / file object )) – Files to receive from server
bulkId (any) – Identification of the files being received
token (string) – Token for the bulk
compress (boolean) – Enable compression for the bulk. By default its True
- Returns:
S_OK/S_ERROR
- receiveFile(filename, fileId, token='')
Receive a file from the server
- Parameters:
filename (string / file descriptor / file object) – File to receive from server
fileId (any) – Identification of the file being received
token (string) – Optional token for the file
- Returns:
S_OK/S_ERROR
- sendBulk(fileList, bulkId, token='', compress=True, bulkSize=-1, onthefly=True)
Send a bulk of files to server
- Parameters:
fileList (list of ( string / file descriptor / file object )) – Files to send to server
bulkId (any) – Identification of the files being sent
token (string) – Token for the bulk
compress (boolean) – Enable compression for the bulk. By default its True
bulkSize (integer) – Optional size of the bulk
- Returns:
S_OK/S_ERROR
- sendFile(filename, fileId, token='')
Send a file to server
- Parameters:
filename (string / file descriptor / file object) – File to send to server
fileId (any) – Identification of the file being sent
token (string) – Optional token for the file
- Returns:
S_OK/S_ERROR