[Storage]STG73

sdk/storage/azure-storage-blob/azure/storage/blob/_generated/_azure_blob_storage.py

@@ -55,7 +55,7 @@ def __init__(self, url, **kwargs):
         self._client = PipelineClient(base_url=base_url, config=self._config, **kwargs)
 
         client_models = {k: v for k, v in models.__dict__.items() if isinstance(v, type)}
-        self.api_version = '2019-07-07'
+        self.api_version = '2019-12-12'
         self._serialize = Serializer(client_models)
         self._deserialize = Deserializer(client_models)
 

sdk/storage/azure-storage-blob/azure/storage/blob/_generated/_configuration.py

@@ -40,7 +40,7 @@ def __init__(self, url, **kwargs):
         self.generate_client_request_id = True
 
         self.url = url
-        self.version = "2019-07-07"
+        self.version = "2019-12-12"
 
     def _configure(self, **kwargs):
         self.user_agent_policy = kwargs.get('user_agent_policy') or policies.UserAgentPolicy(**kwargs)

sdk/storage/azure-storage-blob/azure/storage/blob/_generated/aio/_azure_blob_storage_async.py

@@ -56,7 +56,7 @@ def __init__(
         self._client = AsyncPipelineClient(base_url=base_url, config=self._config, **kwargs)
 
         client_models = {k: v for k, v in models.__dict__.items() if isinstance(v, type)}
-        self.api_version = '2019-07-07'
+        self.api_version = '2019-12-12'
         self._serialize = Serializer(client_models)
         self._deserialize = Deserializer(client_models)
 

sdk/storage/azure-storage-blob/azure/storage/blob/_generated/aio/_configuration_async.py

@@ -41,7 +41,7 @@ def __init__(self, url, **kwargs):
         self.accept_language = None
 
         self.url = url
-        self.version = "2019-07-07"
+        self.version = "2019-12-12"
 
     def _configure(self, **kwargs):
         self.user_agent_policy = kwargs.get('user_agent_policy') or policies.UserAgentPolicy(**kwargs)

sdk/storage/azure-storage-blob/azure/storage/blob/_generated/aio/operations_async/_append_blob_operations_async.py

@@ -200,6 +200,7 @@ async def create(self, content_length, timeout=None, metadata=None, request_id=N
                 'x-ms-client-request-id': self._deserialize('str', response.headers.get('x-ms-client-request-id')),
                 'x-ms-request-id': self._deserialize('str', response.headers.get('x-ms-request-id')),
                 'x-ms-version': self._deserialize('str', response.headers.get('x-ms-version')),
+                'x-ms-version-id': self._deserialize('str', response.headers.get('x-ms-version-id')),
                 'Date': self._deserialize('rfc-1123', response.headers.get('Date')),
                 'x-ms-request-server-encrypted': self._deserialize('bool', response.headers.get('x-ms-request-server-encrypted')),
                 'x-ms-encryption-key-sha256': self._deserialize('str', response.headers.get('x-ms-encryption-key-sha256')),

sdk/storage/azure-storage-blob/azure/storage/blob/_generated/aio/operations_async/_block_blob_operations_async.py

@@ -219,6 +219,7 @@ async def upload(self, body, content_length, timeout=None, transactional_content
                 'x-ms-client-request-id': self._deserialize('str', response.headers.get('x-ms-client-request-id')),
                 'x-ms-request-id': self._deserialize('str', response.headers.get('x-ms-request-id')),
                 'x-ms-version': self._deserialize('str', response.headers.get('x-ms-version')),
+                'x-ms-version-id': self._deserialize('str', response.headers.get('x-ms-version-id')),
                 'Date': self._deserialize('rfc-1123', response.headers.get('Date')),
                 'x-ms-request-server-encrypted': self._deserialize('bool', response.headers.get('x-ms-request-server-encrypted')),
                 'x-ms-encryption-key-sha256': self._deserialize('str', response.headers.get('x-ms-encryption-key-sha256')),
@@ -695,6 +696,7 @@ async def commit_block_list(self, blocks, timeout=None, transactional_content_md
                 'x-ms-client-request-id': self._deserialize('str', response.headers.get('x-ms-client-request-id')),
                 'x-ms-request-id': self._deserialize('str', response.headers.get('x-ms-request-id')),
                 'x-ms-version': self._deserialize('str', response.headers.get('x-ms-version')),
+                'x-ms-version-id': self._deserialize('str', response.headers.get('x-ms-version-id')),
                 'Date': self._deserialize('rfc-1123', response.headers.get('Date')),
                 'x-ms-request-server-encrypted': self._deserialize('bool', response.headers.get('x-ms-request-server-encrypted')),
                 'x-ms-encryption-key-sha256': self._deserialize('str', response.headers.get('x-ms-encryption-key-sha256')),

sdk/storage/azure-storage-blob/azure/storage/blob/_generated/aio/operations_async/_page_blob_operations_async.py

@@ -216,6 +216,7 @@ async def create(self, content_length, blob_content_length, timeout=None, tier=N
                 'x-ms-client-request-id': self._deserialize('str', response.headers.get('x-ms-client-request-id')),
                 'x-ms-request-id': self._deserialize('str', response.headers.get('x-ms-request-id')),
                 'x-ms-version': self._deserialize('str', response.headers.get('x-ms-version')),
+                'x-ms-version-id': self._deserialize('str', response.headers.get('x-ms-version-id')),
                 'Date': self._deserialize('rfc-1123', response.headers.get('Date')),
                 'x-ms-request-server-encrypted': self._deserialize('bool', response.headers.get('x-ms-request-server-encrypted')),
                 'x-ms-encryption-key-sha256': self._deserialize('str', response.headers.get('x-ms-encryption-key-sha256')),

sdk/storage/azure-storage-blob/azure/storage/blob/_generated/models/__init__.py

@@ -31,8 +31,10 @@
     from ._models_py3 import CpkScopeInfo
     from ._models_py3 import DataLakeStorageError, DataLakeStorageErrorException
     from ._models_py3 import DataLakeStorageErrorError
+    from ._models_py3 import DelimitedTextConfiguration
     from ._models_py3 import DirectoryHttpHeaders
     from ._models_py3 import GeoReplication
+    from ._models_py3 import JsonTextConfiguration
     from ._models_py3 import KeyInfo
     from ._models_py3 import LeaseAccessConditions
     from ._models_py3 import ListBlobsFlatSegmentResponse
@@ -43,6 +45,9 @@
     from ._models_py3 import ModifiedAccessConditions
     from ._models_py3 import PageList
     from ._models_py3 import PageRange
+    from ._models_py3 import QueryRequest
+    from ._models_py3 import QuickQueryFormat
+    from ._models_py3 import QuickQuerySerialization
     from ._models_py3 import RetentionPolicy
     from ._models_py3 import SequenceNumberAccessConditions
     from ._models_py3 import SignedIdentifier
@@ -74,8 +79,10 @@
     from ._models import CpkScopeInfo
     from ._models import DataLakeStorageError, DataLakeStorageErrorException
     from ._models import DataLakeStorageErrorError
+    from ._models import DelimitedTextConfiguration
     from ._models import DirectoryHttpHeaders
     from ._models import GeoReplication
+    from ._models import JsonTextConfiguration
     from ._models import KeyInfo
     from ._models import LeaseAccessConditions
     from ._models import ListBlobsFlatSegmentResponse
@@ -86,6 +93,9 @@
     from ._models import ModifiedAccessConditions
     from ._models import PageList
     from ._models import PageRange
+    from ._models import QueryRequest
+    from ._models import QuickQueryFormat
+    from ._models import QuickQuerySerialization
     from ._models import RetentionPolicy
     from ._models import SequenceNumberAccessConditions
     from ._models import SignedIdentifier
@@ -115,6 +125,7 @@
     PathRenameMode,
     PremiumPageBlobAccessTier,
     PublicAccessType,
+    QuickQueryType,
     RehydratePriority,
     SequenceNumberActionType,
     SkuName,
@@ -144,8 +155,10 @@
     'CpkScopeInfo',
     'DataLakeStorageError', 'DataLakeStorageErrorException',
     'DataLakeStorageErrorError',
+    'DelimitedTextConfiguration',
     'DirectoryHttpHeaders',
     'GeoReplication',
+    'JsonTextConfiguration',
     'KeyInfo',
     'LeaseAccessConditions',
     'ListBlobsFlatSegmentResponse',
@@ -156,6 +169,9 @@
     'ModifiedAccessConditions',
     'PageList',
     'PageRange',
+    'QueryRequest',
+    'QuickQueryFormat',
+    'QuickQuerySerialization',
     'RetentionPolicy',
     'SequenceNumberAccessConditions',
     'SignedIdentifier',
@@ -175,6 +191,7 @@
     'BlobType',
     'StorageErrorCode',
     'GeoReplicationStatusType',
+    'QuickQueryType',
     'AccessTierRequired',
     'AccessTierOptional',
     'PremiumPageBlobAccessTier',

sdk/storage/azure-storage-blob/azure/storage/blob/_generated/models/_azure_blob_storage_enums.py

@@ -200,6 +200,12 @@ class GeoReplicationStatusType(str, Enum):
     unavailable = "unavailable"
 
 
+class QuickQueryType(str, Enum):
+
+    delimited = "delimited"
+    json = "json"
+
+
 class AccessTierRequired(str, Enum):
 
     p4 = "P4"

sdk/storage/azure-storage-blob/azure/storage/blob/_generated/models/_models.py

@@ -186,6 +186,10 @@ class BlobItem(Model):
     :type deleted: bool
     :param snapshot: Required.
     :type snapshot: str
+    :param version_id:
+    :type version_id: str
+    :param is_current_version:
+    :type is_current_version: bool
     :param properties: Required.
     :type properties: ~azure.storage.blob.models.BlobProperties
     :param metadata:
@@ -203,6 +207,8 @@ class BlobItem(Model):
         'name': {'key': 'Name', 'type': 'str', 'xml': {'name': 'Name'}},
         'deleted': {'key': 'Deleted', 'type': 'bool', 'xml': {'name': 'Deleted'}},
         'snapshot': {'key': 'Snapshot', 'type': 'str', 'xml': {'name': 'Snapshot'}},
+        'version_id': {'key': 'VersionId', 'type': 'str', 'xml': {'name': 'VersionId'}},
+        'is_current_version': {'key': 'IsCurrentVersion', 'type': 'bool', 'xml': {'name': 'IsCurrentVersion'}},
         'properties': {'key': 'Properties', 'type': 'BlobProperties', 'xml': {'name': 'Properties'}},
         'metadata': {'key': 'Metadata', 'type': 'BlobMetadata', 'xml': {'name': 'Metadata'}},
     }
@@ -215,6 +221,8 @@ def __init__(self, **kwargs):
         self.name = kwargs.get('name', None)
         self.deleted = kwargs.get('deleted', None)
         self.snapshot = kwargs.get('snapshot', None)
+        self.version_id = kwargs.get('version_id', None)
+        self.is_current_version = kwargs.get('is_current_version', None)
         self.properties = kwargs.get('properties', None)
         self.metadata = kwargs.get('metadata', None)
 
@@ -824,6 +832,51 @@ def __init__(self, **kwargs):
         self.message = kwargs.get('message', None)
 
 
+class DelimitedTextConfiguration(Model):
+    """delimited text configuration.
+
+    All required parameters must be populated in order to send to Azure.
+
+    :param column_separator: Required. column separator
+    :type column_separator: str
+    :param field_quote: Required. field quote
+    :type field_quote: str
+    :param record_separator: Required. record separator
+    :type record_separator: str
+    :param escape_char: Required. escape char
+    :type escape_char: str
+    :param has_headers: Required. has headers
+    :type has_headers: str
+    """
+
+    _validation = {
+        'column_separator': {'required': True},
+        'field_quote': {'required': True},
+        'record_separator': {'required': True},
+        'escape_char': {'required': True},
+        'has_headers': {'required': True},
+    }
+
+    _attribute_map = {
+        'column_separator': {'key': 'ColumnSeparator', 'type': 'str', 'xml': {'name': 'ColumnSeparator'}},
+        'field_quote': {'key': 'FieldQuote', 'type': 'str', 'xml': {'name': 'FieldQuote'}},
+        'record_separator': {'key': 'RecordSeparator', 'type': 'str', 'xml': {'name': 'RecordSeparator'}},
+        'escape_char': {'key': 'EscapeChar', 'type': 'str', 'xml': {'name': 'EscapeChar'}},
+        'has_headers': {'key': 'HasHeaders', 'type': 'str', 'xml': {'name': 'HasHeaders'}},
+    }
+    _xml_map = {
+        'name': 'DelimitedTextConfiguration'
+    }
+
+    def __init__(self, **kwargs):
+        super(DelimitedTextConfiguration, self).__init__(**kwargs)
+        self.column_separator = kwargs.get('column_separator', None)
+        self.field_quote = kwargs.get('field_quote', None)
+        self.record_separator = kwargs.get('record_separator', None)
+        self.escape_char = kwargs.get('escape_char', None)
+        self.has_headers = kwargs.get('has_headers', None)
+
+
 class DirectoryHttpHeaders(Model):
     """Additional parameters for a set of operations, such as: Directory_create,
     Directory_rename, Blob_rename.
@@ -892,6 +945,31 @@ def __init__(self, **kwargs):
         self.last_sync_time = kwargs.get('last_sync_time', None)
 
 
+class JsonTextConfiguration(Model):
+    """json text configuration.
+
+    All required parameters must be populated in order to send to Azure.
+
+    :param record_separator: Required. record separator
+    :type record_separator: str
+    """
+
+    _validation = {
+        'record_separator': {'required': True},
+    }
+
+    _attribute_map = {
+        'record_separator': {'key': 'RecordSeparator', 'type': 'str', 'xml': {'name': 'RecordSeparator'}},
+    }
+    _xml_map = {
+        'name': 'JsonTextConfiguration'
+    }
+
+    def __init__(self, **kwargs):
+        super(JsonTextConfiguration, self).__init__(**kwargs)
+        self.record_separator = kwargs.get('record_separator', None)
+
+
 class KeyInfo(Model):
     """Key information.
 
@@ -1266,6 +1344,109 @@ def __init__(self, **kwargs):
         self.end = kwargs.get('end', None)
 
 
+class QueryRequest(Model):
+    """the quick query body.
+
+    Variables are only populated by the server, and will be ignored when
+    sending a request.
+
+    All required parameters must be populated in order to send to Azure.
+
+    :ivar query_type: Required. the query type. Default value: "SQL" .
+    :vartype query_type: str
+    :param expression: Required. a query statement
+    :type expression: str
+    :param input_serialization:
+    :type input_serialization:
+     ~azure.storage.blob.models.QuickQuerySerialization
+    :param output_serialization:
+    :type output_serialization:
+     ~azure.storage.blob.models.QuickQuerySerialization
+    """
+
+    _validation = {
+        'query_type': {'required': True, 'constant': True},
+        'expression': {'required': True},
+    }
+
+    _attribute_map = {
+        'query_type': {'key': 'QueryType', 'type': 'str', 'xml': {'name': 'QueryType'}},
+        'expression': {'key': 'Expression', 'type': 'str', 'xml': {'name': 'Expression'}},
+        'input_serialization': {'key': 'InputSerialization', 'type': 'QuickQuerySerialization', 'xml': {'name': 'InputSerialization'}},
+        'output_serialization': {'key': 'OutputSerialization', 'type': 'QuickQuerySerialization', 'xml': {'name': 'OutputSerialization'}},
+    }
+    _xml_map = {
+        'name': 'QueryRequest'
+    }
+
+    query_type = "SQL"
+
+    def __init__(self, **kwargs):
+        super(QueryRequest, self).__init__(**kwargs)
+        self.expression = kwargs.get('expression', None)
+        self.input_serialization = kwargs.get('input_serialization', None)
+        self.output_serialization = kwargs.get('output_serialization', None)
+
+
+class QuickQueryFormat(Model):
+    """QuickQueryFormat.
+
+    All required parameters must be populated in order to send to Azure.
+
+    :param quick_query_type: Required. Possible values include: 'delimited',
+     'json'
+    :type quick_query_type: str or ~azure.storage.blob.models.QuickQueryType
+    :param delimited_text_configuration:
+    :type delimited_text_configuration:
+     ~azure.storage.blob.models.DelimitedTextConfiguration
+    :param json_text_configuration:
+    :type json_text_configuration:
+     ~azure.storage.blob.models.JsonTextConfiguration
+    """
+
+    _validation = {
+        'quick_query_type': {'required': True},
+    }
+
+    _attribute_map = {
+        'quick_query_type': {'key': 'QuickQueryType', 'type': 'QuickQueryType', 'xml': {'name': 'QuickQueryType'}},
+        'delimited_text_configuration': {'key': 'DelimitedTextConfiguration', 'type': 'DelimitedTextConfiguration', 'xml': {'name': 'DelimitedTextConfiguration'}},
+        'json_text_configuration': {'key': 'JsonTextConfiguration', 'type': 'JsonTextConfiguration', 'xml': {'name': 'JsonTextConfiguration'}},
+    }
+    _xml_map = {
+    }
+
+    def __init__(self, **kwargs):
+        super(QuickQueryFormat, self).__init__(**kwargs)
+        self.quick_query_type = kwargs.get('quick_query_type', None)
+        self.delimited_text_configuration = kwargs.get('delimited_text_configuration', None)
+        self.json_text_configuration = kwargs.get('json_text_configuration', None)
+
+
+class QuickQuerySerialization(Model):
+    """QuickQuerySerialization.
+
+    All required parameters must be populated in order to send to Azure.
+
+    :param format: Required.
+    :type format: ~azure.storage.blob.models.QuickQueryFormat
+    """
+
+    _validation = {
+        'format': {'required': True},
+    }
+
+    _attribute_map = {
+        'format': {'key': 'Format', 'type': 'QuickQueryFormat', 'xml': {'name': 'Format'}},
+    }
+    _xml_map = {
+    }
+
+    def __init__(self, **kwargs):
+        super(QuickQuerySerialization, self).__init__(**kwargs)
+        self.format = kwargs.get('format', None)
+
+
 class RetentionPolicy(Model):
     """the retention policy which determines how long the associated data should
     persist.