New in version v6r20.
DIRAC DMS can be configured to make use of FTS3 servers in order to schedule and monitor efficient transfer of large amounts of data between SEs. Please see Multi Protocol for more details about the protocol used for transfers.
The transfers using FTS come from the RequestManagementSystem ( see Request Management System). It will receive the files to transfer, as well as the list of destinations. If no source is defined, it will choose one. The files will then be grouped together and submited as jobs to the fts servers. These jobs will be monitored, retried if needed, the new replicas will be registered, and the status of the files will be reported back to the RMS.
There are no direct submission possible to the FTS system, it has to go through the RMS.
This system is independent from the previous FTS system, and is totally incompatible with it. Both systems cannot run at the same time.
To go from the old one, you must wait until there are no more Scheduled requests in the RequestManagementSystem (RMS). For that, either you do not submit any transfer for a while (probably not possible), or you switch to transfers using the DataManager. Once you have processed all the Schedule request, you can enable the new FTS3 system.
One needs to install an FTS3DB, the FTS3Manager, and the FTS3Agent. Install the FTS3DB with dirac-install-db or directly on your mysql server and add the Database in the Configuration System:
dirac-admin-sysadmin-cli -H diracserver034.institute.tld > install service DataManagement FTS3Manager > install agent DataManagement FTS3Agent
22.214.171.124. Enable FTS transfers in the RMS
In order for the transfers to be submitted to the FTS system, the following options in the configuration section
Systems/RequestManagement/Agents/RequestExecutingAgent/OperationHandlers/ReplicateAndRegister/ need to be set:
FTSModemust be True
FTSBannedGroupsshould contain the list of groups for which you’d rather do direct transfers.
126.96.36.199. Operations configuration
DataManagement/FTSPlacement/FTS3/ServerPolicy: Policy to choose the FTS server see FTSServer policy.
DataManagement/FTSPlacement/FTS3/FTS3Plugin: Plugin to alter the behavior of the FTS3Agent
188.8.131.52. FTS servers definition
The servers to be used are defined in the
Resources/FTSEndpoints/FTS3 section. Example:
CERN-FTS3 = https://fts3.cern.ch:8446 RAL-FTS3 = https://lcgfts3.gridpp.rl.ac.uk:8446
The option name is just the server name as used internaly. Note that the port number has to be specified, and should correspond to the REST interface
This agent is in charge of performing and monitoring all the transfers. Note that this agent can be duplicated as many time as you wish.
FTS3Agent for configuration details.
There are two possible tasks that can be done with the FTS3 system: transferring and staging.
Each of these task is performed by a dedicated
FTS3Operation contain a list of
FTS3File is for a specific targetSE. The
FTS3Agent will take an
FTS3Operation, group the files following some criteria (see later) into
FTS3Jobs will then be submitted to the FTS3 servers to become real FTS3 jobs. These Jobs are regularly monitored by the
FTS3Agent. When all the
FTS3Files have reached a final status, the
FTS3Operation callback method is called. This callback method depends on the type of
Note that by default, the
FTS3Agent is meant to run without shifter proxy. It will however download the proxy of the user submitting the job in order to delegate it to FTS. This also means that it is not able to perform registration in the DFC, and relies on Operation callback for that.
The RMS will create one FTS3TransferOperation per RMS Operation, and one FTS3File per RMS File. This means that there can be several destination SEs, and potentially source SEs specified.
- The grouping into jobs is done following this logic:
Group by target SE
Group by source SE. If not specified, we take the active replicas as returned by the DataManager
Since there might be several possible source SEs, we need to pick one only. By default, the choice is random, but this can be changed (see FTS3Plugins)
Divide all that according to the maximum number of files we want per job
Once the FTS jobs have been executed, and all the operation is completed, the callback takes place. The callback consists in fetching the RMS request which submitted the FTS3Operation, update the status of the RMS files, and insert a Registration Operation. Note that since the multiple targets are grouped in a single RMS operation, failing to transfer one file to one destination will result in the failure of the Operation. However, there is one Registration operation per target, and hence correctly transferred files will be registered.
Still in development, not meant to be used
This operation is meant to perform BringOnline. The idea behind that is to replace, if deemed working, the whole StorageSystem of DIRAC.
The FTS server to which the job is sent is chose based on the policy. There are 3 possible policy:
Random: the default. makes a random choice
Failover: pick one, and stay on that one until it fails
Sequence: take them in turn, always change
The states for the
FTS objects are as follow:
ALL_STATES = [ "Active", # Default state until FTS has done everything "Processed", # Interactions with FTS done, but callback not done "Finished", # Everything was done "Canceled", # Canceled by the user "Failed", # I don't know yet ] FINAL_STATES = ["Finished", "Canceled", "Failed"] INIT_STATE = "Active"
# States from FTS doc https://fts3-docs.web.cern.ch/fts3-docs/docs/state_machine.html ALL_STATES = [ "Submitted", # Initial state of a job as soon it's dropped into the database "Ready", # One of the files within a job went to Ready state "Active", # One of the files within a job went to Active state "Finished", # All files Finished gracefully "Canceled", # Job canceled "Failed", # All files Failed "Finisheddirty", # Some files Failed "Staging", # One of the files within a job went to Staging state "Archiving", # From FTS: one of the files within a job went to Archiving state ] FINAL_STATES = ["Canceled", "Failed", "Finished", "Finisheddirty"] # This field is only used for optimizing sql queries (`in`` instead of `not in`) NON_FINAL_STATES = list(set(ALL_STATES) - set(FINAL_STATES)) INIT_STATE = "Submitted"
ALL_STATES = [ "New", # Nothing was attempted yet on this file "Submitted", # From FTS: Initial state of a file as soon it's dropped into the database "Ready", # From FTS: File is ready to become active "Active", # From FTS: File went active "Finished", # From FTS: File finished gracefully "Canceled", # From FTS: Canceled by the user "Staging", # From FTS: When staging of a file is requested "Failed", # From FTS: File failure "Defunct", # Totally fail, no more attempt will be made "Started", # From FTS: File transfer has started "Not_used", # From FTS: Transfer not being considered yet, waiting for another one (multihop) "Archiving", # From FTS: file not yet migrated to tape ] # These are the states that we consider final. # No new attempts will be done on our side for # FTS3Files reaching one of these # Note that Canceled is not final state, because # FTS fails some transfers as "Canceled" (gsiftp timeout) FINAL_STATES = ["Finished", "Defunct"] FTS_SUCCESS_STATES = ["Finished"] FTS_FAILED_STATES = ["Canceled", "Failed"] # These are the states that the fts servers consider final. # No new attempts will be done on their side, but we can # still retry. FTS_FINAL_STATES = FTS_SUCCESS_STATES + FTS_FAILED_STATES INIT_STATE = "New"
The status of the FTS3Jobs and FTSFiles are updated every time we monitor the matching job.
The FTS3Operation goes to
Processed when all the files are in a final state, and to
Finished when the callback has been called successfully
New in version v7r1p37: The
FTS3Plugin option allows one to specify a plugin to alter some default choices made by the FTS3 system. These choices concern:
the list of third party protocols used
the selection of a source storage element
the FTS activity used
The multihop strategy
This can be useful if you want to implement a matrix-like selection of protocols, or if some links require specific protocols, etc. The plugins must be placed in
DIRAC.DataManagementSystem.private.FTS3Plugins. The default behaviors, as well as the documentation on how to implement your own plugin can be found in
New in version v7r3p21.
Experimental feature with drawbacks, see below
In the 2020s, the grid world made a leap forward as hardly ever before. In order to make the best use of all the years of experience in manipulating common protocols and fully using the dedicated network to interconnect all sites and storages, WLCG blessed the following ThirdPartyCopy strategy for the years to come:
incompatible protocols between storages are okay
storages not reachable from other site storages are okay
They named this strategy MultiHop ™. It consists of turning a transfer
A -> B into
A -> I1 -> I2 -> ... -> In -> B.
DIRAC supports one intermediate hop (note: not that it would be very hard to implement any number, but having to implement that feature to transfer between two WLCG sites is already afflicting enough, so let’s not overdo it). The choice of the intermediate SE is done in the FTS3Plugin, so feel free to customize it (see above).
The configuration of multihop is done in the form of a
[source][destination] matrix in
Operations/<vo/setup>/DataManagement/MultiHopMatrixOfShame. You can:
Use specific SE Names
Defaultas a any other catch all
disabledas a value to disable multihop for a given route
More details on how the intermediate SE selection is done and how the matrix is defined are available in
If you initiate transfer from A to C that has to go via B but the file is already at B (and registered in the FileCatalog), the multihop will not know about it (with all the danger that comes with this). To avoid that, we recommend defining dedicated SE for intermediate hop
This creates dark data !! As of today, the intermediate file is not cleanup, neither by DIRAC nor by FTS. Work in FTS has a task to try and bring that feature in. A future solution may come from DIRAC. In the meantime, the best solution is to ask the site to either cleanup themselves (some storages like EOS have that built in) or to give you a dump of the namespace, and then do the cleaning yourself.