api.datasources package

Submodules

api.datasources.abstract_datasource module

class api.datasources.abstract_datasource.AbstractDatasource(sensor: Sensor, ds_type: str, is_live: bool = False)

Bases: pioneer.das.api.datasources.datasource.DataSource

__init__(sensor: Sensor, ds_type: str, is_live: bool = False)

Initialize self. See help(type(self)) for accurate signature.

property label
property time_of_issues
property timestamps
to_float_index(timestamp: int) → float
to_positive_index(index)

api.datasources.datasource module

class api.datasources.datasource.DataSource

Bases: object

__getitem__(index)
__init__()

Initialize self. See help(type(self)) for accurate signature.

api.datasources.datasource_wrapper module

class api.datasources.datasource_wrapper.DatasourceWrapper(sensor: Sensor, ds_type: str, ds: pioneer.das.api.sources.filesource.FileSource, sample_interp: Tuple[Any, Any], cache_size: int = 100)

Bases: pioneer.das.api.datasources.abstract_datasource.AbstractDatasource

__getitem__(key: Any) → Union[Sample, List[Sample]]
__init__(sensor: Sensor, ds_type: str, ds: pioneer.das.api.sources.filesource.FileSource, sample_interp: Tuple[Any, Any], cache_size: int = 100)

Initialize self. See help(type(self)) for accurate signature.

get_at_timestamp(timestamp: Union[int, Iterable], interpolator: Callable = None) → Union[Sample, List[Sample]]
get_timestamp_slice(timestamp: int, half_window_size: Union[int, tuple])

Get an index slice that represent a time interval.

The time interval is parametrized by a timestamp and a half window size.

Parameters
  • timestamp – The center of the time interval

  • half_window_size – Half of the time interval. If tuple provided -> (start, end).

Returns

slice – The indices slice representing all the elements that fit in the time interval

property interpolator
invalidate_caches()
property label
property time_of_issues
property timestamps
to_timestamp(float_index: float) → int

Module contents