|
8 | 8 |
|
9 | 9 | from typing import Any, Optional, TYPE_CHECKING
|
10 | 10 |
|
| 11 | +from azure.core.pipeline.transport import AsyncHttpResponse, HttpRequest |
11 | 12 | from azure.mgmt.core import AsyncARMPipelineClient
|
12 | 13 | from msrest import Deserializer, Serializer
|
13 | 14 |
|
|
29 | 30 | from .operations import IntegrationRuntimeMonitoringDataOperations
|
30 | 31 | from .operations import IntegrationRuntimeStatusOperations
|
31 | 32 | from .operations import KeysOperations
|
| 33 | +from .operations import KustoOperationsOperations |
| 34 | +from .operations import KustoPoolOperations |
| 35 | +from .operations import KustoPoolsOperations |
| 36 | +from .operations import KustoPoolChildResourceOperations |
| 37 | +from .operations import AttachedDatabaseConfigurationsOperations |
| 38 | +from .operations import DatabasesOperations |
| 39 | +from .operations import DataConnectionsOperations |
| 40 | +from .operations import KustoPoolPrincipalAssignmentsOperations |
| 41 | +from .operations import DatabasePrincipalAssignmentsOperations |
32 | 42 | from .operations import LibraryOperations
|
33 | 43 | from .operations import LibrariesOperations
|
34 | 44 | from .operations import PrivateEndpointConnectionsOperations
|
@@ -109,6 +119,24 @@ class SynapseManagementClient(object):
|
109 | 119 | :vartype integration_runtime_status: azure.mgmt.synapse.aio.operations.IntegrationRuntimeStatusOperations
|
110 | 120 | :ivar keys: KeysOperations operations
|
111 | 121 | :vartype keys: azure.mgmt.synapse.aio.operations.KeysOperations
|
| 122 | + :ivar kusto_operations: KustoOperationsOperations operations |
| 123 | + :vartype kusto_operations: azure.mgmt.synapse.aio.operations.KustoOperationsOperations |
| 124 | + :ivar kusto_pool: KustoPoolOperations operations |
| 125 | + :vartype kusto_pool: azure.mgmt.synapse.aio.operations.KustoPoolOperations |
| 126 | + :ivar kusto_pools: KustoPoolsOperations operations |
| 127 | + :vartype kusto_pools: azure.mgmt.synapse.aio.operations.KustoPoolsOperations |
| 128 | + :ivar kusto_pool_child_resource: KustoPoolChildResourceOperations operations |
| 129 | + :vartype kusto_pool_child_resource: azure.mgmt.synapse.aio.operations.KustoPoolChildResourceOperations |
| 130 | + :ivar attached_database_configurations: AttachedDatabaseConfigurationsOperations operations |
| 131 | + :vartype attached_database_configurations: azure.mgmt.synapse.aio.operations.AttachedDatabaseConfigurationsOperations |
| 132 | + :ivar databases: DatabasesOperations operations |
| 133 | + :vartype databases: azure.mgmt.synapse.aio.operations.DatabasesOperations |
| 134 | + :ivar data_connections: DataConnectionsOperations operations |
| 135 | + :vartype data_connections: azure.mgmt.synapse.aio.operations.DataConnectionsOperations |
| 136 | + :ivar kusto_pool_principal_assignments: KustoPoolPrincipalAssignmentsOperations operations |
| 137 | + :vartype kusto_pool_principal_assignments: azure.mgmt.synapse.aio.operations.KustoPoolPrincipalAssignmentsOperations |
| 138 | + :ivar database_principal_assignments: DatabasePrincipalAssignmentsOperations operations |
| 139 | + :vartype database_principal_assignments: azure.mgmt.synapse.aio.operations.DatabasePrincipalAssignmentsOperations |
112 | 140 | :ivar library: LibraryOperations operations
|
113 | 141 | :vartype library: azure.mgmt.synapse.aio.operations.LibraryOperations
|
114 | 142 | :ivar libraries: LibrariesOperations operations
|
@@ -256,6 +284,24 @@ def __init__(
|
256 | 284 | self._client, self._config, self._serialize, self._deserialize)
|
257 | 285 | self.keys = KeysOperations(
|
258 | 286 | self._client, self._config, self._serialize, self._deserialize)
|
| 287 | + self.kusto_operations = KustoOperationsOperations( |
| 288 | + self._client, self._config, self._serialize, self._deserialize) |
| 289 | + self.kusto_pool = KustoPoolOperations( |
| 290 | + self._client, self._config, self._serialize, self._deserialize) |
| 291 | + self.kusto_pools = KustoPoolsOperations( |
| 292 | + self._client, self._config, self._serialize, self._deserialize) |
| 293 | + self.kusto_pool_child_resource = KustoPoolChildResourceOperations( |
| 294 | + self._client, self._config, self._serialize, self._deserialize) |
| 295 | + self.attached_database_configurations = AttachedDatabaseConfigurationsOperations( |
| 296 | + self._client, self._config, self._serialize, self._deserialize) |
| 297 | + self.databases = DatabasesOperations( |
| 298 | + self._client, self._config, self._serialize, self._deserialize) |
| 299 | + self.data_connections = DataConnectionsOperations( |
| 300 | + self._client, self._config, self._serialize, self._deserialize) |
| 301 | + self.kusto_pool_principal_assignments = KustoPoolPrincipalAssignmentsOperations( |
| 302 | + self._client, self._config, self._serialize, self._deserialize) |
| 303 | + self.database_principal_assignments = DatabasePrincipalAssignmentsOperations( |
| 304 | + self._client, self._config, self._serialize, self._deserialize) |
259 | 305 | self.library = LibraryOperations(
|
260 | 306 | self._client, self._config, self._serialize, self._deserialize)
|
261 | 307 | self.libraries = LibrariesOperations(
|
@@ -353,6 +399,23 @@ def __init__(
|
353 | 399 | self.restorable_dropped_sql_pools = RestorableDroppedSqlPoolsOperations(
|
354 | 400 | self._client, self._config, self._serialize, self._deserialize)
|
355 | 401 |
|
| 402 | + async def _send_request(self, http_request: HttpRequest, **kwargs: Any) -> AsyncHttpResponse: |
| 403 | + """Runs the network request through the client's chained policies. |
| 404 | +
|
| 405 | + :param http_request: The network request you want to make. Required. |
| 406 | + :type http_request: ~azure.core.pipeline.transport.HttpRequest |
| 407 | + :keyword bool stream: Whether the response payload will be streamed. Defaults to True. |
| 408 | + :return: The response of your network call. Does not do error handling on your response. |
| 409 | + :rtype: ~azure.core.pipeline.transport.AsyncHttpResponse |
| 410 | + """ |
| 411 | + path_format_arguments = { |
| 412 | + 'subscriptionId': self._serialize.url("self._config.subscription_id", self._config.subscription_id, 'str', min_length=1), |
| 413 | + } |
| 414 | + http_request.url = self._client.format_url(http_request.url, **path_format_arguments) |
| 415 | + stream = kwargs.pop("stream", True) |
| 416 | + pipeline_response = await self._client._pipeline.run(http_request, stream=stream, **kwargs) |
| 417 | + return pipeline_response.http_response |
| 418 | + |
356 | 419 | async def close(self) -> None:
|
357 | 420 | await self._client.close()
|
358 | 421 |
|
|
0 commit comments