Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

20200713 sdk automation/azure mgmt kusto #12510

Merged
merged 3 commits into from
Jul 15, 2020
Merged

20200713 sdk automation/azure mgmt kusto #12510

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
627e422
Generated from 0901facf2e66cb8033bec733d0491896d94d1e27
Jul 10, 2020
b375521
version 0.9.0
changlong-liu Jul 13, 2020
0e5862d
run test
changlong-liu Jul 13, 2020
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
9 changes: 9 additions & 0 deletions sdk/kusto/azure-mgmt-kusto/CHANGELOG.md
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -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**
Expand Down
2 changes: 1 addition & 1 deletion sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/_kusto_management_client.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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)

Expand Down
2 changes: 2 additions & 0 deletions sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/__init__.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -128,6 +128,7 @@
Compression,
IotHubDataFormat,
EventGridDataFormat,
BlobStorageEventType,
IdentityType,
DatabasePrincipalRole,
DatabasePrincipalType,
Expand Down Expand Up @@ -208,6 +209,7 @@
'Compression',
'IotHubDataFormat',
'EventGridDataFormat',
'BlobStorageEventType',
'IdentityType',
'DatabasePrincipalRole',
'DatabasePrincipalType',
Expand Down
12 changes: 12 additions & 0 deletions sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/_kusto_management_client_enums.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -109,6 +109,8 @@ class EventHubDataFormat(str, Enum):
tsve = "TSVE"
parquet = "PARQUET"
orc = "ORC"
apacheavro = "APACHEAVRO"
w3_clogfile = "W3CLOGFILE"


class Compression(str, Enum):
Expand All @@ -133,6 +135,8 @@ class IotHubDataFormat(str, Enum):
tsve = "TSVE"
parquet = "PARQUET"
orc = "ORC"
apacheavro = "APACHEAVRO"
w3_clogfile = "W3CLOGFILE"


class EventGridDataFormat(str, Enum):
Expand All @@ -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):
Expand Down
56 changes: 40 additions & 16 deletions sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/_models.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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 = {
Expand All @@ -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 = {
Expand All @@ -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):
Expand All @@ -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):
Expand Down Expand Up @@ -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 = {
Expand All @@ -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 = {
Expand All @@ -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):
Expand All @@ -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):
Expand Down Expand Up @@ -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 = {
Expand All @@ -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 = {
Expand All @@ -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):
Expand All @@ -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'


Expand Down Expand Up @@ -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]
Expand Down Expand Up @@ -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]
Expand Down
Loading