DPM Control¶

Interface for application control. It has a similar role as stdif but limited to operations supported by daqDpmServer.

Note

This interface is reserved for daqOcmServer and is not meant to be used by end-users.

daqDpmServer hosts the interface daqif.DpmControl under URI path /dpm.

class daqif.DpmControl¶

DPM control interface for non-DAQ related commands.

QueryStorageStatus() → StorageStatus ¶

Queries disk space usage and availability on the file system used by daqDpmServer workspace.

Exit() → str¶

Terminates application in a controlled manner.

Note

Reply is sent before application terminates, but there is no guaranteed delivery.

DPM Data Acquisition Control¶

Interface for Data Acquisition control.

Note

This interface is reserved for daqOcmServer and is not meant to be used by end-users.

daqDpmServer hosts the interface daqif.DpmDaqControl under URI path /daq.

class daqif.DpmDaqControl¶

DPM control interface for initiating, monitoring and controlling Data Product creation life-cycle of Data Acquisitions.

QueueDaq(specification) → DaqReply ¶

Add Data Acquisition to queue for merging.

Parameters: specification (str) – JSON encoded string following schema in Data Product Specification specifying how to create the Data Product.
Return type: DaqReply
Raises: DaqException – On fatal error.

AbortDaq(id) → DaqReply ¶

Aborts merging.

Fail-fast

If any error occur DaqException is thrown and the DAQ state remains in Aborting.

GetDaqStatus(id) → DaqStatus ¶

Query Data Acquisition status. If no Data Acquisition has previously been queued with QueueDaq() or is archived (in a completed state) an exceptional reply is returned.

GetActiveDaqs() → List[DaqStatus]¶