20200713 sdk automation/azure mgmt kusto (#12510)

* Generated from 0901facf2e66cb8033bec733d0491896d94d1e27 Update custom-words.txt * version 0.9.0 * run test Co-authored-by: SDK Automation <sdkautomation@microsoft.com>
Azure · Jul 15, 2020 · b20a258 · b20a258
1 parent ca42cd1
commit b20a258
Show file tree

Hide file tree

Showing 15 changed files with 566 additions and 463 deletions.
diff --git a/sdk/kusto/azure-mgmt-kusto/CHANGELOG.md b/sdk/kusto/azure-mgmt-kusto/CHANGELOG.md
@@ -1,5 +1,14 @@
 # Release History
 
+## 0.9.0 (2020-07-13)
+
+**Features**
+
+  - Model Cluster has a new parameter enable_double_encryption
+  - Model ClusterUpdate has a new parameter enable_double_encryption
+  - Model EventGridDataConnection has a new parameter blob_storage_event_type
+  - Model EventGridDataConnection has a new parameter ignore_first_record
+
 ## 0.8.0 (2020-05-31)
 
 **Breaking changes**

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
@@ -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 = '2020-02-15'
+        self.api_version = '2020-06-14'
         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
@@ -128,6 +128,7 @@
     Compression,
     IotHubDataFormat,
     EventGridDataFormat,
+    BlobStorageEventType,
     IdentityType,
     DatabasePrincipalRole,
     DatabasePrincipalType,
@@ -208,6 +209,7 @@
     'Compression',
     'IotHubDataFormat',
     'EventGridDataFormat',
+    'BlobStorageEventType',
     'IdentityType',
     'DatabasePrincipalRole',
     'DatabasePrincipalType',

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
@@ -109,6 +109,8 @@ class EventHubDataFormat(str, Enum):
     tsve = "TSVE"
     parquet = "PARQUET"
     orc = "ORC"
+    apacheavro = "APACHEAVRO"
+    w3_clogfile = "W3CLOGFILE"
 
 
 class Compression(str, Enum):
@@ -133,6 +135,8 @@ class IotHubDataFormat(str, Enum):
     tsve = "TSVE"
     parquet = "PARQUET"
     orc = "ORC"
+    apacheavro = "APACHEAVRO"
+    w3_clogfile = "W3CLOGFILE"
 
 
 class EventGridDataFormat(str, Enum):
@@ -151,6 +155,14 @@ class EventGridDataFormat(str, Enum):
     tsve = "TSVE"
     parquet = "PARQUET"
     orc = "ORC"
+    apacheavro = "APACHEAVRO"
+    w3_clogfile = "W3CLOGFILE"
+
+
+class BlobStorageEventType(str, Enum):
+
+    microsoft_storage_blob_created = "Microsoft.Storage.BlobCreated"
+    microsoft_storage_blob_renamed = "Microsoft.Storage.BlobRenamed"
 
 
 class IdentityType(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
@@ -518,8 +518,12 @@ class Cluster(TrackedResource):
     :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
+    :ivar language_extensions: List of the cluster's language extensions.
+    :vartype language_extensions:
+     ~azure.mgmt.kusto.models.LanguageExtensionsList
+    :param enable_double_encryption: A boolean value that indicates if double
+     encryption is enabled. Default value: False .
+    :type enable_double_encryption: bool
     """
 
     _validation = {
@@ -533,6 +537,7 @@ class Cluster(TrackedResource):
         'uri': {'readonly': True},
         'data_ingestion_uri': {'readonly': True},
         'state_reason': {'readonly': True},
+        'language_extensions': {'readonly': True},
     }
 
     _attribute_map = {
@@ -557,6 +562,7 @@ class Cluster(TrackedResource):
         'key_vault_properties': {'key': 'properties.keyVaultProperties', 'type': 'KeyVaultProperties'},
         'enable_purge': {'key': 'properties.enablePurge', 'type': 'bool'},
         'language_extensions': {'key': 'properties.languageExtensions', 'type': 'LanguageExtensionsList'},
+        'enable_double_encryption': {'key': 'properties.enableDoubleEncryption', 'type': 'bool'},
     }
 
     def __init__(self, **kwargs):
@@ -576,7 +582,8 @@ def __init__(self, **kwargs):
         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)
+        self.language_extensions = None
+        self.enable_double_encryption = kwargs.get('enable_double_encryption', False)
 
 
 class ClusterCheckNameRequest(Model):
@@ -775,8 +782,12 @@ class ClusterUpdate(Resource):
     :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
+    :ivar language_extensions: List of the cluster's language extensions.
+    :vartype language_extensions:
+     ~azure.mgmt.kusto.models.LanguageExtensionsList
+    :param enable_double_encryption: A boolean value that indicates if double
+     encryption is enabled. Default value: False .
+    :type enable_double_encryption: bool
     """
 
     _validation = {
@@ -788,6 +799,7 @@ class ClusterUpdate(Resource):
         'uri': {'readonly': True},
         'data_ingestion_uri': {'readonly': True},
         'state_reason': {'readonly': True},
+        'language_extensions': {'readonly': True},
     }
 
     _attribute_map = {
@@ -811,6 +823,7 @@ class ClusterUpdate(Resource):
         'key_vault_properties': {'key': 'properties.keyVaultProperties', 'type': 'KeyVaultProperties'},
         'enable_purge': {'key': 'properties.enablePurge', 'type': 'bool'},
         'language_extensions': {'key': 'properties.languageExtensions', 'type': 'LanguageExtensionsList'},
+        'enable_double_encryption': {'key': 'properties.enableDoubleEncryption', 'type': 'bool'},
     }
 
     def __init__(self, **kwargs):
@@ -831,7 +844,8 @@ def __init__(self, **kwargs):
         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)
+        self.language_extensions = None
+        self.enable_double_encryption = kwargs.get('enable_double_encryption', False)
 
 
 class Database(ProxyResource):
@@ -1278,17 +1292,25 @@ class EventGridDataConnection(DataConnection):
     :type event_hub_resource_id: str
     :param consumer_group: Required. The event hub consumer group.
     :type consumer_group: str
-    :param table_name: Required. The table where the data should be ingested.
-     Optionally the table information can be added to each message.
+    :param table_name: The table where the data should be ingested. Optionally
+     the table information can be added to each message.
     :type table_name: str
     :param mapping_rule_name: The mapping rule to be used to ingest the data.
      Optionally the mapping information can be added to each message.
     :type mapping_rule_name: str
-    :param data_format: Required. The data format of the message. Optionally
-     the data format can be added to each message. Possible values include:
-     'MULTIJSON', 'JSON', 'CSV', 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW',
-     'SINGLEJSON', 'AVRO', 'TSVE', 'PARQUET', 'ORC'
+    :param data_format: The data format of the message. Optionally the data
+     format can be added to each message. Possible values include: 'MULTIJSON',
+     'JSON', 'CSV', 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON',
+     'AVRO', 'TSVE', 'PARQUET', 'ORC', 'APACHEAVRO', 'W3CLOGFILE'
     :type data_format: str or ~azure.mgmt.kusto.models.EventGridDataFormat
+    :param ignore_first_record: A Boolean value that, if set to true,
+     indicates that ingestion should ignore the first record of every file
+    :type ignore_first_record: bool
+    :param blob_storage_event_type: The name of blob storage event type to
+     process. Possible values include: 'Microsoft.Storage.BlobCreated',
+     'Microsoft.Storage.BlobRenamed'
+    :type blob_storage_event_type: str or
+     ~azure.mgmt.kusto.models.BlobStorageEventType
     """
 
     _validation = {
@@ -1299,8 +1321,6 @@ class EventGridDataConnection(DataConnection):
         'storage_account_resource_id': {'required': True},
         'event_hub_resource_id': {'required': True},
         'consumer_group': {'required': True},
-        'table_name': {'required': True},
-        'data_format': {'required': True},
     }
 
     _attribute_map = {
@@ -1315,6 +1335,8 @@ class EventGridDataConnection(DataConnection):
         'table_name': {'key': 'properties.tableName', 'type': 'str'},
         'mapping_rule_name': {'key': 'properties.mappingRuleName', 'type': 'str'},
         'data_format': {'key': 'properties.dataFormat', 'type': 'str'},
+        'ignore_first_record': {'key': 'properties.ignoreFirstRecord', 'type': 'bool'},
+        'blob_storage_event_type': {'key': 'properties.blobStorageEventType', 'type': 'str'},
     }
 
     def __init__(self, **kwargs):
@@ -1325,6 +1347,8 @@ def __init__(self, **kwargs):
         self.table_name = kwargs.get('table_name', None)
         self.mapping_rule_name = kwargs.get('mapping_rule_name', None)
         self.data_format = kwargs.get('data_format', None)
+        self.ignore_first_record = kwargs.get('ignore_first_record', None)
+        self.blob_storage_event_type = kwargs.get('blob_storage_event_type', None)
         self.kind = 'EventGrid'
 
 
@@ -1362,7 +1386,7 @@ class EventHubDataConnection(DataConnection):
     :param data_format: The data format of the message. Optionally the data
      format can be added to each message. Possible values include: 'MULTIJSON',
      'JSON', 'CSV', 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON',
-     'AVRO', 'TSVE', 'PARQUET', 'ORC'
+     'AVRO', 'TSVE', 'PARQUET', 'ORC', 'APACHEAVRO', 'W3CLOGFILE'
     :type data_format: str or ~azure.mgmt.kusto.models.EventHubDataFormat
     :param event_system_properties: System properties of the event hub
     :type event_system_properties: list[str]
@@ -1551,7 +1575,7 @@ class IotHubDataConnection(DataConnection):
     :param data_format: The data format of the message. Optionally the data
      format can be added to each message. Possible values include: 'MULTIJSON',
      'JSON', 'CSV', 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON',
-     'AVRO', 'TSVE', 'PARQUET', 'ORC'
+     'AVRO', 'TSVE', 'PARQUET', 'ORC', 'APACHEAVRO', 'W3CLOGFILE'
     :type data_format: str or ~azure.mgmt.kusto.models.IotHubDataFormat
     :param event_system_properties: System properties of the iot hub
     :type event_system_properties: list[str]