diff --git a/sdk/storage/azure-storage-blob-changefeed/out/azure/__init__.pyi b/sdk/storage/azure-storage-blob-changefeed/out/azure/__init__.pyi new file mode 100644 index 000000000000..83c51f161800 --- /dev/null +++ b/sdk/storage/azure-storage-blob-changefeed/out/azure/__init__.pyi @@ -0,0 +1,5 @@ +# Stubs for azure (Python 3) +# +# NOTE: This dynamically typed stub was automatically generated by stubgen. + +__path__: str diff --git a/sdk/storage/azure-storage-blob-changefeed/out/azure/storage/__init__.pyi b/sdk/storage/azure-storage-blob-changefeed/out/azure/storage/__init__.pyi new file mode 100644 index 000000000000..c2261d618d02 --- /dev/null +++ b/sdk/storage/azure-storage-blob-changefeed/out/azure/storage/__init__.pyi @@ -0,0 +1,5 @@ +# Stubs for azure.storage (Python 3) +# +# NOTE: This dynamically typed stub was automatically generated by stubgen. + +__path__: str diff --git a/sdk/storage/azure-storage-blob-changefeed/out/azure/storage/blobchangefeed/__init__.pyi b/sdk/storage/azure-storage-blob-changefeed/out/azure/storage/blobchangefeed/__init__.pyi new file mode 100644 index 000000000000..e369a86a0af8 --- /dev/null +++ b/sdk/storage/azure-storage-blob-changefeed/out/azure/storage/blobchangefeed/__init__.pyi @@ -0,0 +1,5 @@ +# Stubs for azure.storage.blobchangefeed (Python 3) +# +# NOTE: This dynamically typed stub was automatically generated by stubgen. + +from ._change_feed_client import ChangeFeedClient as ChangeFeedClient diff --git a/sdk/storage/azure-storage-blob-changefeed/out/azure/storage/blobchangefeed/_change_feed_client.pyi b/sdk/storage/azure-storage-blob-changefeed/out/azure/storage/blobchangefeed/_change_feed_client.pyi new file mode 100644 index 000000000000..92beafa09b79 --- /dev/null +++ b/sdk/storage/azure-storage-blob-changefeed/out/azure/storage/blobchangefeed/_change_feed_client.pyi @@ -0,0 +1,15 @@ +# Stubs for azure.storage.blobchangefeed._change_feed_client (Python 3) +# +# NOTE: This dynamically typed stub was automatically generated by stubgen. + +from ._models import ChangeFeedPaged +from azure.core.paging import ItemPaged +from azure.storage.blob import BlobServiceClient +from datetime import datetime +from typing import Any, Optional + +class ChangeFeedClient: + def __init__(self, account_url: str, credential: Optional[Any]=..., **kwargs: Any) -> None: ... + @classmethod + def from_connection_string(cls: Any, conn_str: str, credential: Optional[Any]=..., **kwargs: Any) -> BlobServiceClient: ... + def list_changes(self, start_time: Optional[datetime]=..., end_time: Optional[datetime]=..., **kwargs: Any) -> ItemPaged[BlobProperties]: ... diff --git a/sdk/storage/azure-storage-blob-changefeed/out/azure/storage/blobchangefeed/_models.pyi b/sdk/storage/azure-storage-blob-changefeed/out/azure/storage/blobchangefeed/_models.pyi new file mode 100644 index 000000000000..1caa7bc0828b --- /dev/null +++ b/sdk/storage/azure-storage-blob-changefeed/out/azure/storage/blobchangefeed/_models.pyi @@ -0,0 +1,72 @@ +# Stubs for azure.storage.blobchangefeed._models (Python 3) +# +# NOTE: This dynamically typed stub was automatically generated by stubgen. + +from azure.core.paging import PageIterator +from typing import Any, Optional + +SEGMENT_COMMON_PATH: str +PATH_DELIMITER: str + +class ChangeFeedPaged(PageIterator): + results_per_page: Any = ... + current_page: Any = ... + def __init__(self, container_client: Any, results_per_page: Optional[Any] = ..., start_time: Optional[Any] = ..., end_time: Optional[Any] = ..., continuation_token: Optional[Any] = ...) -> None: ... + +class ChangeFeed: + client: Any = ... + page_size: Any = ... + unprocessed_segment_paths: Any = ... + current_segment: Any = ... + start_time: Any = ... + end_time: Any = ... + cursor: Any = ... + def __init__(self, client: Any, page_size: Any, start_time: Optional[Any] = ..., end_time: Optional[Any] = ..., cf_cursor: Optional[Any] = ...) -> None: ... + def __iter__(self): ... + def __next__(self): ... + next: Any = ... + +class Segment: + client: Any = ... + segment_path: Any = ... + page_size: Any = ... + shards: Any = ... + cursor: Any = ... + def __init__(self, client: Any, segment_path: Any, page_size: Any, segment_cursor: Optional[Any] = ...) -> None: ... + def __iter__(self): ... + def __next__(self): ... + next: Any = ... + +class Shard: + client: Any = ... + shard_path: Any = ... + current_chunk: Any = ... + unprocessed_chunk_path_props: Any = ... + cursor: Any = ... + def __init__(self, client: Any, shard_path: Any, shard_cursor: Optional[Any] = ...) -> None: ... + def __iter__(self): ... + def __next__(self): ... + next: Any = ... + +class Chunk: + client: Any = ... + chunk_path: Any = ... + file_reader: Any = ... + cursor: Any = ... + def __init__(self, client: Any, chunk_path: Any, chunk_cursor: Optional[Any] = ...) -> None: ... + def __iter__(self): ... + def __next__(self): ... + next: Any = ... + +class ChangeFeedStreamer: + event_position: Any = ... + block_count: Any = ... + def __init__(self, blob_client: Any, chunk_file_start: int = ..., block_count: int = ...) -> None: ... + def __len__(self): ... + def __iter__(self): ... + def seekable(self): ... + def next(self): ... + def tell(self): ... + def seek(self, offset: Any, whence: int = ...) -> None: ... + def read(self, size: Any): ... + def track_event_position(self) -> None: ... diff --git a/sdk/storage/azure-storage-blob-changefeed/out/azure/storage/blobchangefeed/_version.pyi b/sdk/storage/azure-storage-blob-changefeed/out/azure/storage/blobchangefeed/_version.pyi new file mode 100644 index 000000000000..bc887c3aadd9 --- /dev/null +++ b/sdk/storage/azure-storage-blob-changefeed/out/azure/storage/blobchangefeed/_version.pyi @@ -0,0 +1,5 @@ +# Stubs for azure.storage.blobchangefeed._version (Python 3) +# +# NOTE: This dynamically typed stub was automatically generated by stubgen. + +VERSION: str diff --git a/sdk/storage/azure-storage-blob-changefeed/out/setup.pyi b/sdk/storage/azure-storage-blob-changefeed/out/setup.pyi new file mode 100644 index 000000000000..1694b148d59f --- /dev/null +++ b/sdk/storage/azure-storage-blob-changefeed/out/setup.pyi @@ -0,0 +1,12 @@ +# Stubs for setup (Python 3) +# +# NOTE: This dynamically typed stub was automatically generated by stubgen. + +from typing import Any + +PACKAGE_NAME: str +NAMESPACE_NAME: str +PACKAGE_PPRINT_NAME: str +package_folder_path: Any +ver: Any +version: Any diff --git a/sdk/storage/azure-storage-blob/out/azure/storage/blob/__init__.pyi b/sdk/storage/azure-storage-blob/out/azure/storage/blob/__init__.pyi index c7e55df2f282..f04bb686c962 100644 --- a/sdk/storage/azure-storage-blob/out/azure/storage/blob/__init__.pyi +++ b/sdk/storage/azure-storage-blob/out/azure/storage/blob/__init__.pyi @@ -8,7 +8,8 @@ from ._container_client import ContainerClient as ContainerClient from ._download import StorageStreamDownloader as StorageStreamDownloader from ._generated.models import RehydratePriority as RehydratePriority from ._lease import BlobLeaseClient as BlobLeaseClient -from ._models import AccessPolicy as AccessPolicy, BlobAnalyticsLogging as BlobAnalyticsLogging, BlobBlock as BlobBlock, BlobProperties as BlobProperties, BlobSasPermissions as BlobSasPermissions, BlobType as BlobType, BlockState as BlockState, ContainerEncryptionScope as ContainerEncryptionScope, ContainerProperties as ContainerProperties, ContainerSasPermissions as ContainerSasPermissions, ContentSettings as ContentSettings, CopyProperties as CopyProperties, CorsRule as CorsRule, CustomerProvidedEncryptionKey as CustomerProvidedEncryptionKey, LeaseProperties as LeaseProperties, Metrics as Metrics, PageRange as PageRange, PremiumPageBlobTier as PremiumPageBlobTier, PublicAccess as PublicAccess, RetentionPolicy as RetentionPolicy, SequenceNumberAction as SequenceNumberAction, StandardBlobTier as StandardBlobTier, StaticWebsite as StaticWebsite +from ._models import AccessPolicy as AccessPolicy, BlobAnalyticsLogging as BlobAnalyticsLogging, BlobBlock as BlobBlock, BlobProperties as BlobProperties, BlobSasPermissions as BlobSasPermissions, BlobType as BlobType, BlockState as BlockState, ContainerEncryptionScope as ContainerEncryptionScope, ContainerProperties as ContainerProperties, ContainerSasPermissions as ContainerSasPermissions, ContentSettings as ContentSettings, CopyProperties as CopyProperties, CorsRule as CorsRule, CustomerProvidedEncryptionKey as CustomerProvidedEncryptionKey, DelimitedTextConfiguration as DelimitedTextConfiguration, FilteredBlob as FilteredBlob, JsonTextConfiguration as JsonTextConfiguration, LeaseProperties as LeaseProperties, Metrics as Metrics, PageRange as PageRange, PremiumPageBlobTier as PremiumPageBlobTier, PublicAccess as PublicAccess, QuickQueryError as QuickQueryError, RetentionPolicy as RetentionPolicy, SequenceNumberAction as SequenceNumberAction, StandardBlobTier as StandardBlobTier, StaticWebsite as StaticWebsite +from ._quick_query_helper import QuickQueryReader as QuickQueryReader from ._shared.models import AccountSasPermissions as AccountSasPermissions, LocationMode as LocationMode, ResourceTypes as ResourceTypes, StorageErrorCode as StorageErrorCode, UserDelegationKey as UserDelegationKey from ._shared.policies import ExponentialRetry as ExponentialRetry, LinearRetry as LinearRetry from ._shared.response_handlers import PartialBatchErrorException as PartialBatchErrorException diff --git a/sdk/storage/azure-storage-blob/out/azure/storage/blob/_blob_client.pyi b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_blob_client.pyi index 13ae1e132302..e32c5c8227c7 100644 --- a/sdk/storage/azure-storage-blob/out/azure/storage/blob/_blob_client.pyi +++ b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_blob_client.pyi @@ -5,15 +5,16 @@ from ._deserialize import deserialize_blob_properties, deserialize_blob_stream, get_page_ranges_result from ._download import StorageStreamDownloader from ._generated import AzureBlobStorage, VERSION -from ._generated.models import AppendPositionAccessConditions, BlobHTTPHeaders, BlockList, BlockLookupList, CpkInfo, DeleteSnapshotsOptionType, SequenceNumberAccessConditions, StorageErrorException, UserDelegationKey +from ._generated.models import AppendPositionAccessConditions, BlobHTTPHeaders, BlockList, BlockLookupList, CpkInfo, DeleteSnapshotsOptionType, QueryRequest, SequenceNumberAccessConditions, StorageErrorException from ._lease import BlobLeaseClient, get_access_conditions -from ._models import BlobBlock, BlobProperties, BlobSasPermissions, BlobType, ContainerProperties, ContentSettings, PremiumPageBlobTier, SequenceNumberAction, StandardBlobTier -from ._serialize import get_api_version, get_cpk_scope_info, get_modify_conditions, get_source_conditions +from ._models import BlobBlock, BlobProperties, BlobType, ContentSettings, PremiumPageBlobTier, SequenceNumberAction, StandardBlobTier +from ._quick_query_helper import QuickQueryReader +from ._serialize import get_api_version, get_cpk_scope_info, get_modify_conditions, get_quick_query_serialization_info, get_source_conditions, serialize_blob_tags, serialize_blob_tags_header from ._shared import encode_base64 from ._shared.base_client import StorageAccountHostsMixin, parse_connection_str, parse_query from ._shared.encryption import generate_blob_encryption_data from ._shared.request_handlers import add_metadata_headers, get_length, read_length, validate_and_format_range_headers -from ._shared.response_handlers import process_storage_error, return_response_headers +from ._shared.response_handlers import process_storage_error, return_headers_and_deserialized, return_response_headers from ._shared.uploads import IterStreamer from ._upload_helpers import upload_append_blob, upload_block_blob, upload_page_blob from datetime import datetime @@ -23,6 +24,7 @@ class BlobClient(StorageAccountHostsMixin): container_name: Any = ... blob_name: Any = ... snapshot: Any = ... + version_id: Any = ... def __init__(self, account_url: str, container_name: str, blob_name: str, snapshot: Optional[Union[str, Dict[str, Any]]]=..., credential: Optional[Any]=..., **kwargs: Any) -> None: ... @classmethod def from_blob_url(cls: Any, blob_url: str, credential: Optional[Any]=..., snapshot: Optional[Union[str, Dict[str, Any]]]=..., **kwargs: Any) -> BlobClient: ... @@ -31,6 +33,7 @@ class BlobClient(StorageAccountHostsMixin): def get_account_information(self, **kwargs: Any) -> Dict[str, str]: ... def upload_blob(self, data: Union[Iterable[AnyStr], IO[AnyStr]], blob_type: Union[str, BlobType]=..., length: Optional[int]=..., metadata: Optional[Dict[str, str]]=..., **kwargs: Any) -> Any: ... def download_blob(self, offset: Optional[int]=..., length: Optional[int]=..., **kwargs: Any) -> StorageStreamDownloader: ... + def query(self, query_expression: str, **kwargs: Any) -> QuickQueryReader: ... def delete_blob(self, delete_snapshots: bool=..., **kwargs: Any) -> None: ... def undelete_blob(self, **kwargs: Any) -> None: ... def get_blob_properties(self, **kwargs: Any) -> BlobProperties: ... @@ -48,6 +51,8 @@ class BlobClient(StorageAccountHostsMixin): def get_block_list(self, block_list_type: Optional[str]=..., **kwargs: Any) -> Tuple[List[BlobBlock], List[BlobBlock]]: ... def commit_block_list(self, block_list: List[BlobBlock], content_settings: Optional[ContentSettings]=..., metadata: Optional[Dict[str, str]]=..., **kwargs: Any) -> Dict[str, Union[str, datetime]]: ... def set_premium_page_blob_tier(self, premium_page_blob_tier: Union[str, PremiumPageBlobTier], **kwargs: Any) -> None: ... + def set_blob_tags(self, tags: Optional[Dict[str, str]]=..., **kwargs: Any) -> Dict[str, Any]: ... + def get_blob_tags(self, **kwargs: Any) -> Dict[str, str]: ... def get_page_ranges(self, offset: Optional[int]=..., length: Optional[int]=..., previous_snapshot_diff: Optional[Union[str, Dict[str, Any]]]=..., **kwargs: Any) -> Tuple[List[Dict[str, int]], List[Dict[str, int]]]: ... def get_page_range_diff_for_managed_disk(self, previous_snapshot_url: str, offset: Optional[int]=..., length: Optional[int]=..., **kwargs: Any) -> Tuple[List[Dict[str, int]], List[Dict[str, int]]]: ... def set_sequence_number(self, sequence_number_action: Union[str, SequenceNumberAction], sequence_number: Optional[str]=..., **kwargs: Any) -> Dict[str, Union[str, datetime]]: ... diff --git a/sdk/storage/azure-storage-blob/out/azure/storage/blob/_blob_service_client.pyi b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_blob_service_client.pyi index f5bf4ce133a3..fe72407ffc73 100644 --- a/sdk/storage/azure-storage-blob/out/azure/storage/blob/_blob_service_client.pyi +++ b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_blob_service_client.pyi @@ -8,7 +8,7 @@ from ._deserialize import service_properties_deserialize, service_stats_deserial from ._generated import AzureBlobStorage, VERSION from ._generated.models import KeyInfo, StorageErrorException, StorageServiceProperties from ._lease import BlobLeaseClient -from ._models import BlobAnalyticsLogging, BlobProperties, ContainerProperties, ContainerPropertiesPaged, CorsRule, Metrics, PublicAccess, RetentionPolicy, StaticWebsite +from ._models import BlobAnalyticsLogging, BlobProperties, ContainerProperties, ContainerPropertiesPaged, CorsRule, FilteredBlobPaged, Metrics, PublicAccess, RetentionPolicy, StaticWebsite from ._serialize import get_api_version from ._shared.base_client import StorageAccountHostsMixin, TransportWrapper, parse_connection_str, parse_query from ._shared.models import LocationMode, UserDelegationKey @@ -28,6 +28,7 @@ class BlobServiceClient(StorageAccountHostsMixin): def get_service_properties(self, **kwargs: Any) -> Dict[str, Any]: ... def set_service_properties(self, analytics_logging: Optional[BlobAnalyticsLogging]=..., hour_metrics: Optional[Metrics]=..., minute_metrics: Optional[Metrics]=..., cors: Optional[List[CorsRule]]=..., target_version: Optional[str]=..., delete_retention_policy: Optional[RetentionPolicy]=..., static_website: Optional[StaticWebsite]=..., **kwargs: Any) -> None: ... def list_containers(self, name_starts_with: Optional[str]=..., include_metadata: Optional[bool]=..., **kwargs: Any) -> ItemPaged[ContainerProperties]: ... + def filter_blobs(self, where: Optional[Any]=..., **kwargs: Any) -> ItemPaged[BlobProperties]: ... def create_container(self, name: str, metadata: Optional[Dict[str, str]]=..., public_access: Optional[Union[PublicAccess, str]]=..., **kwargs: Any) -> ContainerClient: ... def delete_container(self, container: Union[ContainerProperties, str], lease: Optional[Union[BlobLeaseClient, str]]=..., **kwargs: Any) -> None: ... def get_container_client(self, container: Union[ContainerProperties, str]) -> ContainerClient: ... diff --git a/sdk/storage/azure-storage-blob/out/azure/storage/blob/_container_client.pyi b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_container_client.pyi index 5bbb06d8a450..51d6ebb15cd8 100644 --- a/sdk/storage/azure-storage-blob/out/azure/storage/blob/_container_client.pyi +++ b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_container_client.pyi @@ -15,7 +15,7 @@ from ._shared.response_handlers import process_storage_error, return_headers_and from azure.core.paging import ItemPaged from azure.core.pipeline.transport import HttpResponse from datetime import datetime -from typing import Any, AnyStr, Dict, IO, Iterable, Iterator, Optional, Union +from typing import Any, AnyStr, Dict, IO, Iterable, Iterator, List, Optional, Union class ContainerClient(StorageAccountHostsMixin): container_name: Any = ... @@ -26,13 +26,14 @@ class ContainerClient(StorageAccountHostsMixin): def from_connection_string(cls: Any, conn_str: str, container_name: str, credential: Optional[Any]=..., **kwargs: Any) -> ContainerClient: ... def create_container(self, metadata: Optional[Dict[str, str]]=..., public_access: Optional[Union[PublicAccess, str]]=..., **kwargs: Any) -> None: ... def delete_container(self, **kwargs: Any) -> None: ... + def undelete_container(self, deleted_container_name: str, deleted_container_version: str, **kwargs: Any) -> None: ... def acquire_lease(self, lease_duration: int=..., lease_id: Optional[str]=..., **kwargs: Any) -> BlobLeaseClient: ... def get_account_information(self, **kwargs: Any) -> Dict[str, str]: ... def get_container_properties(self, **kwargs: Any) -> ContainerProperties: ... def set_container_metadata(self, metadata: Optional[Dict[str, str]]=..., **kwargs: Any) -> Dict[str, Union[str, datetime]]: ... def get_container_access_policy(self, **kwargs: Any) -> Dict[str, Any]: ... def set_container_access_policy(self, signed_identifiers: Dict[str, AccessPolicy], public_access: Optional[Union[str, PublicAccess]]=..., **kwargs: Any) -> Dict[str, Union[str, datetime]]: ... - def list_blobs(self, name_starts_with: Optional[str]=..., include: Optional[Any]=..., **kwargs: Any) -> ItemPaged[BlobProperties]: ... + def list_blobs(self, name_starts_with: Optional[str]=..., include: Optional[Union[str, List[str]]]=..., **kwargs: Any) -> ItemPaged[BlobProperties]: ... def walk_blobs(self, name_starts_with: Optional[str]=..., include: Optional[Any]=..., delimiter: str=..., **kwargs: Optional[Any]) -> ItemPaged[BlobProperties]: ... def upload_blob(self, name: Union[str, BlobProperties], data: Union[Iterable[AnyStr], IO[AnyStr]], blob_type: Union[str, BlobType]=..., length: Optional[int]=..., metadata: Optional[Dict[str, str]]=..., **kwargs: Any) -> BlobClient: ... def delete_blob(self, blob: Union[str, BlobProperties], delete_snapshots: Optional[str]=..., **kwargs: Any) -> None: ... diff --git a/sdk/storage/azure-storage-blob/out/azure/storage/blob/_models.pyi b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_models.pyi index ced766709266..df971c85b80e 100644 --- a/sdk/storage/azure-storage-blob/out/azure/storage/blob/_models.pyi +++ b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_models.pyi @@ -2,11 +2,12 @@ # # NOTE: This dynamically typed stub was automatically generated by stubgen. -from ._generated.models import AccessPolicy as GenAccessPolicy, BlobItem, CorsRule as GeneratedCorsRule, Logging as GeneratedLogging, Metrics as GeneratedMetrics, RetentionPolicy as GeneratedRetentionPolicy, StaticWebsite as GeneratedStaticWebsite, StorageErrorException +from ._generated.models import AccessPolicy as GenAccessPolicy, BlobItemInternal, CorsRule as GeneratedCorsRule, DelimitedTextConfiguration as GenDelimitedTextConfiguration, JsonTextConfiguration as GenJsonTextConfiguration, Logging as GeneratedLogging, Metrics as GeneratedMetrics, RetentionPolicy as GeneratedRetentionPolicy, StaticWebsite as GeneratedStaticWebsite, StorageErrorException from ._shared import decode_base64_to_text from ._shared.models import DictMixin, get_enum_value from ._shared.response_handlers import process_storage_error, return_context_and_deserialized from azure.core.paging import ItemPaged, PageIterator +from azure.storage.blob._generated.models import FilterBlobItem from enum import Enum from typing import Any, Optional @@ -86,6 +87,8 @@ class ContainerProperties(DictMixin): lease: Any = ... public_access: Any = ... has_immutability_policy: Any = ... + deleted: Any = ... + version: Any = ... has_legal_hold: Any = ... metadata: Any = ... encryption_scope: Any = ... @@ -104,6 +107,8 @@ class BlobProperties(DictMixin): name: Any = ... container: Any = ... snapshot: Any = ... + version_id: Any = ... + is_current_version: Any = ... blob_type: Any = ... metadata: Any = ... encrypted_metadata: Any = ... @@ -128,6 +133,8 @@ class BlobProperties(DictMixin): encryption_key_sha256: Any = ... encryption_scope: Any = ... request_server_encrypted: Any = ... + tag_count: Any = ... + tags: Any = ... def __init__(self, **kwargs: Any) -> None: ... class BlobPropertiesPaged(PageIterator): @@ -141,6 +148,18 @@ class BlobPropertiesPaged(PageIterator): location_mode: Any = ... def __init__(self, command: Any, container: Optional[Any] = ..., prefix: Optional[Any] = ..., results_per_page: Optional[Any] = ..., continuation_token: Optional[Any] = ..., delimiter: Optional[Any] = ..., location_mode: Optional[Any] = ...) -> None: ... +class FilteredBlob(FilterBlobItem): + def __init__(self, **kwargs: Any) -> None: ... + +class FilteredBlobPaged(PageIterator): + service_endpoint: Any = ... + marker: Any = ... + results_per_page: Any = ... + container: Any = ... + current_page: Any = ... + location_mode: Any = ... + def __init__(self, command: Any, container: Optional[Any] = ..., results_per_page: Optional[Any] = ..., continuation_token: Optional[Any] = ..., location_mode: Optional[Any] = ...) -> None: ... + class BlobPrefix(ItemPaged, DictMixin): name: Any = ... prefix: Any = ... @@ -212,7 +231,8 @@ class BlobSasPermissions: create: Any = ... write: Any = ... delete: Any = ... - def __init__(self, read: bool = ..., add: bool = ..., create: bool = ..., write: bool = ..., delete: bool = ...) -> None: ... + delete_version: Any = ... + def __init__(self, read: bool = ..., add: bool = ..., create: bool = ..., write: bool = ..., delete: bool = ..., delete_version: bool = ...) -> None: ... @classmethod def from_string(cls, permission: Any): ... @@ -226,3 +246,16 @@ class ContainerEncryptionScope: default_encryption_scope: Any = ... prevent_encryption_scope_override: Any = ... def __init__(self, default_encryption_scope: Any, **kwargs: Any) -> None: ... + +class DelimitedTextConfiguration(GenDelimitedTextConfiguration): + def __init__(self, **kwargs: Any) -> None: ... + +class JsonTextConfiguration(GenJsonTextConfiguration): + def __init__(self, **kwargs: Any) -> None: ... + +class QuickQueryError: + name: Any = ... + is_fatal: Any = ... + description: Any = ... + position: Any = ... + def __init__(self, name: Optional[Any] = ..., is_fatal: bool = ..., description: Optional[Any] = ..., position: Optional[Any] = ...) -> None: ... diff --git a/sdk/storage/azure-storage-blob/out/azure/storage/blob/_quick_query_helper.pyi b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_quick_query_helper.pyi new file mode 100644 index 000000000000..267aa08a92ee --- /dev/null +++ b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_quick_query_helper.pyi @@ -0,0 +1,33 @@ +# Stubs for azure.storage.blob._quick_query_helper (Python 3) +# +# NOTE: This dynamically typed stub was automatically generated by stubgen. + +from ._models import QuickQueryError +from ._shared.avro.avro_io import DatumReader +from ._shared.avro.datafile import DataFileReader +from typing import Any, Optional + +class QuickQueryReader: + name: Any = ... + container: Any = ... + response_headers: Any = ... + total_bytes: Any = ... + bytes_processed: int = ... + def __init__(self, client: Optional[Any] = ..., name: Optional[Any] = ..., container: Optional[Any] = ..., progress_callback: Optional[Any] = ..., encoding: Optional[Any] = ..., **kwargs: Any) -> None: ... + def __len__(self): ... + def readall(self): ... + def readinto(self, stream: Any) -> None: ... + +class QuickQueryStreamer: + generator: Any = ... + iterator: Any = ... + leftover: bytes = ... + file_length: Any = ... + def __init__(self, generator: Any) -> None: ... + def __len__(self): ... + def __iter__(self): ... + def seekable(self): ... + def next(self): ... + def tell(self): ... + def seek(self, offset: Any, whence: int = ...) -> None: ... + def read(self, size: Any): ... diff --git a/sdk/storage/azure-storage-blob/out/azure/storage/blob/_serialize.pyi b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_serialize.pyi index c32ea33beae4..45ed5666382e 100644 --- a/sdk/storage/azure-storage-blob/out/azure/storage/blob/_serialize.pyi +++ b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_serialize.pyi @@ -2,12 +2,15 @@ # # NOTE: This dynamically typed stub was automatically generated by stubgen. -from ._generated.models import ContainerCpkScopeInfo, CpkScopeInfo, ModifiedAccessConditions, SourceModifiedAccessConditions +from ._generated.models import BlobTag, BlobTags, ContainerCpkScopeInfo, CpkScopeInfo, DelimitedTextConfiguration, JsonTextConfiguration, ModifiedAccessConditions, QuickQueryFormat, QuickQueryFormatType, QuickQuerySerialization, SourceModifiedAccessConditions from ._models import ContainerEncryptionScope -from typing import Any +from typing import Any, Optional def get_modify_conditions(kwargs: Dict[str, Any]) -> ModifiedAccessConditions: ... def get_source_conditions(kwargs: Dict[str, Any]) -> SourceModifiedAccessConditions: ... def get_cpk_scope_info(kwargs: Dict[str, Any]) -> CpkScopeInfo: ... def get_container_cpk_scope_info(kwargs: Dict[str, Any]) -> ContainerCpkScopeInfo: ... def get_api_version(kwargs: Any, default: Any): ... +def get_quick_query_serialization_info(serialization_settings: Optional[Any] = ...): ... +def serialize_blob_tags_header(tags: Optional[Dict[str, str]]=...) -> str: ... +def serialize_blob_tags(tags: Optional[Dict[str, str]]=...) -> Union[BlobTags, None]: ... diff --git a/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared/avro/__init__.pyi b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared/avro/__init__.pyi new file mode 100644 index 000000000000..3b4c4a020e47 --- /dev/null +++ b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared/avro/__init__.pyi @@ -0,0 +1,4 @@ +# Stubs for azure.storage.blob._shared.avro (Python 3) +# +# NOTE: This dynamically typed stub was automatically generated by stubgen. + diff --git a/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared/avro/avro_io.pyi b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared/avro/avro_io.pyi new file mode 100644 index 000000000000..4a4a9c690844 --- /dev/null +++ b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared/avro/avro_io.pyi @@ -0,0 +1,62 @@ +# Stubs for azure.storage.blob._shared.avro.avro_io (Python 3) +# +# NOTE: This dynamically typed stub was automatically generated by stubgen. + +from ..avro import schema +from typing import Any, Optional + +PY3: Any +logger: Any +STRUCT_FLOAT: Any +STRUCT_DOUBLE: Any + +class SchemaResolutionException(schema.AvroException): + def __init__(self, fail_msg: Any, writer_schema: Optional[Any] = ...) -> None: ... + +class BinaryDecoder: + def __init__(self, reader: Any) -> None: ... + @property + def reader(self): ... + def read(self, n: Any): ... + @staticmethod + def read_null() -> None: ... + def read_boolean(self): ... + def read_int(self): ... + def read_long(self): ... + def read_float(self): ... + def read_double(self): ... + def read_bytes(self): ... + def read_utf8(self): ... + def skip_null(self) -> None: ... + def skip_boolean(self) -> None: ... + def skip_int(self) -> None: ... + def skip_long(self) -> None: ... + def skip_float(self) -> None: ... + def skip_double(self) -> None: ... + def skip_bytes(self) -> None: ... + def skip_utf8(self) -> None: ... + def skip(self, n: Any) -> None: ... + +class DatumReader: + def __init__(self, writer_schema: Optional[Any] = ...) -> None: ... + def set_writer_schema(self, writer_schema: Any) -> None: ... + writer_schema: Any = ... + def read(self, decoder: Any): ... + def read_data(self, writer_schema: Any, decoder: Any): ... + def skip_data(self, writer_schema: Any, decoder: Any): ... + @staticmethod + def read_fixed(writer_schema: Any, decoder: Any): ... + @staticmethod + def skip_fixed(writer_schema: Any, decoder: Any): ... + @staticmethod + def read_enum(writer_schema: Any, decoder: Any): ... + @staticmethod + def skip_enum(decoder: Any): ... + def read_array(self, writer_schema: Any, decoder: Any): ... + def skip_array(self, writer_schema: Any, decoder: Any) -> None: ... + def read_map(self, writer_schema: Any, decoder: Any): ... + def skip_map(self, writer_schema: Any, decoder: Any) -> None: ... + def read_union(self, writer_schema: Any, decoder: Any): ... + def skip_union(self, writer_schema: Any, decoder: Any): ... + def read_record(self, writer_schema: Any, decoder: Any): ... + def skip_record(self, writer_schema: Any, decoder: Any) -> None: ... diff --git a/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared/avro/avro_io_async.pyi b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared/avro/avro_io_async.pyi new file mode 100644 index 000000000000..e709040f02dd --- /dev/null +++ b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared/avro/avro_io_async.pyi @@ -0,0 +1,58 @@ +# Stubs for azure.storage.blob._shared.avro.avro_io_async (Python 3) +# +# NOTE: This dynamically typed stub was automatically generated by stubgen. + +from ..avro import schema +from .avro_io import STRUCT_DOUBLE, STRUCT_FLOAT, SchemaResolutionException +from typing import Any, Optional + +PY3: Any +logger: Any + +class AsyncBinaryDecoder: + def __init__(self, reader: Any) -> None: ... + @property + def reader(self): ... + async def read(self, n: Any): ... + @staticmethod + def read_null() -> None: ... + async def read_boolean(self): ... + async def read_int(self): ... + async def read_long(self): ... + async def read_float(self): ... + async def read_double(self): ... + async def read_bytes(self): ... + async def read_utf8(self): ... + def skip_null(self) -> None: ... + async def skip_boolean(self) -> None: ... + async def skip_int(self) -> None: ... + async def skip_long(self) -> None: ... + async def skip_float(self) -> None: ... + async def skip_double(self) -> None: ... + async def skip_bytes(self) -> None: ... + async def skip_utf8(self) -> None: ... + async def skip(self, n: Any) -> None: ... + +class AsyncDatumReader: + def __init__(self, writer_schema: Optional[Any] = ...) -> None: ... + def set_writer_schema(self, writer_schema: Any) -> None: ... + writer_schema: Any = ... + async def read(self, decoder: Any): ... + async def read_data(self, writer_schema: Any, decoder: Any): ... + async def skip_data(self, writer_schema: Any, decoder: Any): ... + @staticmethod + async def read_fixed(writer_schema: Any, decoder: Any): ... + @staticmethod + async def skip_fixed(writer_schema: Any, decoder: Any): ... + @staticmethod + async def read_enum(writer_schema: Any, decoder: Any): ... + @staticmethod + async def skip_enum(decoder: Any): ... + async def read_array(self, writer_schema: Any, decoder: Any): ... + async def skip_array(self, writer_schema: Any, decoder: Any) -> None: ... + async def read_map(self, writer_schema: Any, decoder: Any): ... + async def skip_map(self, writer_schema: Any, decoder: Any) -> None: ... + async def read_union(self, writer_schema: Any, decoder: Any): ... + async def skip_union(self, writer_schema: Any, decoder: Any): ... + async def read_record(self, writer_schema: Any, decoder: Any): ... + async def skip_record(self, writer_schema: Any, decoder: Any) -> None: ... diff --git a/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared/avro/datafile.pyi b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared/avro/datafile.pyi new file mode 100644 index 000000000000..0678f71749a0 --- /dev/null +++ b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared/avro/datafile.pyi @@ -0,0 +1,43 @@ +# Stubs for azure.storage.blob._shared.avro.datafile (Python 3) +# +# NOTE: This dynamically typed stub was automatically generated by stubgen. + +from ..avro import avro_io, schema +from typing import Any + +PY3: Any +logger: Any +VERSION: int +MAGIC: Any +MAGIC_SIZE: Any +SYNC_SIZE: int +META_SCHEMA: Any +VALID_CODECS: Any +SCHEMA_KEY: str + +class DataFileException(schema.AvroException): ... + +class DataFileReader: + codec: str = ... + def __init__(self, reader: Any, datum_reader: Any, **kwargs: Any) -> None: ... + def __enter__(self): ... + def __exit__(self, data_type: Any, value: Any, traceback: Any) -> None: ... + def __iter__(self): ... + @property + def reader(self): ... + @property + def raw_decoder(self): ... + @property + def datum_decoder(self): ... + @property + def datum_reader(self): ... + @property + def sync_marker(self): ... + @property + def meta(self): ... + @property + def block_count(self): ... + def get_meta(self, key: Any): ... + def __next__(self): ... + def next(self): ... + def close(self) -> None: ... diff --git a/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared/avro/datafile_async.pyi b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared/avro/datafile_async.pyi new file mode 100644 index 000000000000..3562f8b33d1e --- /dev/null +++ b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared/avro/datafile_async.pyi @@ -0,0 +1,36 @@ +# Stubs for azure.storage.blob._shared.avro.datafile_async (Python 3) +# +# NOTE: This dynamically typed stub was automatically generated by stubgen. + +from ..avro import avro_io_async, schema +from .datafile import DataFileException, MAGIC, META_SCHEMA, SCHEMA_KEY, SYNC_SIZE +from typing import Any + +PY3: Any +logger: Any +VALID_CODECS: Any + +class AsyncDataFileReader: + codec: str = ... + def __init__(self, reader: Any, datum_reader: Any, **kwargs: Any) -> None: ... + async def init(self): ... + async def __aenter__(self): ... + async def __aexit__(self, data_type: Any, value: Any, traceback: Any) -> None: ... + def __aiter__(self): ... + @property + def reader(self): ... + @property + def raw_decoder(self): ... + @property + def datum_decoder(self): ... + @property + def datum_reader(self): ... + @property + def sync_marker(self): ... + @property + def meta(self): ... + @property + def block_count(self): ... + def get_meta(self, key: Any): ... + async def __anext__(self): ... + def close(self) -> None: ... diff --git a/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared/avro/schema.pyi b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared/avro/schema.pyi new file mode 100644 index 000000000000..7a6213112aad --- /dev/null +++ b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared/avro/schema.pyi @@ -0,0 +1,174 @@ +# Stubs for azure.storage.blob._shared.avro.schema (Python 3) +# +# NOTE: This dynamically typed stub was automatically generated by stubgen. + +import abc +from typing import Any, Optional + +PY2: Any +logger: Any +DEBUG_VERBOSE: int +NULL: str +BOOLEAN: str +STRING: str +BYTES: str +INT: str +LONG: str +FLOAT: str +DOUBLE: str +FIXED: str +ENUM: str +RECORD: str +ERROR: str +ARRAY: str +MAP: str +UNION: str +REQUEST: str +ERROR_UNION: str +PRIMITIVE_TYPES: Any +NAMED_TYPES: Any +VALID_TYPES: Any +SCHEMA_RESERVED_PROPS: Any +FIELD_RESERVED_PROPS: Any +VALID_FIELD_SORT_ORDERS: Any + +class Error(Exception): ... +class AvroException(Error): ... +class SchemaParseException(AvroException): ... + +class Schema(metaclass=abc.ABCMeta): + def __init__(self, data_type: Any, other_props: Optional[Any] = ...) -> None: ... + @property + def namespace(self): ... + @property + def type(self): ... + @property + def doc(self): ... + @property + def props(self): ... + @property + def other_props(self): ... + @abc.abstractmethod + def to_json(self, names: Any) -> Any: ... + +class Name: + def __init__(self, name: Any, namespace: Optional[Any] = ...) -> None: ... + def __eq__(self, other: Any): ... + @property + def simple_name(self): ... + @property + def namespace(self): ... + @property + def fullname(self): ... + +class Names: + def __init__(self, default_namespace: Optional[Any] = ..., names: Optional[Any] = ...) -> None: ... + @property + def names(self): ... + @property + def default_namespace(self): ... + def new_with_default_namespace(self, namespace: Any): ... + def get_name(self, name: Any, namespace: Optional[Any] = ...): ... + def get_schema(self, name: Any, namespace: Optional[Any] = ...): ... + def prune_namespace(self, properties: Any): ... + def register(self, schema: Any) -> None: ... + +class NamedSchema(Schema, metaclass=abc.ABCMeta): + def __init__(self, data_type: Any, name: Any, namespace: Optional[Any] = ..., names: Optional[Any] = ..., other_props: Optional[Any] = ...) -> None: ... + @property + def avro_name(self): ... + @property + def name(self): ... + @property + def namespace(self): ... + @property + def fullname(self): ... + def name_ref(self, names: Any): ... + @abc.abstractmethod + def to_json(self, names: Any) -> Any: ... + +class Field: + def __init__(self, data_type: Any, name: Any, index: Any, has_default: Any, default: Any = ..., order: Optional[Any] = ..., doc: Optional[Any] = ..., other_props: Optional[Any] = ...) -> None: ... + @property + def type(self): ... + @property + def name(self): ... + @property + def index(self): ... + @property + def default(self): ... + @property + def has_default(self): ... + @property + def order(self): ... + @property + def doc(self): ... + @property + def props(self): ... + @property + def other_props(self): ... + def to_json(self, names: Optional[Any] = ...): ... + def __eq__(self, that: Any): ... + +class PrimitiveSchema(Schema): + def __init__(self, data_type: Any, other_props: Optional[Any] = ...) -> None: ... + @property + def name(self): ... + @property + def fullname(self): ... + def to_json(self, names: Optional[Any] = ...): ... + def __eq__(self, that: Any): ... + +class FixedSchema(NamedSchema): + def __init__(self, name: Any, namespace: Any, size: Any, names: Optional[Any] = ..., other_props: Optional[Any] = ...) -> None: ... + @property + def size(self): ... + def to_json(self, names: Optional[Any] = ...): ... + def __eq__(self, that: Any): ... + +class EnumSchema(NamedSchema): + def __init__(self, name: Any, namespace: Any, symbols: Any, names: Optional[Any] = ..., doc: Optional[Any] = ..., other_props: Optional[Any] = ...) -> None: ... + @property + def symbols(self): ... + def to_json(self, names: Optional[Any] = ...): ... + def __eq__(self, that: Any): ... + +class ArraySchema(Schema): + def __init__(self, items: Any, other_props: Optional[Any] = ...) -> None: ... + @property + def items(self): ... + def to_json(self, names: Optional[Any] = ...): ... + def __eq__(self, that: Any): ... + +class MapSchema(Schema): + def __init__(self, values: Any, other_props: Optional[Any] = ...) -> None: ... + @property + def values(self): ... + def to_json(self, names: Optional[Any] = ...): ... + def __eq__(self, that: Any): ... + +class UnionSchema(Schema): + def __init__(self, schemas: Any) -> None: ... + @property + def schemas(self): ... + def to_json(self, names: Optional[Any] = ...): ... + def __eq__(self, that: Any): ... + +class ErrorUnionSchema(UnionSchema): + def __init__(self, schemas: Any) -> None: ... + def to_json(self, names: Optional[Any] = ...): ... + +class RecordSchema(NamedSchema): + @staticmethod + def make_field_list(field_desc_list: Any, names: Any) -> None: ... + def __init__(self, name: Any, namespace: Any, fields: Optional[Any] = ..., make_fields: Optional[Any] = ..., names: Optional[Any] = ..., record_type: Any = ..., doc: Optional[Any] = ..., other_props: Optional[Any] = ...) -> None: ... + @property + def fields(self): ... + @property + def field_map(self): ... + def to_json(self, names: Optional[Any] = ...): ... + def __eq__(self, that: Any): ... + +def filter_keys_out(items: Any, keys: Any) -> None: ... +def schema_from_json_data(json_data: Any, names: Optional[Any] = ...): ... +def parse(json_string: Any): ... diff --git a/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared/models.pyi b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared/models.pyi index e019dfce0b29..4c4a6aaec176 100644 --- a/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared/models.pyi +++ b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared/models.pyi @@ -192,12 +192,13 @@ class AccountSasPermissions: read: Any = ... write: Any = ... delete: Any = ... + delete_version: Any = ... list: Any = ... add: Any = ... create: Any = ... update: Any = ... process: Any = ... - def __init__(self, read: bool = ..., write: bool = ..., delete: bool = ..., list: bool = ..., add: bool = ..., create: bool = ..., update: bool = ..., process: bool = ...) -> None: ... + def __init__(self, read: bool = ..., write: bool = ..., delete: bool = ..., list: bool = ..., add: bool = ..., create: bool = ..., update: bool = ..., process: bool = ..., delete_version: bool = ...) -> None: ... @classmethod def from_string(cls, permission: Any): ... diff --git a/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared_access_signature.pyi b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared_access_signature.pyi index fb4ec10a9b5d..860e2069e1ac 100644 --- a/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared_access_signature.pyi +++ b/sdk/storage/azure-storage-blob/out/azure/storage/blob/_shared_access_signature.pyi @@ -7,13 +7,15 @@ from azure.storage.blob._shared.shared_access_signature import SharedAccessSigna from datetime import datetime from typing import Any, Optional, Union +X_MS_VERSION: str + class BlobQueryStringConstants: SIGNED_TIMESTAMP: str = ... class BlobSharedAccessSignature(SharedAccessSignature): user_delegation_key: Any = ... def __init__(self, account_name: Any, account_key: Optional[Any] = ..., user_delegation_key: Optional[Any] = ...) -> None: ... - def generate_blob(self, container_name: Any, blob_name: Any, snapshot: Optional[Any] = ..., permission: Optional[Any] = ..., expiry: Optional[Any] = ..., start: Optional[Any] = ..., policy_id: Optional[Any] = ..., ip: Optional[Any] = ..., protocol: Optional[Any] = ..., cache_control: Optional[Any] = ..., content_disposition: Optional[Any] = ..., content_encoding: Optional[Any] = ..., content_language: Optional[Any] = ..., content_type: Optional[Any] = ...): ... + def generate_blob(self, container_name: Any, blob_name: Any, snapshot: Optional[Any] = ..., version_id: Optional[Any] = ..., permission: Optional[Any] = ..., expiry: Optional[Any] = ..., start: Optional[Any] = ..., policy_id: Optional[Any] = ..., ip: Optional[Any] = ..., protocol: Optional[Any] = ..., cache_control: Optional[Any] = ..., content_disposition: Optional[Any] = ..., content_encoding: Optional[Any] = ..., content_language: Optional[Any] = ..., content_type: Optional[Any] = ...): ... def generate_container(self, container_name: Any, permission: Optional[Any] = ..., expiry: Optional[Any] = ..., start: Optional[Any] = ..., policy_id: Optional[Any] = ..., ip: Optional[Any] = ..., protocol: Optional[Any] = ..., cache_control: Optional[Any] = ..., content_disposition: Optional[Any] = ..., content_encoding: Optional[Any] = ..., content_language: Optional[Any] = ..., content_type: Optional[Any] = ...): ... class _BlobSharedAccessHelper(_SharedAccessHelper): @@ -24,4 +26,4 @@ class _BlobSharedAccessHelper(_SharedAccessHelper): def generate_account_sas(account_name: str, account_key: str, resource_types: Union[ResourceTypes, str], permission: Union[AccountSasPermissions, str], expiry: Optional[Union[datetime, str]], start: Optional[Union[datetime, str]]=..., ip: Optional[str]=..., **kwargs: Any) -> str: ... def generate_container_sas(account_name: str, container_name: str, account_key: Optional[str]=..., user_delegation_key: Optional[UserDelegationKey]=..., permission: Optional[Union[ContainerSasPermissions, str]]=..., expiry: Optional[Union[datetime, str]]=..., start: Optional[Union[datetime, str]]=..., policy_id: Optional[str]=..., ip: Optional[str]=..., **kwargs: Any) -> Any: ... -def generate_blob_sas(account_name: str, container_name: str, blob_name: str, snapshot: Optional[str]=..., account_key: Optional[str]=..., user_delegation_key: Optional[UserDelegationKey]=..., permission: Optional[Union[BlobSasPermissions, str]]=..., expiry: Optional[Union[datetime, str]]=..., start: Optional[Union[datetime, str]]=..., policy_id: Optional[str]=..., ip: Optional[str]=..., **kwargs: Any) -> Any: ... +def generate_blob_sas(account_name: str, container_name: str, blob_name: str, snapshot: Optional[str]=..., account_key: Optional[str]=..., user_delegation_key: Optional[UserDelegationKey]=..., permission: Optional[Union[BlobSasPermissions, str]]=..., expiry: Optional[Union[datetime, str]]=..., start: Optional[Union[datetime, str]]=..., policy_id: Optional[str]=..., ip: Optional[str]=..., version_id: Optional[str]=..., **kwargs: Any) -> Any: ... diff --git a/sdk/storage/azure-storage-blob/out/azure/storage/blob/aio/_blob_client_async.pyi b/sdk/storage/azure-storage-blob/out/azure/storage/blob/aio/_blob_client_async.pyi index 31f95edf2809..39301f5f2f2d 100644 --- a/sdk/storage/azure-storage-blob/out/azure/storage/blob/aio/_blob_client_async.pyi +++ b/sdk/storage/azure-storage-blob/out/azure/storage/blob/aio/_blob_client_async.pyi @@ -8,7 +8,7 @@ from .._generated import VERSION from .._generated.aio import AzureBlobStorage from .._generated.models import CpkInfo, StorageErrorException from .._lease import get_access_conditions -from .._models import BlobBlock, BlobProperties, BlobSasPermissions, BlobType, ContainerProperties, ContentSettings, PremiumPageBlobTier, SequenceNumberAction, StandardBlobTier +from .._models import BlobBlock, BlobProperties, BlobType, ContentSettings, PremiumPageBlobTier, SequenceNumberAction, StandardBlobTier from .._serialize import get_api_version, get_modify_conditions from .._shared.base_client_async import AsyncStorageAccountHostsMixin from .._shared.policies_async import ExponentialRetry @@ -41,6 +41,8 @@ class BlobClient(AsyncStorageAccountHostsMixin, BlobClientBase): async def get_block_list(self, block_list_type: Optional[str]=..., **kwargs: Any) -> Tuple[List[BlobBlock], List[BlobBlock]]: ... async def commit_block_list(self, block_list: List[BlobBlock], content_settings: Optional[ContentSettings]=..., metadata: Optional[Dict[str, str]]=..., **kwargs: Any) -> Dict[str, Union[str, datetime]]: ... async def set_premium_page_blob_tier(self, premium_page_blob_tier: Union[str, PremiumPageBlobTier], **kwargs: Any) -> None: ... + async def set_blob_tags(self, tags: Optional[Dict[str, str]]=..., **kwargs: Any) -> Dict[str, Any]: ... + async def get_blob_tags(self, **kwargs: Any) -> Dict[str, str]: ... async def get_page_ranges(self, offset: Optional[int]=..., length: Optional[int]=..., previous_snapshot_diff: Optional[Union[str, Dict[str, Any]]]=..., **kwargs: Any) -> Tuple[List[Dict[str, int]], List[Dict[str, int]]]: ... async def get_page_range_diff_for_managed_disk(self, previous_snapshot_url: str, offset: Optional[int]=..., length: Optional[int]=..., **kwargs: Any) -> Tuple[List[Dict[str, int]], List[Dict[str, int]]]: ... async def set_sequence_number(self, sequence_number_action: Union[str, SequenceNumberAction], sequence_number: Optional[str]=..., **kwargs: Any) -> Dict[str, Union[str, datetime]]: ... diff --git a/sdk/storage/azure-storage-blob/out/azure/storage/blob/aio/_blob_service_client_async.pyi b/sdk/storage/azure-storage-blob/out/azure/storage/blob/aio/_blob_service_client_async.pyi index a4f8eafd0b3a..06bc70da43b0 100644 --- a/sdk/storage/azure-storage-blob/out/azure/storage/blob/aio/_blob_service_client_async.pyi +++ b/sdk/storage/azure-storage-blob/out/azure/storage/blob/aio/_blob_service_client_async.pyi @@ -17,7 +17,7 @@ from .._shared.response_handlers import parse_to_internal_user_delegation_key, p from ._blob_client_async import BlobClient from ._container_client_async import ContainerClient from ._lease_async import BlobLeaseClient -from ._models import ContainerPropertiesPaged +from ._models import ContainerPropertiesPaged, FilteredBlobPaged from azure.core.async_paging import AsyncItemPaged from datetime import datetime from typing import Any, Dict, List, Optional, Union @@ -30,6 +30,7 @@ class BlobServiceClient(AsyncStorageAccountHostsMixin, BlobServiceClientBase): async def get_service_properties(self, **kwargs: Any) -> Dict[str, Any]: ... async def set_service_properties(self, analytics_logging: Optional[BlobAnalyticsLogging]=..., hour_metrics: Optional[Metrics]=..., minute_metrics: Optional[Metrics]=..., cors: Optional[List[CorsRule]]=..., target_version: Optional[str]=..., delete_retention_policy: Optional[RetentionPolicy]=..., static_website: Optional[StaticWebsite]=..., **kwargs: Any) -> None: ... def list_containers(self, name_starts_with: Optional[str]=..., include_metadata: Optional[bool]=..., **kwargs: Any) -> AsyncItemPaged[ContainerProperties]: ... + def filter_blobs(self, where: Optional[Any]=..., **kwargs: Any) -> AsyncItemPaged[BlobProperties]: ... async def create_container(self, name: str, metadata: Optional[Dict[str, str]]=..., public_access: Optional[Union[PublicAccess, str]]=..., **kwargs: Any) -> ContainerClient: ... async def delete_container(self, container: Union[ContainerProperties, str], lease: Optional[Union[BlobLeaseClient, str]]=..., **kwargs: Any) -> None: ... def get_container_client(self, container: Union[ContainerProperties, str]) -> ContainerClient: ... diff --git a/sdk/storage/azure-storage-blob/out/azure/storage/blob/aio/_container_client_async.pyi b/sdk/storage/azure-storage-blob/out/azure/storage/blob/aio/_container_client_async.pyi index 187e01297ead..fdb6c2339679 100644 --- a/sdk/storage/azure-storage-blob/out/azure/storage/blob/aio/_container_client_async.pyi +++ b/sdk/storage/azure-storage-blob/out/azure/storage/blob/aio/_container_client_async.pyi @@ -21,19 +21,20 @@ from ._models import BlobPrefix, BlobPropertiesPaged from azure.core.async_paging import AsyncItemPaged from azure.core.pipeline.transport import AsyncHttpResponse from datetime import datetime -from typing import Any, AnyStr, AsyncIterator, Dict, IO, Iterable, Optional, Union +from typing import Any, AnyStr, AsyncIterator, Dict, IO, Iterable, List, Optional, Union class ContainerClient(AsyncStorageAccountHostsMixin, ContainerClientBase): def __init__(self, account_url: str, container_name: str, credential: Optional[Any]=..., **kwargs: Any) -> None: ... async def create_container(self, metadata: Optional[Dict[str, str]]=..., public_access: Optional[Union[PublicAccess, str]]=..., **kwargs: Any) -> None: ... async def delete_container(self, **kwargs: Any) -> None: ... + async def undelete_container(self, deleted_container_name: str, deleted_container_version: str, **kwargs: Any) -> None: ... async def acquire_lease(self, lease_duration: int=..., lease_id: Optional[str]=..., **kwargs: Any) -> BlobLeaseClient: ... async def get_account_information(self, **kwargs: Any) -> Dict[str, str]: ... async def get_container_properties(self, **kwargs: Any) -> ContainerProperties: ... async def set_container_metadata(self, metadata: Optional[Dict[str, str]]=..., **kwargs: Any) -> Dict[str, Union[str, datetime]]: ... async def get_container_access_policy(self, **kwargs: Any) -> Dict[str, Any]: ... async def set_container_access_policy(self, signed_identifiers: Dict[str, AccessPolicy], public_access: Optional[Union[str, PublicAccess]]=..., **kwargs: Any) -> Dict[str, Union[str, datetime]]: ... - def list_blobs(self, name_starts_with: Optional[str]=..., include: Optional[Any]=..., **kwargs: Any) -> AsyncItemPaged[BlobProperties]: ... + def list_blobs(self, name_starts_with: Optional[str]=..., include: Optional[Union[str, List[str]]]=..., **kwargs: Any) -> AsyncItemPaged[BlobProperties]: ... def walk_blobs(self, name_starts_with: Optional[str]=..., include: Optional[Any]=..., delimiter: str=..., **kwargs: Optional[Any]) -> AsyncItemPaged[BlobProperties]: ... async def upload_blob(self, name: Union[str, BlobProperties], data: Union[Iterable[AnyStr], IO[AnyStr]], blob_type: Union[str, BlobType]=..., length: Optional[int]=..., metadata: Optional[Dict[str, str]]=..., **kwargs: Any) -> BlobClient: ... async def delete_blob(self, blob: Union[str, BlobProperties], delete_snapshots: Optional[str]=..., **kwargs: Any) -> None: ... diff --git a/sdk/storage/azure-storage-blob/out/azure/storage/blob/aio/_models.pyi b/sdk/storage/azure-storage-blob/out/azure/storage/blob/aio/_models.pyi index 3fe31406d6fa..b0ed30fda174 100644 --- a/sdk/storage/azure-storage-blob/out/azure/storage/blob/aio/_models.pyi +++ b/sdk/storage/azure-storage-blob/out/azure/storage/blob/aio/_models.pyi @@ -2,8 +2,8 @@ # # NOTE: This dynamically typed stub was automatically generated by stubgen. -from .._generated.models import BlobItem, StorageErrorException -from .._models import BlobProperties, ContainerProperties +from .._generated.models import BlobItemInternal, FilterBlobItem, StorageErrorException +from .._models import BlobProperties, ContainerProperties, FilteredBlob from .._shared.models import DictMixin from .._shared.response_handlers import process_storage_error, return_context_and_deserialized from azure.core.async_paging import AsyncItemPaged, AsyncPageIterator @@ -29,6 +29,15 @@ class BlobPropertiesPaged(AsyncPageIterator): location_mode: Any = ... def __init__(self, command: Any, container: Optional[Any] = ..., prefix: Optional[Any] = ..., results_per_page: Optional[Any] = ..., continuation_token: Optional[Any] = ..., delimiter: Optional[Any] = ..., location_mode: Optional[Any] = ...) -> None: ... +class FilteredBlobPaged(AsyncPageIterator): + service_endpoint: Any = ... + marker: Any = ... + results_per_page: Any = ... + container: Any = ... + current_page: Any = ... + location_mode: Any = ... + def __init__(self, command: Any, container: Optional[Any] = ..., results_per_page: Optional[Any] = ..., continuation_token: Optional[Any] = ..., location_mode: Optional[Any] = ...) -> None: ... + class BlobPrefix(AsyncItemPaged, DictMixin): name: Any = ... prefix: Any = ... diff --git a/sdk/storage/azure-storage-file-datalake/out/azure/storage/filedatalake/_shared/models.pyi b/sdk/storage/azure-storage-file-datalake/out/azure/storage/filedatalake/_shared/models.pyi index 9e6beab7c073..b3ba13da694b 100644 --- a/sdk/storage/azure-storage-file-datalake/out/azure/storage/filedatalake/_shared/models.pyi +++ b/sdk/storage/azure-storage-file-datalake/out/azure/storage/filedatalake/_shared/models.pyi @@ -192,12 +192,13 @@ class AccountSasPermissions: read: Any = ... write: Any = ... delete: Any = ... + delete_version: Any = ... list: Any = ... add: Any = ... create: Any = ... update: Any = ... process: Any = ... - def __init__(self, read: bool = ..., write: bool = ..., delete: bool = ..., list: bool = ..., add: bool = ..., create: bool = ..., update: bool = ..., process: bool = ...) -> None: ... + def __init__(self, read: bool = ..., write: bool = ..., delete: bool = ..., list: bool = ..., add: bool = ..., create: bool = ..., update: bool = ..., process: bool = ..., delete_version: bool = ...) -> None: ... @classmethod def from_string(cls, permission: Any): ... diff --git a/sdk/storage/azure-storage-file-share/out/azure/storage/fileshare/_models.pyi b/sdk/storage/azure-storage-file-share/out/azure/storage/fileshare/_models.pyi index 7fff025d1d73..f533b4e2864e 100644 --- a/sdk/storage/azure-storage-file-share/out/azure/storage/fileshare/_models.pyi +++ b/sdk/storage/azure-storage-file-share/out/azure/storage/fileshare/_models.pyi @@ -58,6 +58,10 @@ class ShareProperties(DictMixin): next_allowed_quota_downgrade_time: Any = ... metadata: Any = ... snapshot: Any = ... + deleted: Any = ... + deleted_time: Any = ... + version: Any = ... + remaining_retention_days: Any = ... provisioned_egress_mbps: Any = ... provisioned_ingress_mbps: Any = ... provisioned_iops: Any = ... diff --git a/sdk/storage/azure-storage-file-share/out/azure/storage/fileshare/_share_client.pyi b/sdk/storage/azure-storage-file-share/out/azure/storage/fileshare/_share_client.pyi index 308c57c20d75..4980c8aa38bd 100644 --- a/sdk/storage/azure-storage-file-share/out/azure/storage/fileshare/_share_client.pyi +++ b/sdk/storage/azure-storage-file-share/out/azure/storage/fileshare/_share_client.pyi @@ -28,6 +28,7 @@ class ShareClient(StorageAccountHostsMixin): def create_share(self, **kwargs: Any) -> Dict[str, Any]: ... def create_snapshot(self, **kwargs: Optional[Any]) -> Dict[str, Any]: ... def delete_share(self, delete_snapshots: Optional[bool]=..., **kwargs: Any) -> None: ... + def undelete_share(self, deleted_share_name: str, deleted_share_version: str, **kwargs: Any) -> None: ... def get_share_properties(self, **kwargs: Any) -> ShareProperties: ... def set_share_quota(self, quota: int, **kwargs: Any) -> Dict[str, Any]: ... def set_share_metadata(self, metadata: Dict[str, Any], **kwargs: Any) -> Dict[str, Any]: ... diff --git a/sdk/storage/azure-storage-file-share/out/azure/storage/fileshare/_shared/models.pyi b/sdk/storage/azure-storage-file-share/out/azure/storage/fileshare/_shared/models.pyi index 8666ce04f0f6..51264125652e 100644 --- a/sdk/storage/azure-storage-file-share/out/azure/storage/fileshare/_shared/models.pyi +++ b/sdk/storage/azure-storage-file-share/out/azure/storage/fileshare/_shared/models.pyi @@ -192,12 +192,13 @@ class AccountSasPermissions: read: Any = ... write: Any = ... delete: Any = ... + delete_version: Any = ... list: Any = ... add: Any = ... create: Any = ... update: Any = ... process: Any = ... - def __init__(self, read: bool = ..., write: bool = ..., delete: bool = ..., list: bool = ..., add: bool = ..., create: bool = ..., update: bool = ..., process: bool = ...) -> None: ... + def __init__(self, read: bool = ..., write: bool = ..., delete: bool = ..., list: bool = ..., add: bool = ..., create: bool = ..., update: bool = ..., process: bool = ..., delete_version: bool = ...) -> None: ... @classmethod def from_string(cls, permission: Any): ... diff --git a/sdk/storage/azure-storage-file-share/out/azure/storage/fileshare/aio/_share_client_async.pyi b/sdk/storage/azure-storage-file-share/out/azure/storage/fileshare/aio/_share_client_async.pyi index 4b1c5e5b2bfa..b8b71f67a1f1 100644 --- a/sdk/storage/azure-storage-file-share/out/azure/storage/fileshare/aio/_share_client_async.pyi +++ b/sdk/storage/azure-storage-file-share/out/azure/storage/fileshare/aio/_share_client_async.pyi @@ -24,6 +24,7 @@ class ShareClient(AsyncStorageAccountHostsMixin, ShareClientBase): async def create_share(self, **kwargs: Any) -> Dict[str, Any]: ... async def create_snapshot(self, **kwargs: Optional[Any]) -> Dict[str, Any]: ... async def delete_share(self, delete_snapshots: Optional[bool]=..., **kwargs: Any) -> None: ... + async def undelete_share(self, deleted_share_name: str, deleted_share_version: str, **kwargs: Any) -> None: ... async def get_share_properties(self, **kwargs: Any) -> ShareProperties: ... async def set_share_quota(self, quota: int, **kwargs: Any) -> Dict[str, Any]: ... async def set_share_metadata(self, metadata: Dict[str, Any], **kwargs: Any) -> Dict[str, Any]: ...