diff --git a/.generator/schemas/v2/openapi.yaml b/.generator/schemas/v2/openapi.yaml index e0b1c4b3f5..e0e9db98e4 100644 --- a/.generator/schemas/v2/openapi.yaml +++ b/.generator/schemas/v2/openapi.yaml @@ -85302,6 +85302,8 @@ components: Defaults to `DESTINATION_AZURE_DATA_EXPLORER_INGESTION_ENDPOINT` (prefixed with `DD_OP_` at runtime). example: AZURE_DATA_EXPLORER_INGESTION_ENDPOINT type: string + ingestion_mode: + $ref: "#/components/schemas/ObservabilityPipelineAzureDataExplorerDestinationIngestionMode" inputs: description: A list of component IDs whose output is used as the `input` for this component. example: ["filter-processor"] @@ -85493,22 +85495,35 @@ components: description: Maximum batch size in bytes. example: 2000000 format: int64 - maximum: 4000000 - minimum: 1 type: integer max_events: description: Maximum number of events per batch before it is flushed. example: 1000 format: int64 - minimum: 1 type: integer timeout_secs: description: Maximum number of seconds to wait before flushing a partial batch. example: 1 format: int64 - minimum: 1 type: integer type: object + ObservabilityPipelineAzureDataExplorerDestinationIngestionMode: + default: streaming + description: |- + The ingestion method used to send data to Azure Data Explorer. + + - `streaming`: Sends events directly to the table using streaming ingestion. + - `queue`: Sends events through queued (batched) ingestion. + + Defaults to `streaming`. + enum: + - streaming + - queue + example: queue + type: string + x-enum-varnames: + - STREAMING + - QUEUE ObservabilityPipelineAzureDataExplorerDestinationManagedIdentityIdType: description: The type of the user-assigned managed identity ID. enum: diff --git a/src/datadog_api_client/v2/model/observability_pipeline_azure_data_explorer_destination.py b/src/datadog_api_client/v2/model/observability_pipeline_azure_data_explorer_destination.py index a9082b5a84..d9d6bf3239 100644 --- a/src/datadog_api_client/v2/model/observability_pipeline_azure_data_explorer_destination.py +++ b/src/datadog_api_client/v2/model/observability_pipeline_azure_data_explorer_destination.py @@ -25,6 +25,9 @@ from datadog_api_client.v2.model.observability_pipeline_azure_storage_destination_compression_gzip import ( ObservabilityPipelineAzureStorageDestinationCompressionGzip, ) + from datadog_api_client.v2.model.observability_pipeline_azure_data_explorer_destination_ingestion_mode import ( + ObservabilityPipelineAzureDataExplorerDestinationIngestionMode, + ) from datadog_api_client.v2.model.observability_pipeline_azure_data_explorer_destination_type import ( ObservabilityPipelineAzureDataExplorerDestinationType, ) @@ -70,6 +73,9 @@ def openapi_types(_): from datadog_api_client.v2.model.observability_pipeline_azure_storage_destination_compression_gzip import ( ObservabilityPipelineAzureStorageDestinationCompressionGzip, ) + from datadog_api_client.v2.model.observability_pipeline_azure_data_explorer_destination_ingestion_mode import ( + ObservabilityPipelineAzureDataExplorerDestinationIngestionMode, + ) from datadog_api_client.v2.model.observability_pipeline_azure_data_explorer_destination_type import ( ObservabilityPipelineAzureDataExplorerDestinationType, ) @@ -82,6 +88,7 @@ def openapi_types(_): "database": (str,), "id": (str,), "ingestion_endpoint_key": (str,), + "ingestion_mode": (ObservabilityPipelineAzureDataExplorerDestinationIngestionMode,), "inputs": ([str],), "mapping_reference": (str, none_type), "table": (str,), @@ -97,6 +104,7 @@ def openapi_types(_): "database": "database", "id": "id", "ingestion_endpoint_key": "ingestion_endpoint_key", + "ingestion_mode": "ingestion_mode", "inputs": "inputs", "mapping_reference": "mapping_reference", "table": "table", @@ -130,6 +138,7 @@ def __init__( ] = unset, compression: Union[ObservabilityPipelineAzureStorageDestinationCompressionGzip, UnsetType] = unset, ingestion_endpoint_key: Union[str, UnsetType] = unset, + ingestion_mode: Union[ObservabilityPipelineAzureDataExplorerDestinationIngestionMode, UnsetType] = unset, mapping_reference: Union[str, none_type, UnsetType] = unset, token_scope: Union[str, UnsetType] = unset, **kwargs, @@ -161,6 +170,14 @@ def __init__( Defaults to ``DESTINATION_AZURE_DATA_EXPLORER_INGESTION_ENDPOINT`` (prefixed with ``DD_OP_`` at runtime). :type ingestion_endpoint_key: str, optional + :param ingestion_mode: The ingestion method used to send data to Azure Data Explorer. + + * ``streaming`` : Sends events directly to the table using streaming ingestion. + * ``queue`` : Sends events through queued (batched) ingestion. + + Defaults to ``streaming``. + :type ingestion_mode: ObservabilityPipelineAzureDataExplorerDestinationIngestionMode, optional + :param inputs: A list of component IDs whose output is used as the ``input`` for this component. :type inputs: [str] @@ -185,6 +202,8 @@ def __init__( kwargs["compression"] = compression if ingestion_endpoint_key is not unset: kwargs["ingestion_endpoint_key"] = ingestion_endpoint_key + if ingestion_mode is not unset: + kwargs["ingestion_mode"] = ingestion_mode if mapping_reference is not unset: kwargs["mapping_reference"] = mapping_reference if token_scope is not unset: diff --git a/src/datadog_api_client/v2/model/observability_pipeline_azure_data_explorer_destination_batch.py b/src/datadog_api_client/v2/model/observability_pipeline_azure_data_explorer_destination_batch.py index 7259a33633..ae5cbd3808 100644 --- a/src/datadog_api_client/v2/model/observability_pipeline_azure_data_explorer_destination_batch.py +++ b/src/datadog_api_client/v2/model/observability_pipeline_azure_data_explorer_destination_batch.py @@ -14,19 +14,6 @@ class ObservabilityPipelineAzureDataExplorerDestinationBatch(ModelNormal): - validations = { - "max_bytes": { - "inclusive_maximum": 4000000, - "inclusive_minimum": 1, - }, - "max_events": { - "inclusive_minimum": 1, - }, - "timeout_secs": { - "inclusive_minimum": 1, - }, - } - @cached_property def openapi_types(_): return { diff --git a/src/datadog_api_client/v2/model/observability_pipeline_azure_data_explorer_destination_ingestion_mode.py b/src/datadog_api_client/v2/model/observability_pipeline_azure_data_explorer_destination_ingestion_mode.py new file mode 100644 index 0000000000..d2586aa131 --- /dev/null +++ b/src/datadog_api_client/v2/model/observability_pipeline_azure_data_explorer_destination_ingestion_mode.py @@ -0,0 +1,47 @@ +# Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License. +# This product includes software developed at Datadog (https://www.datadoghq.com/). +# Copyright 2019-Present Datadog, Inc. +from __future__ import annotations + + +from datadog_api_client.model_utils import ( + ModelSimple, + cached_property, +) + +from typing import ClassVar + + +class ObservabilityPipelineAzureDataExplorerDestinationIngestionMode(ModelSimple): + """ + The ingestion method used to send data to Azure Data Explorer. + + - `streaming`: Sends events directly to the table using streaming ingestion. + - `queue`: Sends events through queued (batched) ingestion. + + Defaults to `streaming`. + + :param value: If omitted defaults to "streaming". Must be one of ["streaming", "queue"]. + :type value: str + """ + + allowed_values = { + "streaming", + "queue", + } + STREAMING: ClassVar["ObservabilityPipelineAzureDataExplorerDestinationIngestionMode"] + QUEUE: ClassVar["ObservabilityPipelineAzureDataExplorerDestinationIngestionMode"] + + @cached_property + def openapi_types(_): + return { + "value": (str,), + } + + +ObservabilityPipelineAzureDataExplorerDestinationIngestionMode.STREAMING = ( + ObservabilityPipelineAzureDataExplorerDestinationIngestionMode("streaming") +) +ObservabilityPipelineAzureDataExplorerDestinationIngestionMode.QUEUE = ( + ObservabilityPipelineAzureDataExplorerDestinationIngestionMode("queue") +) diff --git a/src/datadog_api_client/v2/model/observability_pipeline_config_destination_item.py b/src/datadog_api_client/v2/model/observability_pipeline_config_destination_item.py index 340c1ea3f3..50c15fa5d6 100644 --- a/src/datadog_api_client/v2/model/observability_pipeline_config_destination_item.py +++ b/src/datadog_api_client/v2/model/observability_pipeline_config_destination_item.py @@ -123,6 +123,14 @@ def __init__(self, **kwargs): Defaults to `DESTINATION_AZURE_DATA_EXPLORER_INGESTION_ENDPOINT` (prefixed with `DD_OP_` at runtime). :type ingestion_endpoint_key: str, optional + :param ingestion_mode: The ingestion method used to send data to Azure Data Explorer. + + - `streaming`: Sends events directly to the table using streaming ingestion. + - `queue`: Sends events through queued (batched) ingestion. + + Defaults to `streaming`. + :type ingestion_mode: ObservabilityPipelineAzureDataExplorerDestinationIngestionMode, optional + :param mapping_reference: The name of a pre-created ingestion mapping on the table used to map incoming events to columns. Supports template syntax. :type mapping_reference: str, none_type, optional diff --git a/src/datadog_api_client/v2/models/__init__.py b/src/datadog_api_client/v2/models/__init__.py index 456ae74dd8..7283ce9f45 100644 --- a/src/datadog_api_client/v2/models/__init__.py +++ b/src/datadog_api_client/v2/models/__init__.py @@ -6983,6 +6983,9 @@ from datadog_api_client.v2.model.observability_pipeline_azure_data_explorer_destination_batch import ( ObservabilityPipelineAzureDataExplorerDestinationBatch, ) +from datadog_api_client.v2.model.observability_pipeline_azure_data_explorer_destination_ingestion_mode import ( + ObservabilityPipelineAzureDataExplorerDestinationIngestionMode, +) from datadog_api_client.v2.model.observability_pipeline_azure_data_explorer_destination_managed_identity_id_type import ( ObservabilityPipelineAzureDataExplorerDestinationManagedIdentityIdType, ) @@ -17897,6 +17900,7 @@ "ObservabilityPipelineAzureDataExplorerDestinationAuthWorkloadIdentity", "ObservabilityPipelineAzureDataExplorerDestinationAuthWorkloadIdentityKind", "ObservabilityPipelineAzureDataExplorerDestinationBatch", + "ObservabilityPipelineAzureDataExplorerDestinationIngestionMode", "ObservabilityPipelineAzureDataExplorerDestinationManagedIdentityIdType", "ObservabilityPipelineAzureDataExplorerDestinationType", "ObservabilityPipelineAzureDataExplorerManagedIdentityClientAssertion",