roboto.domain.topics.topic_reader
Module Contents
Timestamp
TopicReader
Bases: abc.ABC
Private interface for retrieving topic data of a particular format.
TopicReader.accepts()
Parameters
message_paths_to_representations collections.Return type
bool
TopicReader.get_data()
abstract get_data(message_paths_to_representations, start_time=None, end_time=None, timestamp_message_path_representation_mapping=None)#View Source
Parameters
message_paths_to_representations collections.start_time Optional[int]end_time Optional[int]timestamp_message_path_representation_mapping Optional[roboto.Return type
collections. abc. Generator[tuple[Timestamp, dict[str, Any]], None, None]
TopicReader.get_data_as_df()
abstract get_data_as_df(message_paths_to_representations, start_time=None, end_time=None, timestamp_message_path_representation_mapping=None)#View Source
Parameters
message_paths_to_representations collections.start_time Optional[int]end_time Optional[int]timestamp_message_path_representation_mapping Optional[roboto.Return type
tuple[pandas. Series, pandas. DataFrame]