nat.observability.exporter.raw_exporter#
Attributes#
Classes#
A base class for exporting raw intermediate steps. |
Module Contents#
- logger#
- InputT#
- OutputT#
- class RawExporter#
Bases:
nat.observability.exporter.processing_exporter.ProcessingExporter[InputT,OutputT]A base class for exporting raw intermediate steps.
This class provides a base implementation for telemetry exporters that work directly with IntermediateStep objects. It can optionally process them through a pipeline before export.
The flow is: IntermediateStep -> [Processing Pipeline] -> OutputT -> Export
- Args:
context_state (ContextState, optional): The context state to use for the exporter. Defaults to None.
- abstractmethod export_processed(item: OutputT)#
- Async:
- export(event: nat.data_models.intermediate_step.IntermediateStep)#