88
99from copy import deepcopy
1010from typing import Any , TYPE_CHECKING
11+ from typing_extensions import Self
1112
13+ from azure .core .pipeline import policies
1214from azure .core .rest import HttpRequest , HttpResponse
1315from azure .mgmt .core import ARMPipelineClient
16+ from azure .mgmt .core .policies import ARMAutoResourceProviderRegistrationPolicy
1417
1518from . import models as _models
1619from ._configuration import LogAnalyticsManagementClientConfiguration
4851class LogAnalyticsManagementClient : # pylint: disable=client-accepts-api-version-keyword,too-many-instance-attributes
4952 """Operational Insights Client.
5053
51- :ivar query_packs: QueryPacksOperations operations
52- :vartype query_packs: azure.mgmt.loganalytics.operations.QueryPacksOperations
53- :ivar queries: QueriesOperations operations
54- :vartype queries: azure.mgmt.loganalytics.operations.QueriesOperations
54+ :ivar available_service_tiers: AvailableServiceTiersOperations operations
55+ :vartype available_service_tiers:
56+ azure.mgmt.loganalytics.operations.AvailableServiceTiersOperations
57+ :ivar clusters: ClustersOperations operations
58+ :vartype clusters: azure.mgmt.loganalytics.operations.ClustersOperations
5559 :ivar data_exports: DataExportsOperations operations
5660 :vartype data_exports: azure.mgmt.loganalytics.operations.DataExportsOperations
5761 :ivar data_sources: DataSourcesOperations operations
5862 :vartype data_sources: azure.mgmt.loganalytics.operations.DataSourcesOperations
63+ :ivar gateways: GatewaysOperations operations
64+ :vartype gateways: azure.mgmt.loganalytics.operations.GatewaysOperations
5965 :ivar intelligence_packs: IntelligencePacksOperations operations
6066 :vartype intelligence_packs: azure.mgmt.loganalytics.operations.IntelligencePacksOperations
6167 :ivar linked_services: LinkedServicesOperations operations
@@ -65,36 +71,33 @@ class LogAnalyticsManagementClient: # pylint: disable=client-accepts-api-versio
6571 azure.mgmt.loganalytics.operations.LinkedStorageAccountsOperations
6672 :ivar management_groups: ManagementGroupsOperations operations
6773 :vartype management_groups: azure.mgmt.loganalytics.operations.ManagementGroupsOperations
74+ :ivar operations: Operations operations
75+ :vartype operations: azure.mgmt.loganalytics.operations.Operations
6876 :ivar operation_statuses: OperationStatusesOperations operations
6977 :vartype operation_statuses: azure.mgmt.loganalytics.operations.OperationStatusesOperations
78+ :ivar saved_searches: SavedSearchesOperations operations
79+ :vartype saved_searches: azure.mgmt.loganalytics.operations.SavedSearchesOperations
80+ :ivar schema: SchemaOperations operations
81+ :vartype schema: azure.mgmt.loganalytics.operations.SchemaOperations
7082 :ivar shared_keys: SharedKeysOperations operations
7183 :vartype shared_keys: azure.mgmt.loganalytics.operations.SharedKeysOperations
72- :ivar usages: UsagesOperations operations
73- :vartype usages: azure.mgmt.loganalytics.operations.UsagesOperations
7484 :ivar storage_insight_configs: StorageInsightConfigsOperations operations
7585 :vartype storage_insight_configs:
7686 azure.mgmt.loganalytics.operations.StorageInsightConfigsOperations
77- :ivar saved_searches: SavedSearchesOperations operations
78- :vartype saved_searches: azure.mgmt.loganalytics.operations.SavedSearchesOperations
79- :ivar available_service_tiers: AvailableServiceTiersOperations operations
80- :vartype available_service_tiers:
81- azure.mgmt.loganalytics.operations.AvailableServiceTiersOperations
82- :ivar gateways: GatewaysOperations operations
83- :vartype gateways: azure.mgmt.loganalytics.operations.GatewaysOperations
84- :ivar schema: SchemaOperations operations
85- :vartype schema: azure.mgmt.loganalytics.operations.SchemaOperations
87+ :ivar tables: TablesOperations operations
88+ :vartype tables: azure.mgmt.loganalytics.operations.TablesOperations
89+ :ivar usages: UsagesOperations operations
90+ :vartype usages: azure.mgmt.loganalytics.operations.UsagesOperations
8691 :ivar workspace_purge: WorkspacePurgeOperations operations
8792 :vartype workspace_purge: azure.mgmt.loganalytics.operations.WorkspacePurgeOperations
88- :ivar clusters: ClustersOperations operations
89- :vartype clusters: azure.mgmt.loganalytics.operations.ClustersOperations
90- :ivar operations: Operations operations
91- :vartype operations: azure.mgmt.loganalytics.operations.Operations
9293 :ivar workspaces: WorkspacesOperations operations
9394 :vartype workspaces: azure.mgmt.loganalytics.operations.WorkspacesOperations
9495 :ivar deleted_workspaces: DeletedWorkspacesOperations operations
9596 :vartype deleted_workspaces: azure.mgmt.loganalytics.operations.DeletedWorkspacesOperations
96- :ivar tables: TablesOperations operations
97- :vartype tables: azure.mgmt.loganalytics.operations.TablesOperations
97+ :ivar queries: QueriesOperations operations
98+ :vartype queries: azure.mgmt.loganalytics.operations.QueriesOperations
99+ :ivar query_packs: QueryPacksOperations operations
100+ :vartype query_packs: azure.mgmt.loganalytics.operations.QueryPacksOperations
98101 :param credential: Credential needed for the client to connect to Azure. Required.
99102 :type credential: ~azure.core.credentials.TokenCredential
100103 :param subscription_id: The ID of the target subscription. Required.
@@ -115,16 +118,37 @@ def __init__(
115118 self ._config = LogAnalyticsManagementClientConfiguration (
116119 credential = credential , subscription_id = subscription_id , ** kwargs
117120 )
118- self ._client = ARMPipelineClient (base_url = base_url , config = self ._config , ** kwargs )
121+ _policies = kwargs .pop ("policies" , None )
122+ if _policies is None :
123+ _policies = [
124+ policies .RequestIdPolicy (** kwargs ),
125+ self ._config .headers_policy ,
126+ self ._config .user_agent_policy ,
127+ self ._config .proxy_policy ,
128+ policies .ContentDecodePolicy (** kwargs ),
129+ ARMAutoResourceProviderRegistrationPolicy (),
130+ self ._config .redirect_policy ,
131+ self ._config .retry_policy ,
132+ self ._config .authentication_policy ,
133+ self ._config .custom_hook_policy ,
134+ self ._config .logging_policy ,
135+ policies .DistributedTracingPolicy (** kwargs ),
136+ policies .SensitiveHeaderCleanupPolicy (** kwargs ) if self ._config .redirect_policy else None ,
137+ self ._config .http_logging_policy ,
138+ ]
139+ self ._client : ARMPipelineClient = ARMPipelineClient (base_url = base_url , policies = _policies , ** kwargs )
119140
120141 client_models = {k : v for k , v in _models .__dict__ .items () if isinstance (v , type )}
121142 self ._serialize = Serializer (client_models )
122143 self ._deserialize = Deserializer (client_models )
123144 self ._serialize .client_side_validation = False
124- self .query_packs = QueryPacksOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
125- self .queries = QueriesOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
145+ self .available_service_tiers = AvailableServiceTiersOperations (
146+ self ._client , self ._config , self ._serialize , self ._deserialize
147+ )
148+ self .clusters = ClustersOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
126149 self .data_exports = DataExportsOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
127150 self .data_sources = DataSourcesOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
151+ self .gateways = GatewaysOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
128152 self .intelligence_packs = IntelligencePacksOperations (
129153 self ._client , self ._config , self ._serialize , self ._deserialize
130154 )
@@ -135,30 +159,27 @@ def __init__(
135159 self .management_groups = ManagementGroupsOperations (
136160 self ._client , self ._config , self ._serialize , self ._deserialize
137161 )
162+ self .operations = Operations (self ._client , self ._config , self ._serialize , self ._deserialize )
138163 self .operation_statuses = OperationStatusesOperations (
139164 self ._client , self ._config , self ._serialize , self ._deserialize
140165 )
166+ self .saved_searches = SavedSearchesOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
167+ self .schema = SchemaOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
141168 self .shared_keys = SharedKeysOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
142- self .usages = UsagesOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
143169 self .storage_insight_configs = StorageInsightConfigsOperations (
144170 self ._client , self ._config , self ._serialize , self ._deserialize
145171 )
146- self .saved_searches = SavedSearchesOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
147- self .available_service_tiers = AvailableServiceTiersOperations (
148- self ._client , self ._config , self ._serialize , self ._deserialize
149- )
150- self .gateways = GatewaysOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
151- self .schema = SchemaOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
172+ self .tables = TablesOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
173+ self .usages = UsagesOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
152174 self .workspace_purge = WorkspacePurgeOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
153- self .clusters = ClustersOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
154- self .operations = Operations (self ._client , self ._config , self ._serialize , self ._deserialize )
155175 self .workspaces = WorkspacesOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
156176 self .deleted_workspaces = DeletedWorkspacesOperations (
157177 self ._client , self ._config , self ._serialize , self ._deserialize
158178 )
159- self .tables = TablesOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
179+ self .queries = QueriesOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
180+ self .query_packs = QueryPacksOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
160181
161- def _send_request (self , request : HttpRequest , ** kwargs : Any ) -> HttpResponse :
182+ def _send_request (self , request : HttpRequest , * , stream : bool = False , * *kwargs : Any ) -> HttpResponse :
162183 """Runs the network request through the client's chained policies.
163184
164185 >>> from azure.core.rest import HttpRequest
@@ -178,14 +199,14 @@ def _send_request(self, request: HttpRequest, **kwargs: Any) -> HttpResponse:
178199
179200 request_copy = deepcopy (request )
180201 request_copy .url = self ._client .format_url (request_copy .url )
181- return self ._client .send_request (request_copy , ** kwargs )
202+ return self ._client .send_request (request_copy , stream = stream , ** kwargs ) # type: ignore
182203
183204 def close (self ) -> None :
184205 self ._client .close ()
185206
186- def __enter__ (self ) -> "LogAnalyticsManagementClient" :
207+ def __enter__ (self ) -> Self :
187208 self ._client .__enter__ ()
188209 return self
189210
190- def __exit__ (self , * exc_details ) -> None :
211+ def __exit__ (self , * exc_details : Any ) -> None :
191212 self ._client .__exit__ (* exc_details )
0 commit comments