TelemetryStreamHandler

class lsst.ts.scheduler.telemetry_stream_handler.TelemetryStreamHandler(log, efd_name)

Bases: object

Handle telemetry stream.

Parameters:

• log (logging.Logger) – Logger class.

• efd_name (str) – Name of the efd instance to query telemetry from.

Attributes Summary

telemetry_stream_schema

Methods Summary

configure_telemetry_stream(telemetry_stream)	Configure telemetry streams.
get_fill_values_for(stream_name)	Return list of fill values for telemetry stream.
retrieve_telemetry(stream_name)	Retrieve telemetry for a given stream.

Attributes Documentation

telemetry_stream_schema

Methods Documentation

async configure_telemetry_stream(telemetry_stream)

Configure telemetry streams.

Parameters:

telemetry_stream (list of dict) – List of telemetry streams to parse.

Raises:

• ValidationError: – If one (or more) stream is invalid.

• RuntimeError: – If selected efd_table are not in the selected EFD instance. If selected efd_columns are not in the topic attributes.

Return type:

None

get_fill_values_for(stream_name)

Return list of fill values for telemetry stream.

Parameters:

stream_name (str) – Name of the telemetry stream to retrieve data from.

Returns:

Fill values.

Return type:

list of float

async retrieve_telemetry(stream_name)

Retrieve telemetry for a given stream.

Parameters:

stream_name (str) – Name of the telemetry stream to retrieve data from.

Returns:

telemetry_values – Telemetry value, one for each entry in telemetry_streams[stream_name]["efd_columns"].

Return type:

list of float

Raises:

RuntimeError: – If stream_name is not in the list of configured streams.