Index

_

_carry_forward() (in module swxsoc_reach.historical.process_orchestrator) _concatenate_chunk_files() (in module swxsoc_reach.net.udl) _count_records() (in module swxsoc_reach.historical.download_orchestrator) _day_window() (in module swxsoc_reach.historical.download_orchestrator) _decide_action() (in module swxsoc_reach.historical.download_orchestrator) _decide_process_action() (in module swxsoc_reach.historical.process_orchestrator) _expected_records() (in module swxsoc_reach.historical.download_orchestrator)

_fetch_and_spool_chunk() (in module swxsoc_reach.net.udl) _get_logical_file_id() (swxsoc_reach.util.schema.REACHDataSchema method) _get_logical_source() (swxsoc_reach.util.schema.REACHDataSchema method) _get_reach_version() (swxsoc_reach.util.schema.REACHDataSchema method) _match_csv_for_date() (in module swxsoc_reach.historical.process_orchestrator) _process_one_day() (in module swxsoc_reach.historical.process_orchestrator) _relocate_to_nested_layout() (in module swxsoc_reach.historical.process_orchestrator) _write_chunk_file() (in module swxsoc_reach.net.udl)

A

acquire() (swxsoc_reach.net.udl.AdaptiveRateController method) AdaptiveRateController (class in swxsoc_reach.net.udl) additive_increase (swxsoc_reach.historical.download_orchestrator.DownloadRunConfig attribute)

append_row() (swxsoc_reach.historical.telemetry.HistoricalTelemetry method) auth_token (swxsoc_reach.historical.download_orchestrator.DownloadRunConfig attribute) availability_pct (swxsoc_reach.historical.telemetry.TelemetryRow attribute)

B

build_reach_output_filename() (in module swxsoc_reach.net.udl)

build_swxdata() (in module swxsoc_reach.calibration.transform)

C

cdf_path (swxsoc_reach.historical.telemetry.TelemetryRow attribute) cdf_size_mb (swxsoc_reach.historical.telemetry.TelemetryRow attribute) chunk_date_utc (swxsoc_reach.historical.telemetry.TelemetryRow attribute) create_observation_array() (in module swxsoc_reach.calibration.transform)

create_reach_filename() (in module swxsoc_reach.util.util) create_sensor_array() (in module swxsoc_reach.calibration.transform) csv_path (swxsoc_reach.historical.telemetry.TelemetryRow attribute) csv_size_mb (swxsoc_reach.historical.telemetry.TelemetryRow attribute)

D

days_attempted (swxsoc_reach.historical.download_orchestrator.DownloadRunSummary attribute) (swxsoc_reach.historical.process_orchestrator.ProcessRunSummary attribute) days_downloaded (swxsoc_reach.historical.download_orchestrator.DownloadRunSummary attribute) days_failed (swxsoc_reach.historical.download_orchestrator.DownloadRunSummary attribute) (swxsoc_reach.historical.process_orchestrator.ProcessRunSummary attribute) days_planned (swxsoc_reach.historical.download_orchestrator.DownloadRunSummary attribute) (swxsoc_reach.historical.process_orchestrator.ProcessRunSummary attribute) days_processed (swxsoc_reach.historical.process_orchestrator.ProcessRunSummary attribute) days_skipped_existing (swxsoc_reach.historical.download_orchestrator.DownloadRunSummary attribute) (swxsoc_reach.historical.process_orchestrator.ProcessRunSummary attribute) days_skipped_no_data (swxsoc_reach.historical.download_orchestrator.DownloadRunSummary attribute) days_skipped_no_input (swxsoc_reach.historical.process_orchestrator.ProcessRunSummary attribute)

days_uploaded (swxsoc_reach.historical.process_orchestrator.ProcessRunSummary attribute) deduplicate_records() (in module swxsoc_reach.calibration.transform) descriptor (swxsoc_reach.historical.download_orchestrator.DownloadRunConfig attribute) (swxsoc_reach.historical.process_orchestrator.ProcessRunConfig attribute) (swxsoc_reach.historical.telemetry.TelemetryRow attribute) download_seconds (swxsoc_reach.historical.telemetry.TelemetryRow attribute) download_UDL_reach_to_file() (in module swxsoc_reach.net.udl) download_UDL_reach_window() (in module swxsoc_reach.net.udl) DownloadRunConfig (class in swxsoc_reach.historical.download_orchestrator) DownloadRunSummary (class in swxsoc_reach.historical.download_orchestrator) dry_run (swxsoc_reach.historical.download_orchestrator.DownloadRunConfig attribute) (swxsoc_reach.historical.process_orchestrator.ProcessRunConfig attribute)

E

end_date (swxsoc_reach.historical.download_orchestrator.DownloadRunConfig attribute) (swxsoc_reach.historical.process_orchestrator.ProcessRunConfig attribute) error_message (swxsoc_reach.historical.telemetry.TelemetryRow attribute)

error_type (swxsoc_reach.historical.telemetry.TelemetryRow attribute) expected_records (swxsoc_reach.historical.telemetry.TelemetryRow attribute) extract_sensor_metadata() (in module swxsoc_reach.calibration.transform)

F

fetch_reach_chunk() (in module swxsoc_reach.net.udl) finished_at_utc (swxsoc_reach.historical.telemetry.TelemetryRow attribute)

format_udl_timestamp() (in module swxsoc_reach.net.udl) from_dict() (swxsoc_reach.historical.telemetry.TelemetryRow class method)

G

get_reach_datetimelist() (in module swxsoc_reach.net.udl)

get_reach_urllist() (in module swxsoc_reach.net.udl)

H

HistoricalTelemetry (class in swxsoc_reach.historical.telemetry)

I

initial_rate (swxsoc_reach.historical.download_orchestrator.DownloadRunConfig attribute)

input_dir (swxsoc_reach.historical.process_orchestrator.ProcessRunConfig attribute) iter_rows() (swxsoc_reach.historical.telemetry.HistoricalTelemetry method)

L

limit_days (swxsoc_reach.historical.download_orchestrator.DownloadRunConfig attribute) (swxsoc_reach.historical.process_orchestrator.ProcessRunConfig attribute)

load_state() (swxsoc_reach.historical.telemetry.HistoricalTelemetry method)

M

max_concurrent_requests (swxsoc_reach.historical.download_orchestrator.DownloadRunConfig attribute) max_rate (swxsoc_reach.historical.download_orchestrator.DownloadRunConfig attribute) min_rate (swxsoc_reach.historical.download_orchestrator.DownloadRunConfig attribute) module swxsoc_reach swxsoc_reach.calibration.calibration swxsoc_reach.calibration.transform swxsoc_reach.historical.download_orchestrator swxsoc_reach.historical.process_orchestrator swxsoc_reach.historical.s3_upload swxsoc_reach.historical.telemetry swxsoc_reach.io.aws_db swxsoc_reach.io.file_tools swxsoc_reach.net.auth swxsoc_reach.net.udl swxsoc_reach.util.schema swxsoc_reach.util.util

multiplicative_decrease (swxsoc_reach.historical.download_orchestrator.DownloadRunConfig attribute)

O

output_dir (swxsoc_reach.historical.download_orchestrator.DownloadRunConfig attribute) (swxsoc_reach.historical.process_orchestrator.ProcessRunConfig attribute)

output_format (swxsoc_reach.historical.download_orchestrator.DownloadRunConfig attribute) (swxsoc_reach.historical.process_orchestrator.ProcessRunConfig attribute) (swxsoc_reach.historical.telemetry.TelemetryRow attribute)

P

parse_science_filename() (in module swxsoc_reach.util.util) process_file() (in module swxsoc_reach.calibration.calibration)

process_seconds (swxsoc_reach.historical.telemetry.TelemetryRow attribute) ProcessRunConfig (class in swxsoc_reach.historical.process_orchestrator) ProcessRunSummary (class in swxsoc_reach.historical.process_orchestrator)

R

REACHDataSchema (class in swxsoc_reach.util.schema) read_file() (in module swxsoc_reach.io.file_tools) read_udl_csv() (in module swxsoc_reach.io.file_tools) read_udl_json() (in module swxsoc_reach.io.file_tools) record_housekeeping() (in module swxsoc_reach.io.aws_db) record_rate_limit() (swxsoc_reach.net.udl.AdaptiveRateController method) record_success() (swxsoc_reach.net.udl.AdaptiveRateController method) records_downloaded (swxsoc_reach.historical.telemetry.TelemetryRow attribute)

resolve_udl_auth() (in module swxsoc_reach.net.auth) retry_failed (swxsoc_reach.historical.download_orchestrator.DownloadRunConfig attribute) (swxsoc_reach.historical.process_orchestrator.ProcessRunConfig attribute) run_download() (in module swxsoc_reach.historical.download_orchestrator) run_id (swxsoc_reach.historical.download_orchestrator.DownloadRunSummary attribute) (swxsoc_reach.historical.process_orchestrator.ProcessRunSummary attribute) (swxsoc_reach.historical.telemetry.TelemetryRow attribute) run_process() (in module swxsoc_reach.historical.process_orchestrator)

S

s3_bucket (swxsoc_reach.historical.process_orchestrator.ProcessRunConfig attribute) (swxsoc_reach.historical.telemetry.TelemetryRow attribute) s3_key (swxsoc_reach.historical.telemetry.TelemetryRow attribute) sensor_id (swxsoc_reach.historical.download_orchestrator.DownloadRunConfig attribute) (swxsoc_reach.historical.process_orchestrator.ProcessRunConfig attribute) (swxsoc_reach.historical.telemetry.TelemetryRow attribute) start_date (swxsoc_reach.historical.download_orchestrator.DownloadRunConfig attribute) (swxsoc_reach.historical.process_orchestrator.ProcessRunConfig attribute) started_at_utc (swxsoc_reach.historical.telemetry.TelemetryRow attribute) status (swxsoc_reach.historical.telemetry.TelemetryRow attribute) swxsoc_reach module swxsoc_reach.calibration.calibration module swxsoc_reach.calibration.transform module swxsoc_reach.historical.download_orchestrator module

swxsoc_reach.historical.process_orchestrator module swxsoc_reach.historical.s3_upload module swxsoc_reach.historical.telemetry module swxsoc_reach.io.aws_db module swxsoc_reach.io.file_tools module swxsoc_reach.net.auth module swxsoc_reach.net.udl module swxsoc_reach.util.schema module swxsoc_reach.util.util module

T

telemetry_path (swxsoc_reach.historical.download_orchestrator.DownloadRunConfig attribute) (swxsoc_reach.historical.process_orchestrator.ProcessRunConfig attribute)

TelemetryRow (class in swxsoc_reach.historical.telemetry) to_dict() (swxsoc_reach.historical.telemetry.TelemetryRow method)

U

upload_cdf_to_s3() (in module swxsoc_reach.historical.s3_upload) upload_seconds (swxsoc_reach.historical.telemetry.TelemetryRow attribute)

upload_to_s3 (swxsoc_reach.historical.process_orchestrator.ProcessRunConfig attribute) utcnow_iso() (in module swxsoc_reach.historical.telemetry)

W

window_end_utc (swxsoc_reach.historical.telemetry.TelemetryRow attribute)

window_start_utc (swxsoc_reach.historical.telemetry.TelemetryRow attribute) write_reach_output() (in module swxsoc_reach.net.udl)