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
-