roboto.domain.topics.mcap_topic_reader#

Module Contents#

class roboto.domain.topics.mcap_topic_reader.McapTopicReader(roboto_client, cache_dir)#

Bases: roboto.domain.topics.topic_reader.TopicReader

Private interface for retrieving topic data stored in MCAP files.

Note

This is not intended as a public API. To access topic data, prefer the get_data or get_data_as_df methods on Topic, MessagePath, or Event.

Parameters:
static accepts(message_paths_to_representations)#
Parameters:

message_paths_to_representations (collections.abc.Iterable[roboto.domain.topics.operations.MessagePathRepresentationMapping])

Return type:

bool

get_data(message_paths_to_representations, start_time=None, end_time=None, timestamp_message_path_representation_mapping=None)#
Parameters:
Return type:

collections.abc.Generator[tuple[roboto.domain.topics.topic_reader.Timestamp, dict[str, Any]], None, None]

get_data_as_df(message_paths_to_representations, start_time=None, end_time=None, timestamp_message_path_representation_mapping=None)#
Parameters:
Return type:

tuple[pandas.Series, pandas.DataFrame]

roboto.domain.topics.mcap_topic_reader.OUTFILE_NAME_PATTERN = '{repr_id}_{file_id}.mcap'#
roboto.domain.topics.mcap_topic_reader.garbage_collect_old_topic_data(cache_dir, expire_after=datetime.timedelta(days=7))#
Parameters:

  • cache_dir (pathlib.Path)

  • expire_after (datetime.timedelta)

roboto.domain.topics.mcap_topic_reader.logger#
On this page