From 922468c367bc55e6dfbb16aba7b4644f7c241504 Mon Sep 17 00:00:00 2001 From: SDK Automation Date: Fri, 13 Mar 2020 04:25:03 +0000 Subject: [PATCH] Generated from 8d03e06b679d4817d3f3ba5776043c33841ee095 . --- .../mgmt/kusto/_kusto_management_client.py | 2 +- .../azure/mgmt/kusto/models/__init__.py | 10 + .../models/_kusto_management_client_enums.py | 15 ++ .../azure/mgmt/kusto/models/_models.py | 58 +++- .../azure/mgmt/kusto/models/_models_py3.py | 62 ++++- .../azure/mgmt/kusto/models/_paged_models.py | 13 + ...ched_database_configurations_operations.py | 4 +- ...luster_principal_assignments_operations.py | 4 +- .../kusto/operations/_clusters_operations.py | 255 +++++++++++++++++- .../_data_connections_operations.py | 4 +- ...tabase_principal_assignments_operations.py | 4 +- .../kusto/operations/_databases_operations.py | 4 +- .../mgmt/kusto/operations/_operations.py | 4 +- 13 files changed, 420 insertions(+), 19 deletions(-) diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/_kusto_management_client.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/_kusto_management_client.py index d78e346ae980..5b15776f1312 100644 --- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/_kusto_management_client.py +++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/_kusto_management_client.py @@ -61,7 +61,7 @@ def __init__( super(KustoManagementClient, self).__init__(self.config.credentials, self.config) client_models = {k: v for k, v in models.__dict__.items() if isinstance(v, type)} - self.api_version = '2019-11-09' + self.api_version = '2020-02-15' self._serialize = Serializer(client_models) self._deserialize = Deserializer(client_models) diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/__init__.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/__init__.py index 0f9b411d698f..07825e1c5873 100644 --- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/__init__.py +++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/__init__.py @@ -42,6 +42,8 @@ from ._models_py3 import IdentityUserAssignedIdentitiesValue from ._models_py3 import IotHubDataConnection from ._models_py3 import KeyVaultProperties + from ._models_py3 import LanguageExtension + from ._models_py3 import LanguageExtensionsList from ._models_py3 import Operation from ._models_py3 import OperationDisplay from ._models_py3 import OptimizedAutoscale @@ -87,6 +89,8 @@ from ._models import IdentityUserAssignedIdentitiesValue from ._models import IotHubDataConnection from ._models import KeyVaultProperties + from ._models import LanguageExtension + from ._models import LanguageExtensionsList from ._models import Operation from ._models import OperationDisplay from ._models import OptimizedAutoscale @@ -108,11 +112,13 @@ from ._paged_models import DatabasePrincipalPaged from ._paged_models import DataConnectionPaged from ._paged_models import FollowerDatabaseDefinitionPaged +from ._paged_models import LanguageExtensionPaged from ._paged_models import OperationPaged from ._paged_models import SkuDescriptionPaged from ._kusto_management_client_enums import ( State, ProvisioningState, + LanguageExtensionName, AzureSkuName, AzureSkuTier, AzureScaleType, @@ -164,6 +170,8 @@ 'IdentityUserAssignedIdentitiesValue', 'IotHubDataConnection', 'KeyVaultProperties', + 'LanguageExtension', + 'LanguageExtensionsList', 'Operation', 'OperationDisplay', 'OptimizedAutoscale', @@ -180,6 +188,7 @@ 'ClusterPaged', 'SkuDescriptionPaged', 'AzureResourceSkuPaged', + 'LanguageExtensionPaged', 'ClusterPrincipalAssignmentPaged', 'DatabasePaged', 'DatabasePrincipalPaged', @@ -189,6 +198,7 @@ 'OperationPaged', 'State', 'ProvisioningState', + 'LanguageExtensionName', 'AzureSkuName', 'AzureSkuTier', 'AzureScaleType', diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/_kusto_management_client_enums.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/_kusto_management_client_enums.py index d9d07ddc6a59..1e1fc88897ea 100644 --- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/_kusto_management_client_enums.py +++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/_kusto_management_client_enums.py @@ -35,6 +35,12 @@ class ProvisioningState(str, Enum): moving = "Moving" +class LanguageExtensionName(str, Enum): + + python = "PYTHON" + r = "R" + + class AzureSkuName(str, Enum): standard_ds13_v21_tb_ps = "Standard_DS13_v2+1TB_PS" @@ -49,6 +55,15 @@ class AzureSkuName(str, Enum): standard_d12_v2 = "Standard_D12_v2" standard_l4s = "Standard_L4s" dev_no_sla_standard_d11_v2 = "Dev(No SLA)_Standard_D11_v2" + standard_e2a_v4 = "Standard_E2a_v4" + standard_e4a_v4 = "Standard_E4a_v4" + standard_e8a_v4 = "Standard_E8a_v4" + standard_e16a_v4 = "Standard_E16a_v4" + standard_e8as_v41_tb_ps = "Standard_E8as_v4+1TB_PS" + standard_e8as_v42_tb_ps = "Standard_E8as_v4+2TB_PS" + standard_e16as_v43_tb_ps = "Standard_E16as_v4+3TB_PS" + standard_e16as_v44_tb_ps = "Standard_E16as_v4+4TB_PS" + dev_no_sla_standard_e2a_v4 = "Dev(No SLA)_Standard_E2a_v4" class AzureSkuTier(str, Enum): diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/_models.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/_models.py index 19341e13ec4e..906f68d73775 100644 --- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/_models.py +++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/_models.py @@ -263,7 +263,11 @@ class AzureSku(Model): 'Standard_DS13_v2+1TB_PS', 'Standard_DS13_v2+2TB_PS', 'Standard_DS14_v2+3TB_PS', 'Standard_DS14_v2+4TB_PS', 'Standard_D13_v2', 'Standard_D14_v2', 'Standard_L8s', 'Standard_L16s', 'Standard_D11_v2', - 'Standard_D12_v2', 'Standard_L4s', 'Dev(No SLA)_Standard_D11_v2' + 'Standard_D12_v2', 'Standard_L4s', 'Dev(No SLA)_Standard_D11_v2', + 'Standard_E2a_v4', 'Standard_E4a_v4', 'Standard_E8a_v4', + 'Standard_E16a_v4', 'Standard_E8as_v4+1TB_PS', 'Standard_E8as_v4+2TB_PS', + 'Standard_E16as_v4+3TB_PS', 'Standard_E16as_v4+4TB_PS', 'Dev(No + SLA)_Standard_E2a_v4' :type name: str or ~azure.mgmt.kusto.models.AzureSkuName :param capacity: The number of instances of the cluster. :type capacity: int @@ -511,6 +515,11 @@ class Cluster(TrackedResource): :param key_vault_properties: KeyVault properties for the cluster encryption. :type key_vault_properties: ~azure.mgmt.kusto.models.KeyVaultProperties + :param enable_purge: A boolean value that indicates if the purge + operations are enabled. Default value: False . + :type enable_purge: bool + :param language_extensions: List of the cluster's language extensions. + :type language_extensions: ~azure.mgmt.kusto.models.LanguageExtensionsList """ _validation = { @@ -546,6 +555,8 @@ class Cluster(TrackedResource): 'enable_streaming_ingest': {'key': 'properties.enableStreamingIngest', 'type': 'bool'}, 'virtual_network_configuration': {'key': 'properties.virtualNetworkConfiguration', 'type': 'VirtualNetworkConfiguration'}, 'key_vault_properties': {'key': 'properties.keyVaultProperties', 'type': 'KeyVaultProperties'}, + 'enable_purge': {'key': 'properties.enablePurge', 'type': 'bool'}, + 'language_extensions': {'key': 'properties.languageExtensions', 'type': 'LanguageExtensionsList'}, } def __init__(self, **kwargs): @@ -564,6 +575,8 @@ def __init__(self, **kwargs): self.enable_streaming_ingest = kwargs.get('enable_streaming_ingest', False) self.virtual_network_configuration = kwargs.get('virtual_network_configuration', None) self.key_vault_properties = kwargs.get('key_vault_properties', None) + self.enable_purge = kwargs.get('enable_purge', False) + self.language_extensions = kwargs.get('language_extensions', None) class ClusterCheckNameRequest(Model): @@ -759,6 +772,11 @@ class ClusterUpdate(Resource): :param key_vault_properties: KeyVault properties for the cluster encryption. :type key_vault_properties: ~azure.mgmt.kusto.models.KeyVaultProperties + :param enable_purge: A boolean value that indicates if the purge + operations are enabled. Default value: False . + :type enable_purge: bool + :param language_extensions: List of the cluster's language extensions. + :type language_extensions: ~azure.mgmt.kusto.models.LanguageExtensionsList """ _validation = { @@ -791,6 +809,8 @@ class ClusterUpdate(Resource): 'enable_streaming_ingest': {'key': 'properties.enableStreamingIngest', 'type': 'bool'}, 'virtual_network_configuration': {'key': 'properties.virtualNetworkConfiguration', 'type': 'VirtualNetworkConfiguration'}, 'key_vault_properties': {'key': 'properties.keyVaultProperties', 'type': 'KeyVaultProperties'}, + 'enable_purge': {'key': 'properties.enablePurge', 'type': 'bool'}, + 'language_extensions': {'key': 'properties.languageExtensions', 'type': 'LanguageExtensionsList'}, } def __init__(self, **kwargs): @@ -810,6 +830,8 @@ def __init__(self, **kwargs): self.enable_streaming_ingest = kwargs.get('enable_streaming_ingest', False) self.virtual_network_configuration = kwargs.get('virtual_network_configuration', None) self.key_vault_properties = kwargs.get('key_vault_properties', None) + self.enable_purge = kwargs.get('enable_purge', False) + self.language_extensions = kwargs.get('language_extensions', None) class Database(ProxyResource): @@ -1607,6 +1629,40 @@ def __init__(self, **kwargs): self.key_vault_uri = kwargs.get('key_vault_uri', None) +class LanguageExtension(Model): + """The language extension object. + + :param language_extension_name: The language extension name. Possible + values include: 'PYTHON', 'R' + :type language_extension_name: str or + ~azure.mgmt.kusto.models.LanguageExtensionName + """ + + _attribute_map = { + 'language_extension_name': {'key': 'languageExtensionName', 'type': 'str'}, + } + + def __init__(self, **kwargs): + super(LanguageExtension, self).__init__(**kwargs) + self.language_extension_name = kwargs.get('language_extension_name', None) + + +class LanguageExtensionsList(Model): + """The list of language extension objects. + + :param value: The list of language extensions. + :type value: list[~azure.mgmt.kusto.models.LanguageExtension] + """ + + _attribute_map = { + 'value': {'key': 'value', 'type': '[LanguageExtension]'}, + } + + def __init__(self, **kwargs): + super(LanguageExtensionsList, self).__init__(**kwargs) + self.value = kwargs.get('value', None) + + class Operation(Model): """A REST API operation. diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/_models_py3.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/_models_py3.py index 81bc114d2fa7..7008b25fb1b0 100644 --- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/_models_py3.py +++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/_models_py3.py @@ -263,7 +263,11 @@ class AzureSku(Model): 'Standard_DS13_v2+1TB_PS', 'Standard_DS13_v2+2TB_PS', 'Standard_DS14_v2+3TB_PS', 'Standard_DS14_v2+4TB_PS', 'Standard_D13_v2', 'Standard_D14_v2', 'Standard_L8s', 'Standard_L16s', 'Standard_D11_v2', - 'Standard_D12_v2', 'Standard_L4s', 'Dev(No SLA)_Standard_D11_v2' + 'Standard_D12_v2', 'Standard_L4s', 'Dev(No SLA)_Standard_D11_v2', + 'Standard_E2a_v4', 'Standard_E4a_v4', 'Standard_E8a_v4', + 'Standard_E16a_v4', 'Standard_E8as_v4+1TB_PS', 'Standard_E8as_v4+2TB_PS', + 'Standard_E16as_v4+3TB_PS', 'Standard_E16as_v4+4TB_PS', 'Dev(No + SLA)_Standard_E2a_v4' :type name: str or ~azure.mgmt.kusto.models.AzureSkuName :param capacity: The number of instances of the cluster. :type capacity: int @@ -511,6 +515,11 @@ class Cluster(TrackedResource): :param key_vault_properties: KeyVault properties for the cluster encryption. :type key_vault_properties: ~azure.mgmt.kusto.models.KeyVaultProperties + :param enable_purge: A boolean value that indicates if the purge + operations are enabled. Default value: False . + :type enable_purge: bool + :param language_extensions: List of the cluster's language extensions. + :type language_extensions: ~azure.mgmt.kusto.models.LanguageExtensionsList """ _validation = { @@ -546,9 +555,11 @@ class Cluster(TrackedResource): 'enable_streaming_ingest': {'key': 'properties.enableStreamingIngest', 'type': 'bool'}, 'virtual_network_configuration': {'key': 'properties.virtualNetworkConfiguration', 'type': 'VirtualNetworkConfiguration'}, 'key_vault_properties': {'key': 'properties.keyVaultProperties', 'type': 'KeyVaultProperties'}, + 'enable_purge': {'key': 'properties.enablePurge', 'type': 'bool'}, + 'language_extensions': {'key': 'properties.languageExtensions', 'type': 'LanguageExtensionsList'}, } - def __init__(self, *, location: str, sku, tags=None, zones=None, identity=None, trusted_external_tenants=None, optimized_autoscale=None, enable_disk_encryption: bool=None, enable_streaming_ingest: bool=False, virtual_network_configuration=None, key_vault_properties=None, **kwargs) -> None: + def __init__(self, *, location: str, sku, tags=None, zones=None, identity=None, trusted_external_tenants=None, optimized_autoscale=None, enable_disk_encryption: bool=None, enable_streaming_ingest: bool=False, virtual_network_configuration=None, key_vault_properties=None, enable_purge: bool=False, language_extensions=None, **kwargs) -> None: super(Cluster, self).__init__(tags=tags, location=location, **kwargs) self.sku = sku self.zones = zones @@ -564,6 +575,8 @@ def __init__(self, *, location: str, sku, tags=None, zones=None, identity=None, self.enable_streaming_ingest = enable_streaming_ingest self.virtual_network_configuration = virtual_network_configuration self.key_vault_properties = key_vault_properties + self.enable_purge = enable_purge + self.language_extensions = language_extensions class ClusterCheckNameRequest(Model): @@ -759,6 +772,11 @@ class ClusterUpdate(Resource): :param key_vault_properties: KeyVault properties for the cluster encryption. :type key_vault_properties: ~azure.mgmt.kusto.models.KeyVaultProperties + :param enable_purge: A boolean value that indicates if the purge + operations are enabled. Default value: False . + :type enable_purge: bool + :param language_extensions: List of the cluster's language extensions. + :type language_extensions: ~azure.mgmt.kusto.models.LanguageExtensionsList """ _validation = { @@ -791,9 +809,11 @@ class ClusterUpdate(Resource): 'enable_streaming_ingest': {'key': 'properties.enableStreamingIngest', 'type': 'bool'}, 'virtual_network_configuration': {'key': 'properties.virtualNetworkConfiguration', 'type': 'VirtualNetworkConfiguration'}, 'key_vault_properties': {'key': 'properties.keyVaultProperties', 'type': 'KeyVaultProperties'}, + 'enable_purge': {'key': 'properties.enablePurge', 'type': 'bool'}, + 'language_extensions': {'key': 'properties.languageExtensions', 'type': 'LanguageExtensionsList'}, } - def __init__(self, *, tags=None, location: str=None, sku=None, identity=None, trusted_external_tenants=None, optimized_autoscale=None, enable_disk_encryption: bool=None, enable_streaming_ingest: bool=False, virtual_network_configuration=None, key_vault_properties=None, **kwargs) -> None: + def __init__(self, *, tags=None, location: str=None, sku=None, identity=None, trusted_external_tenants=None, optimized_autoscale=None, enable_disk_encryption: bool=None, enable_streaming_ingest: bool=False, virtual_network_configuration=None, key_vault_properties=None, enable_purge: bool=False, language_extensions=None, **kwargs) -> None: super(ClusterUpdate, self).__init__(**kwargs) self.tags = tags self.location = location @@ -810,6 +830,8 @@ def __init__(self, *, tags=None, location: str=None, sku=None, identity=None, tr self.enable_streaming_ingest = enable_streaming_ingest self.virtual_network_configuration = virtual_network_configuration self.key_vault_properties = key_vault_properties + self.enable_purge = enable_purge + self.language_extensions = language_extensions class Database(ProxyResource): @@ -1607,6 +1629,40 @@ def __init__(self, *, key_name: str, key_version: str, key_vault_uri: str, **kwa self.key_vault_uri = key_vault_uri +class LanguageExtension(Model): + """The language extension object. + + :param language_extension_name: The language extension name. Possible + values include: 'PYTHON', 'R' + :type language_extension_name: str or + ~azure.mgmt.kusto.models.LanguageExtensionName + """ + + _attribute_map = { + 'language_extension_name': {'key': 'languageExtensionName', 'type': 'str'}, + } + + def __init__(self, *, language_extension_name=None, **kwargs) -> None: + super(LanguageExtension, self).__init__(**kwargs) + self.language_extension_name = language_extension_name + + +class LanguageExtensionsList(Model): + """The list of language extension objects. + + :param value: The list of language extensions. + :type value: list[~azure.mgmt.kusto.models.LanguageExtension] + """ + + _attribute_map = { + 'value': {'key': 'value', 'type': '[LanguageExtension]'}, + } + + def __init__(self, *, value=None, **kwargs) -> None: + super(LanguageExtensionsList, self).__init__(**kwargs) + self.value = value + + class Operation(Model): """A REST API operation. diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/_paged_models.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/_paged_models.py index a0bcc63dbb36..ce8562c108fa 100644 --- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/_paged_models.py +++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/_paged_models.py @@ -64,6 +64,19 @@ class AzureResourceSkuPaged(Paged): def __init__(self, *args, **kwargs): super(AzureResourceSkuPaged, self).__init__(*args, **kwargs) +class LanguageExtensionPaged(Paged): + """ + A paging container for iterating over a list of :class:`LanguageExtension ` object + """ + + _attribute_map = { + 'next_link': {'key': 'nextLink', 'type': 'str'}, + 'current_page': {'key': 'value', 'type': '[LanguageExtension]'} + } + + def __init__(self, *args, **kwargs): + + super(LanguageExtensionPaged, self).__init__(*args, **kwargs) class ClusterPrincipalAssignmentPaged(Paged): """ A paging container for iterating over a list of :class:`ClusterPrincipalAssignment ` object diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_attached_database_configurations_operations.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_attached_database_configurations_operations.py index fa6a608e66ec..f3b117f8efc7 100644 --- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_attached_database_configurations_operations.py +++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_attached_database_configurations_operations.py @@ -27,7 +27,7 @@ class AttachedDatabaseConfigurationsOperations(object): :param config: Configuration of service client. :param serializer: An object model serializer. :param deserializer: An object model deserializer. - :ivar api_version: Client API Version. Constant value: "2019-11-09". + :ivar api_version: Client API Version. Constant value: "2020-02-15". """ models = models @@ -37,7 +37,7 @@ def __init__(self, client, config, serializer, deserializer): self._client = client self._serialize = serializer self._deserialize = deserializer - self.api_version = "2019-11-09" + self.api_version = "2020-02-15" self.config = config diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_cluster_principal_assignments_operations.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_cluster_principal_assignments_operations.py index 2151ca53cd87..f5629e11f981 100644 --- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_cluster_principal_assignments_operations.py +++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_cluster_principal_assignments_operations.py @@ -27,7 +27,7 @@ class ClusterPrincipalAssignmentsOperations(object): :param config: Configuration of service client. :param serializer: An object model serializer. :param deserializer: An object model deserializer. - :ivar api_version: Client API Version. Constant value: "2019-11-09". + :ivar api_version: Client API Version. Constant value: "2020-02-15". """ models = models @@ -37,7 +37,7 @@ def __init__(self, client, config, serializer, deserializer): self._client = client self._serialize = serializer self._deserialize = deserializer - self.api_version = "2019-11-09" + self.api_version = "2020-02-15" self.config = config diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_clusters_operations.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_clusters_operations.py index 473c378af5e2..8a38204a2ee4 100644 --- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_clusters_operations.py +++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_clusters_operations.py @@ -27,7 +27,7 @@ class ClustersOperations(object): :param config: Configuration of service client. :param serializer: An object model serializer. :param deserializer: An object model deserializer. - :ivar api_version: Client API Version. Constant value: "2019-11-09". + :ivar api_version: Client API Version. Constant value: "2020-02-15". """ models = models @@ -37,7 +37,7 @@ def __init__(self, client, config, serializer, deserializer): self._client = client self._serialize = serializer self._deserialize = deserializer - self.api_version = "2019-11-09" + self.api_version = "2020-02-15" self.config = config @@ -1157,3 +1157,254 @@ def internal_paging(next_link=None): return deserialized list_skus_by_resource.metadata = {'url': '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Kusto/clusters/{clusterName}/skus'} + + def list_language_extensions( + self, resource_group_name, cluster_name, custom_headers=None, raw=False, **operation_config): + """Returns a list of language extensions that can run within KQL queries. + + :param resource_group_name: The name of the resource group containing + the Kusto cluster. + :type resource_group_name: str + :param cluster_name: The name of the Kusto cluster. + :type cluster_name: str + :param dict custom_headers: headers that will be added to the request + :param bool raw: returns the direct response alongside the + deserialized response + :param operation_config: :ref:`Operation configuration + overrides`. + :return: An iterator like instance of LanguageExtension + :rtype: + ~azure.mgmt.kusto.models.LanguageExtensionPaged[~azure.mgmt.kusto.models.LanguageExtension] + :raises: :class:`CloudError` + """ + def prepare_request(next_link=None): + if not next_link: + # Construct URL + url = self.list_language_extensions.metadata['url'] + path_format_arguments = { + 'subscriptionId': self._serialize.url("self.config.subscription_id", self.config.subscription_id, 'str'), + 'resourceGroupName': self._serialize.url("resource_group_name", resource_group_name, 'str'), + 'clusterName': self._serialize.url("cluster_name", cluster_name, 'str') + } + url = self._client.format_url(url, **path_format_arguments) + + # Construct parameters + query_parameters = {} + query_parameters['api-version'] = self._serialize.query("self.api_version", self.api_version, 'str') + + else: + url = next_link + query_parameters = {} + + # Construct headers + header_parameters = {} + header_parameters['Accept'] = 'application/json' + if self.config.generate_client_request_id: + header_parameters['x-ms-client-request-id'] = str(uuid.uuid1()) + if custom_headers: + header_parameters.update(custom_headers) + if self.config.accept_language is not None: + header_parameters['accept-language'] = self._serialize.header("self.config.accept_language", self.config.accept_language, 'str') + + # Construct and send request + request = self._client.post(url, query_parameters, header_parameters) + return request + + def internal_paging(next_link=None): + request = prepare_request(next_link) + + response = self._client.send(request, stream=False, **operation_config) + + if response.status_code not in [200]: + exp = CloudError(response) + exp.request_id = response.headers.get('x-ms-request-id') + raise exp + + return response + + # Deserialize response + header_dict = None + if raw: + header_dict = {} + deserialized = models.LanguageExtensionPaged(internal_paging, self._deserialize.dependencies, header_dict) + + return deserialized + list_language_extensions.metadata = {'url': '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Kusto/clusters/{clusterName}/listLanguageExtensions'} + + + def _add_language_extensions_initial( + self, resource_group_name, cluster_name, value=None, custom_headers=None, raw=False, **operation_config): + language_extensions_to_add = models.LanguageExtensionsList(value=value) + + # Construct URL + url = self.add_language_extensions.metadata['url'] + path_format_arguments = { + 'subscriptionId': self._serialize.url("self.config.subscription_id", self.config.subscription_id, 'str'), + 'resourceGroupName': self._serialize.url("resource_group_name", resource_group_name, 'str'), + 'clusterName': self._serialize.url("cluster_name", cluster_name, 'str') + } + url = self._client.format_url(url, **path_format_arguments) + + # Construct parameters + query_parameters = {} + query_parameters['api-version'] = self._serialize.query("self.api_version", self.api_version, 'str') + + # Construct headers + header_parameters = {} + header_parameters['Content-Type'] = 'application/json; charset=utf-8' + if self.config.generate_client_request_id: + header_parameters['x-ms-client-request-id'] = str(uuid.uuid1()) + if custom_headers: + header_parameters.update(custom_headers) + if self.config.accept_language is not None: + header_parameters['accept-language'] = self._serialize.header("self.config.accept_language", self.config.accept_language, 'str') + + # Construct body + body_content = self._serialize.body(language_extensions_to_add, 'LanguageExtensionsList') + + # Construct and send request + request = self._client.post(url, query_parameters, header_parameters, body_content) + response = self._client.send(request, stream=False, **operation_config) + + if response.status_code not in [200, 202]: + exp = CloudError(response) + exp.request_id = response.headers.get('x-ms-request-id') + raise exp + + if raw: + client_raw_response = ClientRawResponse(None, response) + return client_raw_response + + def add_language_extensions( + self, resource_group_name, cluster_name, value=None, custom_headers=None, raw=False, polling=True, **operation_config): + """Add a list of language extensions that can run within KQL queries. + + :param resource_group_name: The name of the resource group containing + the Kusto cluster. + :type resource_group_name: str + :param cluster_name: The name of the Kusto cluster. + :type cluster_name: str + :param value: The list of language extensions. + :type value: list[~azure.mgmt.kusto.models.LanguageExtension] + :param dict custom_headers: headers that will be added to the request + :param bool raw: The poller return type is ClientRawResponse, the + direct response alongside the deserialized response + :param polling: True for ARMPolling, False for no polling, or a + polling object for personal polling strategy + :return: An instance of LROPoller that returns None or + ClientRawResponse if raw==True + :rtype: ~msrestazure.azure_operation.AzureOperationPoller[None] or + ~msrestazure.azure_operation.AzureOperationPoller[~msrest.pipeline.ClientRawResponse[None]] + :raises: :class:`CloudError` + """ + raw_result = self._add_language_extensions_initial( + resource_group_name=resource_group_name, + cluster_name=cluster_name, + value=value, + custom_headers=custom_headers, + raw=True, + **operation_config + ) + + def get_long_running_output(response): + if raw: + client_raw_response = ClientRawResponse(None, response) + return client_raw_response + + lro_delay = operation_config.get( + 'long_running_operation_timeout', + self.config.long_running_operation_timeout) + if polling is True: polling_method = ARMPolling(lro_delay, **operation_config) + elif polling is False: polling_method = NoPolling() + else: polling_method = polling + return LROPoller(self._client, raw_result, get_long_running_output, polling_method) + add_language_extensions.metadata = {'url': '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Kusto/clusters/{clusterName}/addLanguageExtensions'} + + + def _remove_language_extensions_initial( + self, resource_group_name, cluster_name, value=None, custom_headers=None, raw=False, **operation_config): + language_extensions_to_remove = models.LanguageExtensionsList(value=value) + + # Construct URL + url = self.remove_language_extensions.metadata['url'] + path_format_arguments = { + 'subscriptionId': self._serialize.url("self.config.subscription_id", self.config.subscription_id, 'str'), + 'resourceGroupName': self._serialize.url("resource_group_name", resource_group_name, 'str'), + 'clusterName': self._serialize.url("cluster_name", cluster_name, 'str') + } + url = self._client.format_url(url, **path_format_arguments) + + # Construct parameters + query_parameters = {} + query_parameters['api-version'] = self._serialize.query("self.api_version", self.api_version, 'str') + + # Construct headers + header_parameters = {} + header_parameters['Content-Type'] = 'application/json; charset=utf-8' + if self.config.generate_client_request_id: + header_parameters['x-ms-client-request-id'] = str(uuid.uuid1()) + if custom_headers: + header_parameters.update(custom_headers) + if self.config.accept_language is not None: + header_parameters['accept-language'] = self._serialize.header("self.config.accept_language", self.config.accept_language, 'str') + + # Construct body + body_content = self._serialize.body(language_extensions_to_remove, 'LanguageExtensionsList') + + # Construct and send request + request = self._client.post(url, query_parameters, header_parameters, body_content) + response = self._client.send(request, stream=False, **operation_config) + + if response.status_code not in [200, 202]: + exp = CloudError(response) + exp.request_id = response.headers.get('x-ms-request-id') + raise exp + + if raw: + client_raw_response = ClientRawResponse(None, response) + return client_raw_response + + def remove_language_extensions( + self, resource_group_name, cluster_name, value=None, custom_headers=None, raw=False, polling=True, **operation_config): + """Remove a list of language extensions that can run within KQL queries. + + :param resource_group_name: The name of the resource group containing + the Kusto cluster. + :type resource_group_name: str + :param cluster_name: The name of the Kusto cluster. + :type cluster_name: str + :param value: The list of language extensions. + :type value: list[~azure.mgmt.kusto.models.LanguageExtension] + :param dict custom_headers: headers that will be added to the request + :param bool raw: The poller return type is ClientRawResponse, the + direct response alongside the deserialized response + :param polling: True for ARMPolling, False for no polling, or a + polling object for personal polling strategy + :return: An instance of LROPoller that returns None or + ClientRawResponse if raw==True + :rtype: ~msrestazure.azure_operation.AzureOperationPoller[None] or + ~msrestazure.azure_operation.AzureOperationPoller[~msrest.pipeline.ClientRawResponse[None]] + :raises: :class:`CloudError` + """ + raw_result = self._remove_language_extensions_initial( + resource_group_name=resource_group_name, + cluster_name=cluster_name, + value=value, + custom_headers=custom_headers, + raw=True, + **operation_config + ) + + def get_long_running_output(response): + if raw: + client_raw_response = ClientRawResponse(None, response) + return client_raw_response + + lro_delay = operation_config.get( + 'long_running_operation_timeout', + self.config.long_running_operation_timeout) + if polling is True: polling_method = ARMPolling(lro_delay, **operation_config) + elif polling is False: polling_method = NoPolling() + else: polling_method = polling + return LROPoller(self._client, raw_result, get_long_running_output, polling_method) + remove_language_extensions.metadata = {'url': '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Kusto/clusters/{clusterName}/removeLanguageExtensions'} diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_data_connections_operations.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_data_connections_operations.py index dadcd830e0d1..b174abea75dd 100644 --- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_data_connections_operations.py +++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_data_connections_operations.py @@ -27,7 +27,7 @@ class DataConnectionsOperations(object): :param config: Configuration of service client. :param serializer: An object model serializer. :param deserializer: An object model deserializer. - :ivar api_version: Client API Version. Constant value: "2019-11-09". + :ivar api_version: Client API Version. Constant value: "2020-02-15". """ models = models @@ -37,7 +37,7 @@ def __init__(self, client, config, serializer, deserializer): self._client = client self._serialize = serializer self._deserialize = deserializer - self.api_version = "2019-11-09" + self.api_version = "2020-02-15" self.config = config diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_database_principal_assignments_operations.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_database_principal_assignments_operations.py index e31567b5e1ea..49122e09b978 100644 --- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_database_principal_assignments_operations.py +++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_database_principal_assignments_operations.py @@ -27,7 +27,7 @@ class DatabasePrincipalAssignmentsOperations(object): :param config: Configuration of service client. :param serializer: An object model serializer. :param deserializer: An object model deserializer. - :ivar api_version: Client API Version. Constant value: "2019-11-09". + :ivar api_version: Client API Version. Constant value: "2020-02-15". """ models = models @@ -37,7 +37,7 @@ def __init__(self, client, config, serializer, deserializer): self._client = client self._serialize = serializer self._deserialize = deserializer - self.api_version = "2019-11-09" + self.api_version = "2020-02-15" self.config = config diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_databases_operations.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_databases_operations.py index 77d40b84ad29..c1aa5100d037 100644 --- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_databases_operations.py +++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_databases_operations.py @@ -27,7 +27,7 @@ class DatabasesOperations(object): :param config: Configuration of service client. :param serializer: An object model serializer. :param deserializer: An object model deserializer. - :ivar api_version: Client API Version. Constant value: "2019-11-09". + :ivar api_version: Client API Version. Constant value: "2020-02-15". """ models = models @@ -37,7 +37,7 @@ def __init__(self, client, config, serializer, deserializer): self._client = client self._serialize = serializer self._deserialize = deserializer - self.api_version = "2019-11-09" + self.api_version = "2020-02-15" self.config = config diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_operations.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_operations.py index 444db1b77143..6c0e7ac91645 100644 --- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_operations.py +++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_operations.py @@ -25,7 +25,7 @@ class Operations(object): :param config: Configuration of service client. :param serializer: An object model serializer. :param deserializer: An object model deserializer. - :ivar api_version: Client API Version. Constant value: "2019-11-09". + :ivar api_version: Client API Version. Constant value: "2020-02-15". """ models = models @@ -35,7 +35,7 @@ def __init__(self, client, config, serializer, deserializer): self._client = client self._serialize = serializer self._deserialize = deserializer - self.api_version = "2019-11-09" + self.api_version = "2020-02-15" self.config = config