Globus
Classes¶
GlobusRSEProtocol ¶
GlobusRSEProtocol(
protocol_attr, rse_settings, logger=logging.log
)
Implementing access to RSEs using the Globus service as a Rucio RSE protocol.
Initializes the object with information about the referred RSE.
| PARAMETER | DESCRIPTION |
|---|---|
props
|
Properties of the requested protocol
|
Functions¶
lfns2pfns ¶
lfns2pfns(lfns)
Returns a fully qualified PFN for the file referred by path.
| PARAMETER | DESCRIPTION |
|---|---|
path
|
The path to the file.
|
| RETURNS | DESCRIPTION |
|---|---|
|
Fully qualified PFN. |
_get_path ¶
_get_path(scope, name)
Transforms the logical file name into a PFN. Suitable for sites implementing the RUCIO naming convention. This implementation is only invoked if the RSE is deterministic.
| PARAMETER | DESCRIPTION |
|---|---|
scope
|
scope
|
name
|
filename
|
| RETURNS | DESCRIPTION |
|---|---|
|
RSE specific URI of the physical file |
parse_pfns ¶
parse_pfns(pfns)
Splits the given PFN into the parts known by the protocol. It is also checked if the provided protocol supports the given PFNs.
| PARAMETER | DESCRIPTION |
|---|---|
pfns
|
a list of a fully qualified PFNs
|
| RETURNS | DESCRIPTION |
|---|---|
|
dic with PFN as key and a dict with path and name as value |
| RAISES | DESCRIPTION |
|---|---|
RSEFileNameNotSupported
|
if the provided PFN doesn't match with the protocol settings |
exists ¶
exists(path)
Checks if the requested file is known by the referred RSE.
| PARAMETER | DESCRIPTION |
|---|---|
path
|
Physical file name
|
| RETURNS | DESCRIPTION |
|---|---|
|
True if the file exists, False if it doesn't |
| RAISES | DESCRIPTION |
|---|---|
SourceNotFound
|
if the source file was not found on the referred storage. |
list ¶
list(path)
Checks if the requested path is known by the referred RSE and returns a list of items
| PARAMETER | DESCRIPTION |
|---|---|
path
|
Physical file name
|
| RETURNS | DESCRIPTION |
|---|---|
|
List of items |
delete ¶
delete(path)
Deletes a file from the connected RSE.
| PARAMETER | DESCRIPTION |
|---|---|
path
|
path to the to be deleted file
|
| RAISES | DESCRIPTION |
|---|---|
ServiceUnavailable
|
if some generic error occurred in the library. |
SourceNotFound
|
if the source file was not found on the referred storage. |
bulk_delete ¶
bulk_delete(pfns)
Submits an async task to bulk delete files on globus endpoint.
| PARAMETER | DESCRIPTION |
|---|---|
pfns
|
list of pfns to delete
|
| RAISES | DESCRIPTION |
|---|---|
TransferAPIError
|
if unexpected response from the service. |
connect ¶
connect()
Establishes the actual connection to the referred RSE.
reaper2 daemon requires implementation of protocol.connect
close ¶
close()
Closes the connection to RSE.
reaper2 daemon requires implementation of protocol.close