CpEfdClient

class lsst.cp.pipe.CpEfdClient(efdInstance='usdf_efd', dieOnSearch=False, log=None)

Bases: object

An EFD client to retrieve calibration results.

Parameters

efdInstancestr, optional

EFD instance name to connect to.

loglogging.Logger, optional

Log to write messages to.

Methods Summary

checkConnection()	Check the connection to the EFD.
getEfdElectrometerData([dataSeries, ...])	Retrieve Electrometer data from the EFD.
getEfdMonochromatorData([dataSeries, ...])	Retrieve Monochromator data from the EFD.
getSchemaDtype(topicName)	Get datatypes for a topic.
parseElectrometerStatus(data, dateStr[, ...])	Determine electrometer status for a specific date.
parseMonochromatorStatus(data, dateStr)	Determine monochromator status for a specific date.
query(query)	Execute an EFD query.
rewriteElectrometerStatus(inResults)	Rewrite intermediate electrometer data extracted from the EFD logEvents.
searchResults(data, dateStr)	Find the row entry in data immediately preceding the specified date.
selectTimeSeries(topicName[, fields, ...])	Query a topic for a time series.

Methods Documentation

checkConnection()

Check the connection to the EFD.

Raises

RuntimeError :

Raised if the connection check fails.

getEfdElectrometerData(dataSeries=None, dateMin=None, dateMax=None)

Retrieve Electrometer data from the EFD.

Parameters

dataSeriesstr, optional

Data series to request from the EFD.

dateMinstr, optional

Minimum date (in TAI) to retrieve from EFD.

dateMaxstr, optional

Maximum date (in TAI) to retrieve from EFD.

Returns

resultsastropy.table.Table

The table of results returned from the EFD.

getEfdMonochromatorData(dataSeries=None, dateMin=None, dateMax=None)

Retrieve Monochromator data from the EFD.

Parameters

dataSeriesstr, optional

Data series to request from the EFD.

dateMinstr, optional

Minimum date (in TAI) to retrieve from EFD.

dateMaxstr, optional

Maximum date (in TAI) to retrieve from EFD.

Returns

resultsastropy.table.Table

The table of results returned from the EFD.

getSchemaDtype(topicName)

Get datatypes for a topic.

Parameters

topicNamestr

Topic to get datatypes for

Returns

datatypeslist [tuple [str, str]]

List of tuples of field names and data types.

parseElectrometerStatus(data, dateStr, dateEnd=None, doIntegrateSamples=False, index=201)

Determine electrometer status for a specific date.

Parameters

dataastropy.table.Table

The dataframe of electrometer results from the EFD.

dateStrstr

The date (in TAI) to look up in the status for.

dateEndstr

The end date (in TAI) to look in the status for.

doIntegrateSamples: bool

If true, take the average of all samples between dateStr and dateEnd.

indexint

The salIndex of the device we want to read. For LATISS, this should be 201. For the main telescope, 101.

Returns

indexDatestr

Date string (in TAI) indicating the electrometer state change.

intensity: float

Average electrometer intensity.

parseMonochromatorStatus(data, dateStr)

Determine monochromator status for a specific date.

Parameters

dataastropy.table.Table

The dataframe of monochromator results from the EFD.

dateStrstr

The date (in TAI) to look up in the status for.

Returns

indexDatestr

Date string (in TAI) indicating the monochromator state change.

wavelengthfloat

Monochromator commanded peak.

query(query)

Execute an EFD query.

Parameters

querystr

Query to run.

Returns

resultsdict

Dictionary of results returned.

Raises

RuntimeError :

Raised if the the database could not be read from.

rewriteElectrometerStatus(inResults)

Rewrite intermediate electrometer data extracted from the EFD logEvents.

Parameters

inResultsastropy.table.Table

The table of results returned from the EFD.

Returns

outResultsastropy.table.Table

The rewritten table containing only electrometer summary status events.

searchResults(data, dateStr)

Find the row entry in data immediately preceding the specified date.

Parameters

dataastropy.table.Table

The table of results from the EFD.

dateStrstr

The date (in TAI) to look up in the status for.

Returns

result = astropy.table.Row

The row of the data table corresponding to dateStr.

selectTimeSeries(topicName, fields=[], startDate=None, endDate=None)

Query a topic for a time series.

Parameters

topicNamestr

Database “topic” to query.

fieldslist, optional

List of fields to return. If empty, all fields are returned.

startDateastropy.time.Time, optional

Start date to limit the results returned.

endDateastropy.time.Time, optional

End date to limit the results returned.

Returns

tableastropy.table.Table

A table containing the fields requested, with each row corresponding to one date (available in the "time" column).