SensitivityAnalyzer

class dias.analyzers.SensitivityAnalyzer(name, write_dir, state_dir)

Bases: dias.chime_analyzer.CHIMEAnalyzer

SensitivityAnalyzer.

Analyzer for telescope sensitivity.

DocLib 792 describes this analyzer and the associated theremin graph.

Attributes:

acq_suffix

archive_data_dir

correlator

cyl_start_char

cyl_start_num

data_size_max

include_auto

include_crosspol

include_intracyl

lag

log_level

nfreq_per_block

output_suffix

period

sep_cyl

start_time

state_size_max

Methods

Finder(self[, acqs])	Get a ch_util Finder object.
add_data_metric(self, name[, description, …])	Add a gauge metric.
add_task_metric(self, metric_name[, …])	Add a gauge metric.
delete_callback(self, deleted_files)	Tell the analyzer that files have been deleted after the task has run.
finish(self)	Close connection to data index database.
from_config(config, \*args, \*\*kwargs)	Create a new instance with values loaded from config.
get_baselines(self, indexmap, inputmap)	Return baseline indices for averaging.
get_cyl(self, cyl_num)	Return the cylinfer ID (char).
init_logger(self[, log_level_override])	Set up the logger.
read_config(self, config[, compare_keys, …])	Set all properties in this class from the supplied config.
refresh_data_index(self)	Remove expired rows from the data index database.
run(self)	Task stage: analyzes data from the last period.
setup(self)	Open connection to data index database.
update_data_index(self, start, stop[, filename])	Add row to data index database.

Construct the CHIME analyzer base class.

Parameters:

• name (String) – The name of the task.
• write_dir (String) – The path to write output data to.
• state_dir (String) – The path to write state data to.

Attributes:

acq_suffix

archive_data_dir

correlator

cyl_start_char

cyl_start_num

data_size_max

include_auto

include_crosspol

include_intracyl

lag

log_level

nfreq_per_block

output_suffix

period

sep_cyl

start_time

state_size_max

Methods

Finder(self[, acqs])	Get a ch_util Finder object.
add_data_metric(self, name[, description, …])	Add a gauge metric.
add_task_metric(self, metric_name[, …])	Add a gauge metric.
delete_callback(self, deleted_files)	Tell the analyzer that files have been deleted after the task has run.
finish(self)	Close connection to data index database.
from_config(config, \*args, \*\*kwargs)	Create a new instance with values loaded from config.
get_baselines(self, indexmap, inputmap)	Return baseline indices for averaging.
get_cyl(self, cyl_num)	Return the cylinfer ID (char).
init_logger(self[, log_level_override])	Set up the logger.
read_config(self, config[, compare_keys, …])	Set all properties in this class from the supplied config.
refresh_data_index(self)	Remove expired rows from the data index database.
run(self)	Task stage: analyzes data from the last period.
setup(self)	Open connection to data index database.
update_data_index(self, start, stop[, filename])	Add row to data index database.

Attributes Summary

acq_suffix
correlator
cyl_start_char
cyl_start_num
include_auto
include_crosspol
include_intracyl
lag
nfreq_per_block
output_suffix
sep_cyl

Methods Summary

finish(self)	Close connection to data index database.
get_baselines(self, indexmap, inputmap)	Return baseline indices for averaging.
get_cyl(self, cyl_num)	Return the cylinfer ID (char).
refresh_data_index(self)	Remove expired rows from the data index database.
run(self)	Task stage: analyzes data from the last period.
setup(self)	Open connection to data index database.
update_data_index(self, start, stop[, filename])	Add row to data index database.

Attributes Documentation

acq_suffix = None

correlator = None

cyl_start_char = None

cyl_start_num = None

include_auto = None

include_crosspol = None

include_intracyl = None

lag = None

nfreq_per_block = None

output_suffix = None

sep_cyl = None

Methods Documentation

finish(self)

Close connection to data index database.

get_baselines(self, indexmap, inputmap)

Return baseline indices for averaging.

get_cyl(self, cyl_num)

Return the cylinfer ID (char).

refresh_data_index(self)

Remove expired rows from the data index database.

Remove any rows of the data index database that correspond to files that have been cleaned (removed) by dias manager.

run(self)

Task stage: analyzes data from the last period.

setup(self)

Open connection to data index database.

Creates table if it does not exist. Further, it adds the data metric.

update_data_index(self, start, stop, filename=None)

Add row to data index database.

Update the data index database with a row that contains the name of the file and the span of time the file contains.

Parameters:

• start (unix time) – Earliest time contained in the file.
• stop (unix time) – Latest time contained in the file.
• filename (str) – Name of the file.