nat.plugins.data_flywheel.observability.mixin.elasticsearch_mixin

Attributes

logger

Classes

ElasticsearchMixin

Mixin for elasticsearch exporters.

Module Contents

logger

class ElasticsearchMixin(*args, endpoint: str, index: str, elasticsearch_auth: tuple[str, str], headers: dict[str, str] | None = None, \*\*kwargs)

Mixin for elasticsearch exporters.

This mixin provides elasticsearch-specific functionality for SpanExporter exporters. It handles elasticsearch-specific resource tagging and uses the AsyncElasticsearch client.

Initialize the elasticsearch exporter.

Args:

endpoint (str): The elasticsearch endpoint. index (str): The elasticsearch index. elasticsearch_auth (tuple[str, str]): The elasticsearch authentication credentials. headers (dict[str, str] | None): The elasticsearch headers.

_elastic_client

_index

async export_processed(item: dict | list[dict]) → None

Export a batch of spans.

Args:

item (dict | list[dict]): Dictionary or list of dictionaries to export to Elasticsearch.