wehub-resource-sync
33 lines
687 B
Python
33 lines
687 B
Python
"""Walk through a basic chunk-processing pipeline: read, filter, write."""
|
|
|
|
from __future__ import annotations
|
|
|
|
from pathlib import Path
|
|
|
|
mcap_path = (
|
|
Path(__file__).resolve().parents[4]
|
|
/ "tests"
|
|
/ "assets"
|
|
/ "mcap"
|
|
/ "trossen_transfer_cube.mcap"
|
|
)
|
|
output_path = Path("chunk_processing_intro.rrd")
|
|
|
|
# region: read
|
|
from rerun.experimental import McapReader
|
|
|
|
stream = McapReader(mcap_path).stream()
|
|
# endregion: read
|
|
|
|
# region: filter
|
|
stream = stream.filter(content="/robot_left/**")
|
|
# endregion: filter
|
|
|
|
# region: terminal
|
|
stream.write_rrd(
|
|
output_path,
|
|
application_id="rerun_example_chunk_processing_intro",
|
|
recording_id="run1",
|
|
)
|
|
# endregion: terminal
|