nat.observability.exporter.raw_exporter

Attributes

logger
InputT
OutputT

Classes

RawExporter

A base class for exporting raw intermediate steps.

Module Contents

logger

InputT

OutputT

class RawExporter(

context_state: nat.builder.context.ContextState | None = None,

)

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.

Initialize the processing exporter.

Args:

context_state: The context state to use for the exporter.

abstractmethod export_processed(item: OutputT)

Async:

Export the processed item.

This method must be implemented by concrete exporters to handle the actual export logic after the item has been processed through the pipeline.

Args:

item: The processed item to export (PipelineOutputT type)

export(event: nat.data_models.intermediate_step.IntermediateStep)

Export an IntermediateStep event through the processing pipeline.

This method converts the IntermediateStep to the expected PipelineInputT type, processes it through the pipeline, and exports the result.

Args:

event (IntermediateStep): The event to be exported.