APIs on Master

sdk/storage/azure-storage-blob/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

sdk/storage/azure-storage-blob/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

sdk/storage/azure-storage-blob/out/azure/storage/blob/__init__.pyi

@@ -0,0 +1,19 @@
+# Stubs for azure.storage.blob (Python 3)
+#
+# NOTE: This dynamically typed stub was automatically generated by stubgen.
+
+from ._blob_client import BlobClient as BlobClient
+from ._blob_service_client import BlobServiceClient as BlobServiceClient
+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 ._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
+from ._shared_access_signature import generate_account_sas as generate_account_sas, generate_blob_sas as generate_blob_sas, generate_container_sas as generate_container_sas
+from typing import Any, AnyStr, Dict, IO, Iterable, Union
+
+def upload_blob_to_url(blob_url: str, data: Union[Iterable[AnyStr], IO[AnyStr]], credential: Any=..., **kwargs: Any) -> Dict[str, Any]: ...
+def download_blob_from_url(blob_url: str, output: str, credential: Any=..., **kwargs: Any) -> None: ...

sdk/storage/azure-storage-blob/out/azure/storage/blob/_blob_client.pyi

@@ -0,0 +1,59 @@
+# Stubs for azure.storage.blob._blob_client (Python 3)
+#
+# NOTE: This dynamically typed stub was automatically generated by stubgen.
+
+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 ._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 ._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.uploads import IterStreamer
+from ._upload_helpers import upload_append_blob, upload_block_blob, upload_page_blob
+from datetime import datetime
+from typing import Any, AnyStr, Dict, IO, Iterable, List, Optional, Tuple, Union
+
+class BlobClient(StorageAccountHostsMixin):
+    container_name: Any = ...
+    blob_name: Any = ...
+    snapshot: 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: ...
+    @classmethod
+    def from_connection_string(cls: Any, conn_str: str, container_name: str, blob_name: str, snapshot: Optional[str]=..., credential: Optional[Any]=..., **kwargs: Any) -> BlobClient: ...
+    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 delete_blob(self, delete_snapshots: bool=..., **kwargs: Any) -> None: ...
+    def undelete_blob(self, **kwargs: Any) -> None: ...
+    def get_blob_properties(self, **kwargs: Any) -> BlobProperties: ...
+    def set_http_headers(self, content_settings: Optional[ContentSettings]=..., **kwargs: Any) -> None: ...
+    def set_blob_metadata(self, metadata: Optional[Dict[str, str]]=..., **kwargs: Any) -> Dict[str, Union[str, datetime]]: ...
+    def create_page_blob(self, size: int, content_settings: Optional[ContentSettings]=..., metadata: Optional[Dict[str, str]]=..., premium_page_blob_tier: Optional[Union[str, PremiumPageBlobTier]]=..., **kwargs: Any) -> Dict[str, Union[str, datetime]]: ...
+    def create_append_blob(self, content_settings: Optional[ContentSettings]=..., metadata: Optional[Dict[str, str]]=..., **kwargs: Any) -> Dict[str, Union[str, datetime]]: ...
+    def create_snapshot(self, metadata: Optional[Dict[str, str]]=..., **kwargs: Any) -> Dict[str, Union[str, datetime]]: ...
+    def start_copy_from_url(self, source_url: str, metadata: Optional[Dict[str, str]]=..., incremental_copy: bool=..., **kwargs: Any) -> Dict[str, Union[str, datetime]]: ...
+    def abort_copy(self, copy_id: Union[str, Dict[str, Any], BlobProperties], **kwargs: Any) -> None: ...
+    def acquire_lease(self, lease_duration: int=..., lease_id: Optional[str]=..., **kwargs: Any) -> BlobLeaseClient: ...
+    def set_standard_blob_tier(self, standard_blob_tier: Union[str, StandardBlobTier], **kwargs: Any) -> None: ...
+    def stage_block(self, block_id: str, data: Union[Iterable[AnyStr], IO[AnyStr]], length: Optional[int]=..., **kwargs: Any) -> Dict[str, Any]: ...
+    def stage_block_from_url(self, block_id: str, source_url: str, source_offset: Optional[int]=..., source_length: Optional[int]=..., source_content_md5: Optional[Union[bytes, bytearray]]=..., **kwargs: Any) -> Dict[str, Any]: ...
+    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 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]]: ...
+    def resize_blob(self, size: int, **kwargs: Any) -> Dict[str, Union[str, datetime]]: ...
+    def upload_page(self, page: bytes, offset: int, length: int, **kwargs: Any) -> Dict[str, Union[str, datetime]]: ...
+    def upload_pages_from_url(self, source_url: str, offset: int, length: int, source_offset: int, **kwargs: Any) -> Dict[str, Any]: ...
+    def clear_page(self, offset: int, length: int, **kwargs: Any) -> Dict[str, Union[str, datetime]]: ...
+    def append_block(self, data: Union[AnyStr, Iterable[AnyStr], IO[AnyStr]], length: Optional[int]=..., **kwargs: Any) -> Dict[str, Union[str, datetime, int]]: ...
+    def append_block_from_url(self, copy_source_url: str, source_offset: Optional[int]=..., source_length: Optional[int]=..., **kwargs: Any) -> Dict[str, Union[str, datetime, int]]: ...

sdk/storage/azure-storage-blob/out/azure/storage/blob/_blob_service_client.pyi

@@ -0,0 +1,34 @@
+# Stubs for azure.storage.blob._blob_service_client (Python 3)
+#
+# NOTE: This dynamically typed stub was automatically generated by stubgen.
+
+from ._blob_client import BlobClient
+from ._container_client import ContainerClient
+from ._deserialize import service_properties_deserialize, service_stats_deserialize
+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 ._serialize import get_api_version
+from ._shared.base_client import StorageAccountHostsMixin, TransportWrapper, parse_connection_str, parse_query
+from ._shared.models import LocationMode, UserDelegationKey
+from ._shared.parser import _to_utc_datetime
+from ._shared.response_handlers import parse_to_internal_user_delegation_key, process_storage_error, return_response_headers
+from azure.core.paging import ItemPaged
+from datetime import datetime
+from typing import Any, Dict, List, Optional, Union
+
+class BlobServiceClient(StorageAccountHostsMixin):
+    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 get_user_delegation_key(self, key_start_time: datetime, key_expiry_time: datetime, **kwargs: Any) -> UserDelegationKey: ...
+    def get_account_information(self, **kwargs: Any) -> Dict[str, str]: ...
+    def get_service_stats(self, **kwargs: Any) -> Dict[str, Any]: ...
+    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 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: ...
+    def get_blob_client(self, container: Union[ContainerProperties, str], blob: Union[BlobProperties, str], snapshot: Optional[Union[Dict[str, Any], str]]=...) -> BlobClient: ...

sdk/storage/azure-storage-blob/out/azure/storage/blob/_container_client.pyi

@@ -0,0 +1,43 @@
+# Stubs for azure.storage.blob._container_client (Python 3)
+#
+# NOTE: This dynamically typed stub was automatically generated by stubgen.
+
+from ._blob_client import BlobClient
+from ._deserialize import deserialize_container_properties
+from ._generated import AzureBlobStorage, VERSION
+from ._generated.models import SignedIdentifier, StorageErrorException
+from ._lease import BlobLeaseClient, get_access_conditions
+from ._models import AccessPolicy, BlobPrefix, BlobProperties, BlobPropertiesPaged, BlobType, ContainerProperties, ContentSettings, PremiumPageBlobTier, PublicAccess, StandardBlobTier
+from ._serialize import get_api_version, get_container_cpk_scope_info, get_modify_conditions
+from ._shared.base_client import StorageAccountHostsMixin, TransportWrapper, parse_connection_str, parse_query
+from ._shared.request_handlers import add_metadata_headers, serialize_iso
+from ._shared.response_handlers import process_storage_error, return_headers_and_deserialized, return_response_headers
+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
+
+class ContainerClient(StorageAccountHostsMixin):
+    container_name: Any = ...
+    def __init__(self, account_url: str, container_name: str, credential: Optional[Any]=..., **kwargs: Any) -> None: ...
+    @classmethod
+    def from_container_url(cls: Any, container_url: str, credential: Optional[Any]=..., **kwargs: Any) -> ContainerClient: ...
+    @classmethod
+    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 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 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: ...
+    def download_blob(self, blob: Union[str, BlobProperties], offset: Optional[int]=..., length: Optional[int]=..., **kwargs: Any) -> StorageStreamDownloader: ...
+    def delete_blobs(self, *blobs: Any, **kwargs: Any) -> Iterator[HttpResponse]: ...
+    def set_standard_blob_tier_blobs(self, standard_blob_tier: Union[str, StandardBlobTier], *blobs: Union[str, BlobProperties], **kwargs: Any) -> Iterator[HttpResponse]: ...
+    def set_premium_page_blob_tier_blobs(self, premium_page_blob_tier: Union[str, PremiumPageBlobTier], *blobs: Union[str, BlobProperties], **kwargs: Any) -> Iterator[HttpResponse]: ...
+    def get_blob_client(self, blob: Union[str, BlobProperties], snapshot: str=...) -> BlobClient: ...

sdk/storage/azure-storage-blob/out/azure/storage/blob/_deserialize.pyi

@@ -0,0 +1,15 @@
+# Stubs for azure.storage.blob._deserialize (Python 3)
+#
+# NOTE: This dynamically typed stub was automatically generated by stubgen.
+
+from ._models import BlobAnalyticsLogging, BlobProperties, ContainerProperties, CorsRule, Metrics, RetentionPolicy, StaticWebsite
+from ._shared.response_handlers import deserialize_metadata
+from azure.storage.blob._generated.models import PageList
+from typing import Any, Dict, List, Tuple
+
+def deserialize_blob_properties(response: Any, obj: Any, headers: Any): ...
+def deserialize_blob_stream(response: Any, obj: Any, headers: Any): ...
+def deserialize_container_properties(response: Any, obj: Any, headers: Any): ...
+def get_page_ranges_result(ranges: PageList) -> Tuple[List[Dict[str, int]], List[Dict[str, int]]]: ...
+def service_stats_deserialize(generated: Any): ...
+def service_properties_deserialize(generated: Any): ...

sdk/storage/azure-storage-blob/out/azure/storage/blob/_download.pyi

@@ -0,0 +1,54 @@
+# Stubs for azure.storage.blob._download (Python 3)
+#
+# NOTE: This dynamically typed stub was automatically generated by stubgen.
+
+from ._deserialize import get_page_ranges_result
+from ._shared.encryption import decrypt_blob
+from ._shared.request_handlers import validate_and_format_range_headers
+from ._shared.response_handlers import parse_length_from_content_range, process_storage_error
+from typing import Any, Optional
+
+def process_range_and_offset(start_range: Any, end_range: Any, length: Any, encryption: Any): ...
+def process_content(data: Any, start_offset: Any, end_offset: Any, encryption: Any): ...
+
+class _ChunkDownloader:
+    client: Any = ...
+    non_empty_ranges: Any = ...
+    chunk_size: Any = ...
+    total_size: Any = ...
+    start_index: Any = ...
+    end_index: Any = ...
+    stream: Any = ...
+    stream_lock: Any = ...
+    progress_lock: Any = ...
+    stream_start: Any = ...
+    progress_total: Any = ...
+    encryption_options: Any = ...
+    validate_content: Any = ...
+    request_options: Any = ...
+    def __init__(self, client: Optional[Any] = ..., non_empty_ranges: Optional[Any] = ..., total_size: Optional[Any] = ..., chunk_size: Optional[Any] = ..., current_progress: Optional[Any] = ..., start_range: Optional[Any] = ..., end_range: Optional[Any] = ..., stream: Optional[Any] = ..., parallel: Optional[Any] = ..., validate_content: Optional[Any] = ..., encryption_options: Optional[Any] = ..., **kwargs: Any) -> None: ...
+    def get_chunk_offsets(self) -> None: ...
+    def process_chunk(self, chunk_start: Any) -> None: ...
+    def yield_chunk(self, chunk_start: Any): ...
+
+class _ChunkIterator:
+    size: Any = ...
+    def __init__(self, size: Any, content: Any, downloader: Any) -> None: ...
+    def __len__(self): ...
+    def __iter__(self): ...
+    def __next__(self): ...
+    next: Any = ...
+
+class StorageStreamDownloader:
+    name: Any = ...
+    container: Any = ...
+    properties: Any = ...
+    size: Any = ...
+    def __init__(self, clients: Optional[Any] = ..., config: Optional[Any] = ..., start_range: Optional[Any] = ..., end_range: Optional[Any] = ..., validate_content: Optional[Any] = ..., encryption_options: Optional[Any] = ..., max_concurrency: int = ..., name: Optional[Any] = ..., container: Optional[Any] = ..., encoding: Optional[Any] = ..., **kwargs: Any) -> None: ...
+    def __len__(self): ...
+    def chunks(self): ...
+    def readall(self): ...
+    def content_as_bytes(self, max_concurrency: int = ...): ...
+    def content_as_text(self, max_concurrency: int = ..., encoding: str = ...): ...
+    def readinto(self, stream: Any): ...
+    def download_to_stream(self, stream: Any, max_concurrency: int = ...): ...