pyicat_plus.client.interface.IcatClientInterface#

class pyicat_plus.client.interface.IcatClientInterface[source]#

Bases: object

add_files(dataset_id=None)[source]#

Add missing files to a dataset already ingested.

Parameters:

dataset_id (Optional[int]) – The ICAT dataset identifier.

disconnect()[source]#
property expire_datasets_on_close: bool#

A flag indicating whether the dataset expires when it is closed or if it is synchronized with the metadata catalog.

investigation_info(beamline, proposal, date=None, allow_open_ended=True, timeout=None)[source]#

Return the information of the experiment session corresponding to a beamline, proposal and date.

Parameters:

  • beamline (str) – The beamline name.

  • proposal (str) – The proposal name.

  • date (Union[datetime, date, None]) – The date of the proposal, current date by default.

  • allow_open_ended (bool) – If True, enable to select an unofficial experiment session.

  • timeout (Optional[float]) – Set a timeout for the ICAT request.

Return type:

Optional[dict]

Returns:

If found, return the proposal, beamline, e-logbbok url and data portal url of the experiment session.

investigation_info_string(beamline, proposal, date=None, allow_open_ended=True, timeout=None)[source]#

Return the experiment session information as a string.

Parameters:

  • beamline (str) – The beamline name.

  • proposal (str) – The proposal name.

  • date (Union[datetime, date, None]) – The date of the proposal, current date by default.

  • allow_open_ended (bool) – If True, enable to select an unofficial experiment session.

  • timeout (Optional[float]) – Set a timeout for the ICAT request.

Return type:

str

Returns:

If found, return the experiment session information from the metadata catalog as a string.

investigation_summary(beamline, proposal, date=None, allow_open_ended=True, timeout=None)[source]#

Return the experiment session information as a Tuple.

Parameters:

  • beamline (str) – The beamline name.

  • proposal (str) – The proposal name.

  • date (Union[datetime, date, None]) – The date of the proposal, current date by default.

  • allow_open_ended (bool) – If True, enable to select an unofficial experiment session.

  • timeout (Optional[float]) – Set a timeout for the ICAT request.

Return type:

List[Tuple]

Returns:

If found, return the experiment session information from the metadata catalog as a Tuple.

property reason_for_missing_information: str#

A string explaining why some information is missing in the metadata catalog.

registered_dataset_ids(beamline, proposal, date=None, allow_open_ended=True, timeout=None)[source]#

Return the dataset list of an experiment session.

Parameters:

  • beamline (str) – The beamline name of the proposal.

  • proposal (str) – The proposal name.

  • date (Union[datetime, date, None]) – The date of the proposal, current date by default.

  • allow_open_ended (bool) – If True, enable to select an unofficial experiment session.

  • timeout (Optional[float]) – Set a timeout for the ICAT request.

Return type:

Optional[List[DatasetId]]

Returns:

The list of datasets (name and path).

registered_datasets(beamline, proposal, date=None, allow_open_ended=True, timeout=None)[source]#

Return the dataset information list of an experiment session.

Parameters:

  • beamline (str) – The beamline name of the proposal.

  • proposal (str) – The proposal name.

  • date (Union[datetime, date, None]) – The date of the proposal, current date by default.

  • allow_open_ended (bool) – If True, enable to select an unofficial experiment session.

  • timeout (Optional[float]) – Set a timeout for the ICAT request.

Return type:

Optional[List[Dataset]]

Returns:

The list of datasets (name, path, ICAT identifier, and DatasetMetadata).

send_binary_data(data, mimetype=None, beamline=None, proposal=None, beamline_only=None, **payload)[source]#

Send an image in base64 format to the proposal or beamline e-logbook.

Parameters:

  • data (bytes) – The binary message content.

  • mimetype (Optional[str]) – {‘text/plain’, ‘text/html’}, optional.

  • beamline (Optional[str]) – The beamline name of the proposal or beamline e-logbook.

  • proposal (Optional[str]) – The proposal name of the e-logbook. Ignored if beamline_only is True.

  • beamline_only (Optional[bool]) – if True, the message will be stored in the beamline e-logbook.

  • payload – Additional payload for the e-logbook message. It can contain tags (list of strings or list of dictionaries), the machine, the software.

send_binary_file(filename, beamline=None, proposal=None, beamline_only=None, **payload)[source]#

Send the content of a file as a binary image to the proposal or beamline e-logbook.

Parameters:

  • filename (str) – The filename of the image to be sent.

  • beamline (Optional[str]) – The beamline name of the proposal or beamline e-logbook.

  • proposal (Optional[str]) – The proposal name of the e-logbook. Ignored if beamline_only is True.

  • beamline_only (Optional[bool]) – if True, the message will be stored in the beamline e-logbook.

  • payload – Additional payload for the e-logbook message. It can contain tags (list of strings or list of dictionaries), the machine, the software.

send_message(msg, msg_type=None, beamline=None, proposal=None, dataset=None, beamline_only=None, **payload)[source]#

Send a message to the proposal or beamline e-logbook.

Parameters:

  • msg (str) – The message content.

  • msg_type (Optional[str]) – {‘comment’, ‘debug’, ‘info’, ‘error’, ‘commandLine’}, optional.

  • beamline (Optional[str]) – The beamline name of the proposal or beamline e-logbook.

  • proposal (Optional[str]) – The proposal name of the e-logbook. Ignored if beamline_only is True.

  • dataset (Optional[str]) – The specific dataset name to link the message to.

  • beamline_only (Optional[bool]) – if True, the message will be stored in the beamline e-logbook.

  • editable – Used with the formatted field, to determine the category of message. Annotation characterizes editable and unformatted messages, while Notification charaterizes non-editable and formatted messages.

  • formatted – Used with the editable field, to determine the category of message. Annotation characterizes editable and unformatted messages, while Notification charaterizes non-editable and formatted messages.

  • mimetype – {‘text/plain’, ‘text/html’}, optional.

  • payload – Additional payload for the message. It can contain tags (list of strings or list of dictionaries), the machine, the software.

send_text_file(filename, beamline=None, proposal=None, dataset=None, beamline_only=None, **payload)[source]#

Send the content of a text file as a message to the proposal or beamline e-logbook.

Parameters:

  • filename (str) – The filename containing the message to be sent.

  • beamline (Optional[str]) – The beamline name of the proposal or beamline e-logbook.

  • proposal (Optional[str]) – The proposal name of the e-logbook. Ignored if beamline_only is True.

  • beamline_only (Optional[bool]) – if True, the message will be stored in the beamline e-logbook.

  • payload – Additional payload for the e-logbook message. It can contain tags (list of strings or list of dictionaries), the machine, the software.

  • dataset (Optional[str])

start_investigation(beamline=None, proposal=None, start_datetime=None, end_datetime=None)[source]#

Send a message to ActiveMQ to either synchronize the experiment session from the User Portal in ICAT or to create a test experiment session in ICAT.

Parameters:

  • beamline (Optional[str]) – The beamline name of the proposal.

  • proposal (Optional[str]) – The proposal name.

  • start_datetime – The start date of the experiment session, timezone local time. Current date time by default.

  • end_datetime – The end date of the experiment session, timezone local time.

store_dataset(beamline=None, proposal=None, dataset=None, path=None, metadata=None, store_filename=None)[source]#

Request icat to store raw dataset.

Parameters:

  • str (proposal) – beamline name like id01, id15a, bm18…

  • str – proposal name like in1169, blc14795, ihma429…

  • dataset (Optional[str]) – dataset name.

  • path (Optional[str]) – path to the raw dataset to store. Must be a folder.

  • metadata (Optional[dict]) – metadata to associate to the dataset. Must contains keys defined by the appropriate application definition from https://gitlab.esrf.fr/icat/hdf5-master-config/-/blob/88a975039694d5dba60e240b7bf46c22d34065a0/hdf5_cfg.xml.

  • store_filename (Optional[str]) – xml file with metadata to be stored.

  • beamline (Optional[str])

  • proposal (Optional[str])

  • dataset

  • path

  • metadata

  • store_filename

store_dataset_from_file(store_filename=None)[source]#

Send a message to ActiveMQ to store a dataset and the associated metadata from a xml file stored on the disk.

Parameters:

store_filename (Optional[str]) – The XML filename containing all dataset metadata.

store_processed_data(beamline=None, proposal=None, dataset=None, path=None, metadata=None, raw=(), store_filename=None)[source]#

Request icat to store a processed dataset.

Parameters:

  • str (proposal) – beamline name like id01, id15a, bm18…

  • str – proposal name like in1169, blc14795, ihma429…

  • dataset (Optional[str]) – dataset name like sample_XYZ.

  • path (Optional[str]) – path to the processed dataset to store. Can be a file or a folder.

  • metadata (Optional[dict]) – metadata to associate to the dataset. Must contains keys defined by the appropriate application definition from https://gitlab.esrf.fr/icat/hdf5-master-config/-/blob/88a975039694d5dba60e240b7bf46c22d34065a0/hdf5_cfg.xml.

  • raw (Sequence) – Path to the raw dataset(s). Expects to be path to ‘bliss dataset’ folder(s). See https://confluence.esrf.fr/display/BM02KW/File+structure for If processing rely on more than one dataset then all dataset folders must be provided.

  • store_filename (Optional[str]) – xml file with metadata to be stored.

  • beamline (Optional[str])

  • proposal (Optional[str])

  • dataset

  • path

  • metadata

  • raw

  • store_filename

update_archive_restore_status(dataset_id=None, type=None, level=StatusLevel.INFO, message=None)[source]#

Update the archiving or restore status of a dataset.

Parameters:

  • dataset_id (Optional[int]) – The ICAT dataset identifier.

  • type (Optional[StatusType]) – The type of the status, possible options are {‘archiving’, ‘restoration’}.

  • level (StatusLevel) – The level of the status message; possible options are {‘info’, ‘warning’, ‘error’}.

  • message (Optional[str]) – The optional status’ message.

update_metadata(proposal=None, beamline=None, dataset_paths=None, metadata_name=None, metadata_value=None)[source]#

Update or create datasets metadata.

Parameters:

  • proposal (Optional[str]) – The proposal name.

  • beamline (Optional[str]) – The beamline name of the proposal.

  • dataset_paths (Optional[str]) – Comma-separated list of the dataset locations.

  • metadata_name (Optional[str]) – The name of the metadata to update.

  • metadata_value (Optional[str]) – The new value of the metadata.