Index

_

__call__() (snsary.functions.filter.Filter method) (snsary.functions.function.Function method) (snsary.functions.rename.Rename method) (snsary.functions.window.Window method) (snsary.utils.scraper.for_class method)

__iter__() (snsary.utils.tracing.history.History method) __len__() (snsary.utils.tracing.history.History method) __str__() (snsary.models.reading.Reading method)

A

add() (snsary.utils.tracing.history.History method) aggregate() (snsary.functions.window.Window method) (snsary.functions.window_average.WindowAverage method) (snsary.functions.window_summary.WindowSummary method) analyse() (snsary.utils.tracing.monitors.GapAlert method) (snsary.utils.tracing.monitors.LivenessAlert method) (snsary.utils.tracing.monitors.Monitor method)

apply() (snsary.streams.stream.Stream method) AsyncStream (class in snsary.streams.async_stream) average() (snsary.streams.stream.Stream method) AwairSensor (class in snsary.contrib.awair)

B

baselines_changed() (snsary.contrib.adafruit.sgp30.SGP30Sensor method)

BatchOutput (class in snsary.outputs.batch_output) BigQueryOutput (class in snsary.contrib.google.bigquery)

C

capture_exceptions() (in module snsary.utils.tracing.core) clear_services() (in module snsary.system.service) Config (class in snsary.utils.tracing.config)

configure() (in module snsary.utils.tracing.core) configure_logging() (in module snsary.utils.logging) CONSUMPTION_URL (snsary.contrib.octopus.OctopusSensor attribute)

D

DATA_URL (snsary.contrib.awair.AwairSensor attribute) datetime (snsary.models.reading.Reading property) DESCRIPTOR (in module snsary.contrib.google.reading_pb2) device (snsary.contrib.adafruit.generic.GenericSensor property)

DEVICES_URL (snsary.contrib.awair.AwairSensor attribute) discover() (snsary.contrib.awair.AwairSensor class method) discover_from_env() (snsary.contrib.awair.AwairSensor class method) dup() (snsary.models.reading.Reading method)

E

electricity_from_env() (snsary.contrib.octopus.OctopusSensor class method)

extract_from() (in module snsary.utils.scraper)

F

factory() (snsary.utils.tracing.monitors.Monitor class method) FAILURE (snsary.utils.tracing.sample.Sample attribute) Filter (class in snsary.functions.filter) filter_names() (snsary.streams.stream.Stream method) flush() (snsary.outputs.batch_output.BatchOutput method) for_class (class in snsary.utils.scraper)

from_env() (snsary.contrib.datastax.GraphQLOutput class method) (snsary.contrib.google.bigquery.BigQueryOutput class method) (snsary.contrib.grafana.GraphiteOutput class method) (snsary.contrib.influxdb.InfluxDBOutput class method) FuncStream (class in snsary.streams.func_stream) Function (class in snsary.functions.function) FUNCTIONS (snsary.contrib.psutil.PSUtilSensor attribute)

G

GapAlert (class in snsary.utils.tracing.monitors) gas_from_env() (snsary.contrib.octopus.OctopusSensor class method) GenericSensor (class in snsary.contrib.adafruit.generic) (class in snsary.contrib.pimoroni) get() (snsary.utils.tracing.config.Config method) (snsary.utils.tracing.registry.Registry method)

get_logger() (in module snsary.utils.logging) get_services() (in module snsary.system.service) get_storage() (in module snsary.utils.storage.backend) GraphiteOutput (class in snsary.contrib.grafana) GraphQLOutput (class in snsary.contrib.datastax)

H

HasLogger (class in snsary.utils.logging)

HasStore (class in snsary.utils.storage.backend) History (class in snsary.utils.tracing.history)

I

InfluxDBOutput (class in snsary.contrib.influxdb)

into() (snsary.streams.stream.Stream method) invert (snsary.functions.filter.Filter property)

K

key() (snsary.functions.window.Window method)

L

LivenessAlert (class in snsary.utils.tracing.monitors)

logger (snsary.utils.logging.HasLogger property) loggers (in module snsary.utils.logging)

M

MAX_GAPS (snsary.utils.tracing.monitors.GapAlert attribute) MAX_HISTORY (snsary.utils.tracing.monitors.TimeSeriesAlert attribute) max_length (snsary.utils.tracing.history.History property) MaxTracker (class in snsary.utils.storage.max_tracker) mics6814_i2c() (snsary.contrib.pimoroni.GenericSensor class method) MockOutput (class in snsary.outputs.mock_output) MockSensor (class in snsary.sources.mock_sensor) module snsary snsary.contrib snsary.contrib.adafruit snsary.contrib.adafruit.generic snsary.contrib.adafruit.sgp30 snsary.contrib.awair snsary.contrib.datastax snsary.contrib.google snsary.contrib.google.bigquery snsary.contrib.google.reading_pb2 snsary.contrib.grafana snsary.contrib.influxdb snsary.contrib.octopus snsary.contrib.pimoroni snsary.contrib.psutil snsary.contrib.pypms snsary.functions snsary.functions.filter snsary.functions.function snsary.functions.rename snsary.functions.window snsary.functions.window_average snsary.functions.window_summary snsary.models snsary.models.reading snsary.outputs snsary.outputs.batch_output snsary.outputs.mock_output snsary.outputs.output snsary.sources snsary.sources.mock_sensor snsary.sources.multi_source snsary.sources.poller snsary.sources.polling_sensor snsary.sources.sensor snsary.sources.source snsary.streams snsary.streams.async_stream snsary.streams.func_stream snsary.streams.simple_stream snsary.streams.stream snsary.system snsary.system.backend snsary.system.service snsary.utils snsary.utils.logging snsary.utils.request snsary.utils.scraper snsary.utils.storage snsary.utils.storage.backend snsary.utils.storage.max_tracker snsary.utils.storage.null_tracker snsary.utils.storage.tracker snsary.utils.tracing snsary.utils.tracing.config snsary.utils.tracing.core snsary.utils.tracing.history snsary.utils.tracing.monitors snsary.utils.tracing.registry snsary.utils.tracing.sample

Monitor (class in snsary.utils.tracing.monitors) MultiSource (class in snsary.sources.multi_source)

N

name (snsary.contrib.adafruit.generic.GenericSensor property) (snsary.contrib.adafruit.sgp30.SGP30Sensor property) (snsary.contrib.awair.AwairSensor property) (snsary.contrib.octopus.OctopusSensor property) (snsary.contrib.pimoroni.GenericSensor property) (snsary.contrib.psutil.PSUtilSensor property) (snsary.contrib.pypms.PyPMSSensor property) (snsary.models.reading.Reading property) (snsary.outputs.mock_output.MockOutput property) (snsary.sources.mock_sensor.MockSensor property) (snsary.utils.logging.HasLogger property)

names() (snsary.functions.filter.Filter class method) NullTracker (class in snsary.utils.storage.null_tracker)

O

OctopusSensor (class in snsary.contrib.octopus)

on_change() (snsary.utils.storage.tracker.Tracker method) Output (class in snsary.outputs.output)

P

PERIOD (snsary.contrib.awair.AwairSensor attribute) period (snsary.sources.poller.Poller property) Poller (class in snsary.sources.poller) PollingSensor (class in snsary.sources.polling_sensor) PSUtilSensor (class in snsary.contrib.psutil) publish() (snsary.outputs.batch_output.BatchOutput method) (snsary.outputs.mock_output.MockOutput method) (snsary.outputs.output.Output method) (snsary.streams.async_stream.AsyncStream method) (snsary.streams.func_stream.FuncStream method) (snsary.streams.simple_stream.SimpleStream method)

publish_batch() (snsary.contrib.adafruit.sgp30.SGP30Sensor method) (snsary.contrib.datastax.GraphQLOutput method) (snsary.contrib.google.bigquery.BigQueryOutput method) (snsary.contrib.grafana.GraphiteOutput method) (snsary.contrib.influxdb.InfluxDBOutput method) (snsary.outputs.batch_output.BatchOutput method) PyPMSSensor (class in snsary.contrib.pypms) PyPMSSensor.SnsaryReader (class in snsary.contrib.pypms)

R

Reading (class in snsary.models.reading) (in module snsary.contrib.google.reading_pb2) ready() (snsary.contrib.adafruit.generic.GenericSensor method) (snsary.contrib.adafruit.sgp30.SGP30Sensor method) Registry (class in snsary.utils.tracing.registry) Rename (class in snsary.functions.rename) rename() (snsary.streams.stream.Stream method)

reset() (in module snsary.utils.tracing.core) (snsary.utils.tracing.config.Config method) (snsary.utils.tracing.history.History method) (snsary.utils.tracing.registry.Registry method) RETRY_DEADLINE (snsary.contrib.google.bigquery.BigQueryOutput attribute) retrying_session() (in module snsary.utils.request) rootLogger (in module snsary.utils.logging)

S

Sample (class in snsary.utils.tracing.sample) sample() (snsary.contrib.adafruit.generic.GenericSensor method) (snsary.contrib.adafruit.sgp30.SGP30Sensor method) (snsary.contrib.awair.AwairSensor method) (snsary.contrib.octopus.OctopusSensor method) (snsary.contrib.pimoroni.GenericSensor method) (snsary.contrib.psutil.PSUtilSensor method) (snsary.contrib.pypms.PyPMSSensor method) (snsary.sources.mock_sensor.MockSensor method) (snsary.sources.polling_sensor.PollingSensor method) Sensor (class in snsary.sources.sensor) sensor_name (snsary.models.reading.Reading property) sensor_name() (snsary.functions.filter.Filter class method) Service (class in snsary.system.service) set() (snsary.utils.tracing.config.Config method) SGP30Sensor (class in snsary.contrib.adafruit.sgp30) SimpleStream (class in snsary.streams.simple_stream) snsary module snsary.contrib module snsary.contrib.adafruit module snsary.contrib.adafruit.generic module snsary.contrib.adafruit.sgp30 module snsary.contrib.awair module snsary.contrib.datastax module snsary.contrib.google module snsary.contrib.google.bigquery module snsary.contrib.google.reading_pb2 module snsary.contrib.grafana module snsary.contrib.influxdb module snsary.contrib.octopus module snsary.contrib.pimoroni module snsary.contrib.psutil module snsary.contrib.pypms module snsary.functions module snsary.functions.filter module snsary.functions.function module snsary.functions.rename module snsary.functions.window module snsary.functions.window_average module snsary.functions.window_summary module snsary.models module snsary.models.reading module snsary.outputs module snsary.outputs.batch_output module snsary.outputs.mock_output module snsary.outputs.output module snsary.sources module snsary.sources.mock_sensor module snsary.sources.multi_source module

snsary.sources.poller module snsary.sources.polling_sensor module snsary.sources.sensor module snsary.sources.source module snsary.streams module snsary.streams.async_stream module snsary.streams.func_stream module snsary.streams.simple_stream module snsary.streams.stream module snsary.system module snsary.system.backend module snsary.system.service module snsary.utils module snsary.utils.logging module snsary.utils.request module snsary.utils.scraper module snsary.utils.storage module snsary.utils.storage.backend module snsary.utils.storage.max_tracker module snsary.utils.storage.null_tracker module snsary.utils.storage.tracker module snsary.utils.tracing module snsary.utils.tracing.config module snsary.utils.tracing.core module snsary.utils.tracing.history module snsary.utils.tracing.monitors module snsary.utils.tracing.registry module snsary.utils.tracing.sample module Source (class in snsary.sources.source) start (snsary.sources.polling_sensor.PollingSensor attribute) start() (in module snsary.system.backend) (snsary.contrib.adafruit.sgp30.SGP30Sensor method) (snsary.contrib.pypms.PyPMSSensor method) (snsary.sources.poller.Poller method) (snsary.system.service.Service method) start_and_wait() (in module snsary.system.backend) stop() (in module snsary.system.backend) (snsary.contrib.pypms.PyPMSSensor method) (snsary.functions.window.Window method) (snsary.outputs.batch_output.BatchOutput method) (snsary.sources.poller.Poller method) (snsary.system.service.Service method) store (snsary.utils.storage.backend.HasStore property) Stream (class in snsary.streams.stream) stream (snsary.sources.multi_source.MultiSource property) (snsary.sources.sensor.Sensor property) subscribe() (snsary.sources.multi_source.MultiSource method) (snsary.sources.sensor.Sensor method) (snsary.sources.source.Source method) (snsary.streams.async_stream.AsyncStream method) (snsary.streams.simple_stream.SimpleStream method) SUCCESS (snsary.utils.tracing.sample.Sample attribute) summarize() (snsary.streams.stream.Stream method)

T

tee() (snsary.streams.stream.Stream method) tick() (snsary.sources.poller.Poller method) (snsary.sources.polling_sensor.PollingSensor method)

TimeSeriesAlert (class in snsary.utils.tracing.monitors) timestamp (snsary.models.reading.Reading property) Tracker (class in snsary.utils.storage.tracker) TTL (snsary.contrib.datastax.GraphQLOutput attribute)

U

update() (snsary.utils.storage.null_tracker.NullTracker method) (snsary.utils.storage.tracker.Tracker method)

V

value (snsary.models.reading.Reading property)

values (snsary.utils.storage.null_tracker.NullTracker property) (snsary.utils.storage.tracker.Tracker property)

W

wait() (in module snsary.system.backend) Window (class in snsary.functions.window)

WindowAverage (class in snsary.functions.window_average) WindowSummary (class in snsary.functions.window_summary)