generic_exporters.processors.exporters.datastores.timeseries package

Submodules

generic_exporters.processors.exporters.datastores.timeseries.multi module

class generic_exporters.processors.exporters.datastores.timeseries.multi.TimeSeriesMultiDataStore(*datastores: TimeSeriesDataStoreBase)

Bases: TimeSeriesDataStoreBase

async data_exists(key: Any, ts: datetime) → bool

Returns True if the datapoint exists in all datastores, False if not.

async push(key: Any, ts: datetime, data: Decimal) → None

Exports one datapoint to all datastores. NOTE: Will swallow any exceptions that may occur. They will not raise.

generic_exporters.processors.exporters.datastores.timeseries.sql module

class generic_exporters.processors.exporters.datastores.timeseries.sql.SQLTimeSeriesKeyValueStore(**connection_params: Dict[str, Any] | None)

Bases: TimeSeriesDataStoreBase

async _push(key: Any, ts: datetime, value: Any) → None

Exports data to Victoria Metrics using key somehow. lol

async data_exists(key: Any, ts: datetime) → bool

Returns True if key returns results from your Postgres db at ts, False if not.

push = None

class generic_exporters.processors.exporters.datastores.timeseries.sql.TimeSeriesKV(*args, **kwargs)

Bases: Entity

classmethod _count(key: Any, timestamp: datetime) → int

classmethod _insert(key: Any, timestamp: datetime, value: Any) → None

_insert_sql_cache_ = {}

_interleave_ = None

_keys_ = []

_load_sql_cache_ = {}

_multiset_subclass_ = None

_new_attrs_ = [TimeSeriesKV.key, TimeSeriesKV.timestamp, TimeSeriesKV.value]

_pk_ = (TimeSeriesKV.key, TimeSeriesKV.timestamp)

_pk_attrs_ = (TimeSeriesKV.key, TimeSeriesKV.timestamp)

_pk_columns_ = None

_pk_is_composite_ = True

_propagation_mixin_ = None

_root_

alias of TimeSeriesKV

classmethod _select(key: Any, timestamp: datetime) → Query

_set_wrapper_subclass_ = None

_simple_keys_ = []

_subclass_adict_ = {}

_subclass_attrs_ = []

_subclasses_ = {}

_table_ = None

_update_sql_cache_ = {}

async classmethod count(key: Any, timestamp: datetime) → int

async classmethod insert(key: Any, timestamp: datetime, value: Any) → int

key

timestamp

value

generic_exporters.processors.exporters.datastores.timeseries.victoria module

class generic_exporters.processors.exporters.datastores.timeseries.victoria.VictoriaMetrics(url: str, key_label_name: LabelName, extra_labels: Dict[LabelName, LabelValue])

Bases: TimeSeriesDataStoreBase

async _post(data: bytes) → Any

async data_exists(key: LabelValue, ts: datetime) → bool

Returns True if data_query returns results from your Victoria Metrics db, False if not.

async push(key: LabelValue, ts: datetime, data: Decimal) → None

Exports data to Victoria Metrics using key somehow. lol

Module contents