nat.plugins.data_flywheel.observability.schema.sink.elasticsearch

Submodules

• nat.plugins.data_flywheel.observability.schema.sink.elasticsearch.contract_version
• nat.plugins.data_flywheel.observability.schema.sink.elasticsearch.dfw_es_record

Classes

ContractVersion	The contract version for Elasticsearch schema.
DFWESRecord	Data Flywheel Elasticsearch record.

Package Contents

class ContractVersion

Bases: str, enum.Enum

The contract version for Elasticsearch schema.

Initialize self. See help(type(self)) for accurate signature.

V1_0 = '1.0'

V1_1 = '1.1'

get_contract_class() → type[pydantic.BaseModel]

Get the Pydantic model class for this contract version.

class DFWESRecord(/, **data: Any)

Bases: pydantic.BaseModel

Data Flywheel Elasticsearch record.

Create a new model by parsing and validating input data from keyword arguments.

Raises [ValidationError][pydantic_core.ValidationError] if the input data cannot be validated to form a valid model.

self is explicitly positional-only to allow self as a field name.

model_config

Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

contract_version: nat.plugins.data_flywheel.observability.schema.sink.elasticsearch.contract_version.ContractVersion = None

request: ESRequest = None

response: Response = None

client_id: str = None

workload_id: str = None

timestamp: int = None

error_details: str | None = None

validate_data_consistency() → Self