Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -6,5 +6,5 @@
# Changes may cause incorrect behavior and will be lost if the code is regenerated.
# --------------------------------------------------------------------------

from ._azure_monitor_client_async import AzureMonitorClient
from ._azure_monitor_client import AzureMonitorClient
__all__ = ['AzureMonitorClient']
Original file line number Diff line number Diff line change
Expand Up @@ -11,8 +11,8 @@
from azure.core import AsyncPipelineClient
from msrest import Deserializer, Serializer

from ._configuration_async import AzureMonitorClientConfiguration
from .operations_async import AzureMonitorClientOperationsMixin
from ._configuration import AzureMonitorClientConfiguration
from .operations import AzureMonitorClientOperationsMixin
from .. import models


Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
# Changes may cause incorrect behavior and will be lost if the code is regenerated.
# --------------------------------------------------------------------------

from ._azure_monitor_client_operations_async import AzureMonitorClientOperationsMixin
from ._azure_monitor_client_operations import AzureMonitorClientOperationsMixin

__all__ = [
'AzureMonitorClientOperationsMixin',
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,11 +8,11 @@
from typing import Any, Callable, Dict, Generic, List, Optional, TypeVar, Union
import warnings

from azure.core.exceptions import HttpResponseError, ResourceExistsError, ResourceNotFoundError, map_error
from azure.core.exceptions import ClientAuthenticationError, HttpResponseError, ResourceExistsError, ResourceNotFoundError, map_error
from azure.core.pipeline import PipelineResponse
from azure.core.pipeline.transport import AsyncHttpResponse, HttpRequest

from ... import models
from ... import models as _models

T = TypeVar('T')
ClsType = Optional[Callable[[PipelineResponse[HttpRequest, AsyncHttpResponse], T, Dict[str, Any]], Any]]
Expand All @@ -21,9 +21,9 @@ class AzureMonitorClientOperationsMixin:

async def track(
self,
body: List["models.TelemetryItem"],
body: List["_models.TelemetryItem"],
**kwargs
) -> "models.TrackResponse":
) -> "_models.TrackResponse":
"""Track telemetry events.

This operation sends a sequence of telemetry events that will be monitored by Azure Monitor.
Expand All @@ -35,18 +35,20 @@ async def track(
:rtype: ~azure_monitor_client.models.TrackResponse
:raises: ~azure.core.exceptions.HttpResponseError
"""
cls = kwargs.pop('cls', None) # type: ClsType["models.TrackResponse"]
cls = kwargs.pop('cls', None) # type: ClsType["_models.TrackResponse"]
error_map = {
401: ClientAuthenticationError,
404: ResourceNotFoundError,
409: ResourceExistsError,
400: lambda response: HttpResponseError(response=response, model=self._deserialize(models.TrackResponse, response)),
402: lambda response: HttpResponseError(response=response, model=self._deserialize(models.TrackResponse, response)),
429: lambda response: HttpResponseError(response=response, model=self._deserialize(models.TrackResponse, response)),
500: lambda response: HttpResponseError(response=response, model=self._deserialize(models.TrackResponse, response)),
503: lambda response: HttpResponseError(response=response, model=self._deserialize(models.TrackResponse, response)),
400: lambda response: HttpResponseError(response=response, model=self._deserialize(_models.TrackResponse, response)),
402: lambda response: HttpResponseError(response=response, model=self._deserialize(_models.TrackResponse, response)),
429: lambda response: HttpResponseError(response=response, model=self._deserialize(_models.TrackResponse, response)),
500: lambda response: HttpResponseError(response=response, model=self._deserialize(_models.TrackResponse, response)),
503: lambda response: HttpResponseError(response=response, model=self._deserialize(_models.TrackResponse, response)),
}
error_map.update(kwargs.pop('error_map', {}))
content_type = kwargs.pop("content_type", "application/json")
accept = "application/json"

# Construct URL
url = self.track.metadata['url'] # type: ignore
Expand All @@ -61,13 +63,12 @@ async def track(
# Construct headers
header_parameters = {} # type: Dict[str, Any]
header_parameters['Content-Type'] = self._serialize.header("content_type", content_type, 'str')
header_parameters['Accept'] = 'application/json'
header_parameters['Accept'] = self._serialize.header("accept", accept, 'str')

body_content_kwargs = {} # type: Dict[str, Any]
body_content = self._serialize.body(body, '[TelemetryItem]')
body_content_kwargs['content'] = body_content
request = self._client.post(url, query_parameters, header_parameters, **body_content_kwargs)

pipeline_response = await self._client._pipeline.run(request, stream=False, **kwargs)
response = pipeline_response.http_response

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,11 +8,11 @@
from typing import TYPE_CHECKING
import warnings

from azure.core.exceptions import HttpResponseError, ResourceExistsError, ResourceNotFoundError, map_error
from azure.core.exceptions import ClientAuthenticationError, HttpResponseError, ResourceExistsError, ResourceNotFoundError, map_error
from azure.core.pipeline import PipelineResponse
from azure.core.pipeline.transport import HttpRequest, HttpResponse

from .. import models
from .. import models as _models

if TYPE_CHECKING:
# pylint: disable=unused-import,ungrouped-imports
Expand All @@ -25,10 +25,10 @@ class AzureMonitorClientOperationsMixin(object):

def track(
self,
body, # type: List["models.TelemetryItem"]
body, # type: List["_models.TelemetryItem"]
**kwargs # type: Any
):
# type: (...) -> "models.TrackResponse"
# type: (...) -> "_models.TrackResponse"
"""Track telemetry events.

This operation sends a sequence of telemetry events that will be monitored by Azure Monitor.
Expand All @@ -40,18 +40,20 @@ def track(
:rtype: ~azure_monitor_client.models.TrackResponse
:raises: ~azure.core.exceptions.HttpResponseError
"""
cls = kwargs.pop('cls', None) # type: ClsType["models.TrackResponse"]
cls = kwargs.pop('cls', None) # type: ClsType["_models.TrackResponse"]
error_map = {
401: ClientAuthenticationError,
404: ResourceNotFoundError,
409: ResourceExistsError,
400: lambda response: HttpResponseError(response=response, model=self._deserialize(models.TrackResponse, response)),
402: lambda response: HttpResponseError(response=response, model=self._deserialize(models.TrackResponse, response)),
429: lambda response: HttpResponseError(response=response, model=self._deserialize(models.TrackResponse, response)),
500: lambda response: HttpResponseError(response=response, model=self._deserialize(models.TrackResponse, response)),
503: lambda response: HttpResponseError(response=response, model=self._deserialize(models.TrackResponse, response)),
400: lambda response: HttpResponseError(response=response, model=self._deserialize(_models.TrackResponse, response)),
402: lambda response: HttpResponseError(response=response, model=self._deserialize(_models.TrackResponse, response)),
429: lambda response: HttpResponseError(response=response, model=self._deserialize(_models.TrackResponse, response)),
500: lambda response: HttpResponseError(response=response, model=self._deserialize(_models.TrackResponse, response)),
503: lambda response: HttpResponseError(response=response, model=self._deserialize(_models.TrackResponse, response)),
}
error_map.update(kwargs.pop('error_map', {}))
content_type = kwargs.pop("content_type", "application/json")
accept = "application/json"

# Construct URL
url = self.track.metadata['url'] # type: ignore
Expand All @@ -66,13 +68,12 @@ def track(
# Construct headers
header_parameters = {} # type: Dict[str, Any]
header_parameters['Content-Type'] = self._serialize.header("content_type", content_type, 'str')
header_parameters['Accept'] = 'application/json'
header_parameters['Accept'] = self._serialize.header("accept", accept, 'str')

body_content_kwargs = {} # type: Dict[str, Any]
body_content = self._serialize.body(body, '[TelemetryItem]')
body_content_kwargs['content'] = body_content
request = self._client.post(url, query_parameters, header_parameters, **body_content_kwargs)

pipeline_response = self._client._pipeline.run(request, stream=False, **kwargs)
response = pipeline_response.http_response

Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
# Opentelemtry Exporter for Azure Monitor Client for Python
# OpenTelemetry Exporter for Azure Monitor Client for Python

> see https://aka.ms/autorest

Expand All @@ -15,16 +15,17 @@ autorest ./swagger/README.md --python --v3

```yaml
title: AzureMonitorClient
description: Opentelemetry Exporter for Azure Monitor
description: OpenTelemetry Exporter for Azure Monitor
generated-metadata: false
license-header: MICROSOFT_MIT_NO_VERSION
no-namespace-folders: true
trace: false
output-folder: ../microsoft/opentelemetry/exporter/azuremonitor/_generated
source-code-folder-path: ./microsoft/opentelemetry/exporter/azuremonitor/_generated
input-file:
- https://github.com/Azure/azure-rest-api-specs/blob/master/specification/applicationinsights/data-plane/Monitor.Exporters/preview/2020-09-15_Preview/swagger.json

python: true
v3: true
use: "@autorest/python@5.1.0-preview.7"
use: "@autorest/python@5.5.0"
```