cerebralcortex.core.data_manager.time_series package

Submodules

cerebralcortex.core.data_manager.time_series.data module

class TimeSeriesData(CC)[source]

Bases: cerebralcortex.core.data_manager.time_series.influxdb_handler.InfluxdbHandler

cerebralcortex.core.data_manager.time_series.influxdb_handler module

class InfluxdbHandler[source]

Bases: object

save_data_to_influxdb(datastream: cerebralcortex.core.datatypes.datastream.DataStream)[source]

Save data stream to influxdb only for visualization purposes.

Parameters:datastream (DataStream) – a DataStream object
Returns:True if data is ingested successfully or False otherwise
Return type:bool

Todo

This needs to be updated with the new structure. Should metadata be stored or not?

Example

>>> CC = CerebralCortex("/directory/path/of/configs/")
>>> ds = DataStream(dataframe, MetaData)
>>> CC.save_data_to_influxdb(ds)
write_pd_to_influxdb(user_id: str, username: str, stream_name: str, df: pandas.core.frame.DataFrame)[source]

Store data in influxdb. Influxdb is used for visualization purposes

Parameters:
  • user_id (str) – id of a user
  • username (str) – username
  • stream_name (str) – name of a stream
  • df (pandas) – pandas dataframe
Raises:

Exception – if error occurs during storing data to influxdb

Module contents