From aecfd9458928cda269987f3d2bdee21d6f0619d4 Mon Sep 17 00:00:00 2001 From: Travis Prescott Date: Fri, 29 May 2026 16:08:16 -0700 Subject: [PATCH] [API Review] API.md for azure-cosmos 4.16.0b3 --- sdk/cosmos/azure-cosmos/API.md | 152 ++++++++++++++++++++++++++++++--- 1 file changed, 139 insertions(+), 13 deletions(-) diff --git a/sdk/cosmos/azure-cosmos/API.md b/sdk/cosmos/azure-cosmos/API.md index 225b75e9b7da..2ef508e09d9a 100644 --- a/sdk/cosmos/azure-cosmos/API.md +++ b/sdk/cosmos/azure-cosmos/API.md @@ -45,6 +45,7 @@ namespace azure.cosmos post_trigger_include: Optional[str] = None, indexing_directive: Optional[int] = None, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., enable_automatic_id_generation: bool = False, excluded_locations: Optional[Sequence[str]] = ..., initial_headers: Optional[dict[str, str]] = ..., @@ -90,6 +91,7 @@ namespace azure.cosmos pre_trigger_include: Optional[str] = None, post_trigger_include: Optional[str] = None, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., etag: Optional[str] = ..., excluded_locations: Optional[Sequence[str]] = ..., initial_headers: Optional[dict[str, str]] = ..., @@ -108,11 +110,13 @@ namespace azure.cosmos batch_operations: Sequence[Union[Tuple[str, Tuple[Any, ]], Tuple[str, Tuple[Any, ], dict[str, Any]]]], partition_key: PartitionKeyType, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., excluded_locations: Optional[Sequence[str]] = ..., post_trigger_include: Optional[str] = ..., pre_trigger_include: Optional[str] = ..., priority: Optional[Literal[High, Low]] = ..., response_hook: Optional[Callable[[Mapping[str, str], list[dict[str, Any]]], None]] = ..., + retry_write: Optional[int] = ..., session_token: Optional[str] = ..., throughput_bucket: Optional[int] = ..., **kwargs: Any @@ -166,6 +170,7 @@ namespace azure.cosmos partition_key: PartitionKeyType, patch_operations: list[dict[str, Any]], *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., etag: Optional[str] = ..., excluded_locations: Optional[Sequence[str]] = ..., filter_predicate: Optional[str] = ..., @@ -205,43 +210,50 @@ namespace azure.cosmos enable_scan_in_query: Optional[bool] = None, populate_query_metrics: Optional[bool] = None, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., continuation_token_limit: Optional[int] = ..., + full_text_score_scope: Optional[Literal[Local, Global]] = ..., initial_headers: Optional[dict[str, str]] = ..., max_integrated_cache_staleness_in_ms: Optional[int] = ..., populate_index_metrics: Optional[bool] = ..., + populate_query_advice: Optional[bool] = ..., priority: Optional[Literal[High, Low]] = ..., response_hook: Optional[Callable[[Mapping[str, str], dict[str, Any]], None]] = ..., session_token: Optional[str] = ..., throughput_bucket: Optional[int] = ..., **kwargs: Any - ) -> ItemPaged[dict[str, Any]]: ... + ) -> CosmosItemPaged: ... @overload def query_items( self, query: str, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., continuation_token_limit: Optional[int] = ..., enable_cross_partition_query: Optional[bool] = ..., enable_scan_in_query: Optional[bool] = ..., feed_range: dict[str, Any], + full_text_score_scope: Optional[Literal[Local, Global]] = ..., initial_headers: Optional[dict[str, str]] = ..., max_integrated_cache_staleness_in_ms: Optional[int] = ..., max_item_count: Optional[int] = ..., parameters: Optional[list[dict[str, object]]] = ..., populate_index_metrics: Optional[bool] = ..., + populate_query_advice: Optional[bool] = ..., populate_query_metrics: Optional[bool] = ..., priority: Optional[Literal[High, Low]] = ..., response_hook: Optional[Callable[[Mapping[str, str], dict[str, Any]], None]] = ..., session_token: Optional[str] = ..., throughput_bucket: Optional[int] = ..., **kwargs: Any - ) -> ItemPaged[dict[str, Any]]: ... + ) -> CosmosItemPaged: ... @overload def query_items_change_feed( self, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., max_item_count: Optional[int] = ..., mode: Optional[Literal[LatestVersion, AllVersionsAndDeletes]] = ..., partition_key: PartitionKeyType, @@ -255,6 +267,7 @@ namespace azure.cosmos def query_items_change_feed( self, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., feed_range: dict[str, Any], max_item_count: Optional[int] = ..., mode: Optional[Literal[LatestVersion, AllVersionsAndDeletes]] = ..., @@ -268,6 +281,7 @@ namespace azure.cosmos def query_items_change_feed( self, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., continuation: str, max_item_count: Optional[int] = ..., priority: Optional[Literal[High, Low]] = ..., @@ -279,6 +293,7 @@ namespace azure.cosmos def query_items_change_feed( self, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., max_item_count: Optional[int] = ..., mode: Optional[Literal[LatestVersion, AllVersionsAndDeletes]] = ..., priority: Optional[Literal[High, Low]] = ..., @@ -306,6 +321,7 @@ namespace azure.cosmos max_item_count: Optional[int] = None, populate_query_metrics: Optional[bool] = None, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., excluded_locations: Optional[Sequence[str]] = ..., initial_headers: Optional[dict[str, str]] = ..., max_integrated_cache_staleness_in_ms: Optional[int] = ..., @@ -332,6 +348,7 @@ namespace azure.cosmos populate_query_metrics: Optional[bool] = None, post_trigger_include: Optional[str] = None, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., excluded_locations: Optional[Sequence[str]] = ..., initial_headers: Optional[dict[str, str]] = ..., max_integrated_cache_staleness_in_ms: Optional[int] = ..., @@ -347,6 +364,7 @@ namespace azure.cosmos self, items: Sequence[Tuple[str, PartitionKeyType]], *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., consistency_level: Optional[str] = ..., excluded_locations: Optional[list[str]] = ..., executor: Optional[ThreadPoolExecutor] = ..., @@ -375,6 +393,7 @@ namespace azure.cosmos pre_trigger_include: Optional[str] = None, post_trigger_include: Optional[str] = None, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., etag: Optional[str] = ..., excluded_locations: Optional[Sequence[str]] = ..., initial_headers: Optional[dict[str, str]] = ..., @@ -414,6 +433,7 @@ namespace azure.cosmos pre_trigger_include: Optional[str] = None, post_trigger_include: Optional[str] = None, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., etag: Optional[str] = ..., excluded_locations: Optional[Sequence[str]] = ..., initial_headers: Optional[dict[str, str]] = ..., @@ -449,6 +469,8 @@ namespace azure.cosmos **kwargs ) -> CosmosClient: ... + def close(self) -> None: ... + @overload def create_database( self, @@ -1257,6 +1279,7 @@ namespace azure.cosmos.aio self, body: dict[str, Any], *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., enable_automatic_id_generation: bool = False, excluded_locations: Optional[Sequence[str]] = ..., indexing_directive: Optional[int] = ..., @@ -1302,6 +1325,7 @@ namespace azure.cosmos.aio item: Union[str, Mapping[str, Any]], partition_key: PartitionKeyType, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., etag: Optional[str] = ..., excluded_locations: Optional[Sequence[str]] = ..., initial_headers: Optional[dict[str, str]] = ..., @@ -1322,11 +1346,13 @@ namespace azure.cosmos.aio batch_operations: Sequence[Union[Tuple[str, Tuple[Any, ]], Tuple[str, Tuple[Any, ], dict[str, Any]]]], partition_key: PartitionKeyType, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., excluded_locations: Optional[Sequence[str]] = ..., post_trigger_include: Optional[str] = ..., pre_trigger_include: Optional[str] = ..., priority: Optional[Literal[High, Low]] = ..., response_hook: Optional[Callable] = ..., + retry_write: Optional[int] = ..., session_token: Optional[str] = ..., throughput_bucket: Optional[int] = ..., **kwargs: Any @@ -1380,6 +1406,7 @@ namespace azure.cosmos.aio partition_key: PartitionKeyType, patch_operations: list[dict[str, Any]], *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., etag: Optional[str] = ..., excluded_locations: Optional[Sequence[str]] = ..., filter_predicate: Optional[str] = ..., @@ -1412,67 +1439,77 @@ namespace azure.cosmos.aio self, query: str, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., continuation_token_limit: Optional[int] = ..., enable_scan_in_query: Optional[bool] = ..., + full_text_score_scope: Optional[Literal[Local, Global]] = ..., initial_headers: Optional[dict[str, str]] = ..., max_integrated_cache_staleness_in_ms: Optional[int] = ..., max_item_count: Optional[int] = ..., parameters: Optional[list[dict[str, object]]] = ..., partition_key: PartitionKeyType, populate_index_metrics: Optional[bool] = ..., + populate_query_advice: Optional[bool] = ..., populate_query_metrics: Optional[bool] = ..., priority: Optional[Literal[High, Low]] = ..., response_hook: Optional[Callable[[Mapping[str, str], dict[str, Any]], None]] = ..., session_token: Optional[str] = ..., throughput_bucket: Optional[int] = ..., **kwargs: Any - ) -> AsyncItemPaged[dict[str, Any]]: ... + ) -> CosmosAsyncItemPaged: ... @overload def query_items( self, query: str, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., continuation_token_limit: Optional[int] = ..., enable_scan_in_query: Optional[bool] = ..., feed_range: dict[str, Any], + full_text_score_scope: Optional[Literal[Local, Global]] = ..., initial_headers: Optional[dict[str, str]] = ..., max_integrated_cache_staleness_in_ms: Optional[int] = ..., max_item_count: Optional[int] = ..., parameters: Optional[list[dict[str, object]]] = ..., populate_index_metrics: Optional[bool] = ..., + populate_query_advice: Optional[bool] = ..., populate_query_metrics: Optional[bool] = ..., priority: Optional[Literal[High, Low]] = ..., response_hook: Optional[Callable[[Mapping[str, str], dict[str, Any]], None]] = ..., session_token: Optional[str] = ..., throughput_bucket: Optional[int] = ..., **kwargs: Any - ) -> AsyncItemPaged[dict[str, Any]]: ... + ) -> CosmosAsyncItemPaged: ... @overload def query_items( self, query: str, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., continuation_token_limit: Optional[int] = ..., enable_scan_in_query: Optional[bool] = ..., + full_text_score_scope: Optional[Literal[Local, Global]] = ..., initial_headers: Optional[dict[str, str]] = ..., max_integrated_cache_staleness_in_ms: Optional[int] = ..., max_item_count: Optional[int] = ..., parameters: Optional[list[dict[str, object]]] = ..., populate_index_metrics: Optional[bool] = ..., + populate_query_advice: Optional[bool] = ..., populate_query_metrics: Optional[bool] = ..., priority: Optional[Literal[High, Low]] = ..., response_hook: Optional[Callable[[Mapping[str, str], dict[str, Any]], None]] = ..., session_token: Optional[str] = ..., throughput_bucket: Optional[int] = ..., **kwargs: Any - ) -> AsyncItemPaged[dict[str, Any]]: ... + ) -> CosmosAsyncItemPaged: ... @overload def query_items_change_feed( self, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., max_item_count: Optional[int] = ..., mode: Optional[Literal[LatestVersion, AllVersionsAndDeletes]] = ..., partition_key: PartitionKeyType, @@ -1486,6 +1523,7 @@ namespace azure.cosmos.aio def query_items_change_feed( self, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., feed_range: dict[str, Any], max_item_count: Optional[int] = ..., mode: Optional[Literal[LatestVersion, AllVersionsAndDeletes]] = ..., @@ -1499,6 +1537,7 @@ namespace azure.cosmos.aio def query_items_change_feed( self, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., continuation: str, max_item_count: Optional[int] = ..., priority: Optional[Literal[High, Low]] = ..., @@ -1510,6 +1549,7 @@ namespace azure.cosmos.aio def query_items_change_feed( self, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., max_item_count: Optional[int] = ..., mode: Optional[Literal[LatestVersion, AllVersionsAndDeletes]] = ..., priority: Optional[Literal[High, Low]] = ..., @@ -1534,6 +1574,7 @@ namespace azure.cosmos.aio def read_all_items( self, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., excluded_locations: Optional[Sequence[str]] = ..., initial_headers: Optional[dict[str, str]] = ..., max_integrated_cache_staleness_in_ms: Optional[int] = ..., @@ -1559,6 +1600,7 @@ namespace azure.cosmos.aio item: Union[str, Mapping[str, Any]], partition_key: PartitionKeyType, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., excluded_locations: Optional[Sequence[str]] = ..., initial_headers: Optional[dict[str, str]] = ..., max_integrated_cache_staleness_in_ms: Optional[int] = ..., @@ -1575,6 +1617,7 @@ namespace azure.cosmos.aio self, items: Sequence[Tuple[str, PartitionKeyType]], *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., consistency_level: Optional[str] = ..., excluded_locations: Optional[list[str]] = ..., initial_headers: Optional[dict[str, str]] = ..., @@ -1591,6 +1634,7 @@ namespace azure.cosmos.aio item: Union[str, Mapping[str, Any]], body: dict[str, Any], *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., etag: Optional[str] = ..., excluded_locations: Optional[Sequence[str]] = ..., initial_headers: Optional[dict[str, str]] = ..., @@ -1629,6 +1673,7 @@ namespace azure.cosmos.aio self, body: dict[str, Any], *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., etag: Optional[str] = ..., excluded_locations: Optional[Sequence[str]] = ..., initial_headers: Optional[dict[str, str]] = ..., @@ -1652,6 +1697,8 @@ namespace azure.cosmos.aio url: str, credential: Union[str, dict[str, str], AsyncTokenCredential], *, + availability_strategy: Union[bool, dict[str, Any]] = False, + availability_strategy_max_concurrency: Optional[int] = ..., consistency_level: Optional[str] = ..., **kwargs: Any ) -> None: ... @@ -2305,6 +2352,7 @@ namespace azure.cosmos.container post_trigger_include: Optional[str] = None, indexing_directive: Optional[int] = None, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., enable_automatic_id_generation: bool = False, excluded_locations: Optional[Sequence[str]] = ..., initial_headers: Optional[dict[str, str]] = ..., @@ -2350,6 +2398,7 @@ namespace azure.cosmos.container pre_trigger_include: Optional[str] = None, post_trigger_include: Optional[str] = None, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., etag: Optional[str] = ..., excluded_locations: Optional[Sequence[str]] = ..., initial_headers: Optional[dict[str, str]] = ..., @@ -2368,11 +2417,13 @@ namespace azure.cosmos.container batch_operations: Sequence[Union[Tuple[str, Tuple[Any, ]], Tuple[str, Tuple[Any, ], dict[str, Any]]]], partition_key: PartitionKeyType, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., excluded_locations: Optional[Sequence[str]] = ..., post_trigger_include: Optional[str] = ..., pre_trigger_include: Optional[str] = ..., priority: Optional[Literal[High, Low]] = ..., response_hook: Optional[Callable[[Mapping[str, str], list[dict[str, Any]]], None]] = ..., + retry_write: Optional[int] = ..., session_token: Optional[str] = ..., throughput_bucket: Optional[int] = ..., **kwargs: Any @@ -2426,6 +2477,7 @@ namespace azure.cosmos.container partition_key: PartitionKeyType, patch_operations: list[dict[str, Any]], *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., etag: Optional[str] = ..., excluded_locations: Optional[Sequence[str]] = ..., filter_predicate: Optional[str] = ..., @@ -2465,43 +2517,50 @@ namespace azure.cosmos.container enable_scan_in_query: Optional[bool] = None, populate_query_metrics: Optional[bool] = None, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., continuation_token_limit: Optional[int] = ..., + full_text_score_scope: Optional[Literal[Local, Global]] = ..., initial_headers: Optional[dict[str, str]] = ..., max_integrated_cache_staleness_in_ms: Optional[int] = ..., populate_index_metrics: Optional[bool] = ..., + populate_query_advice: Optional[bool] = ..., priority: Optional[Literal[High, Low]] = ..., response_hook: Optional[Callable[[Mapping[str, str], dict[str, Any]], None]] = ..., session_token: Optional[str] = ..., throughput_bucket: Optional[int] = ..., **kwargs: Any - ) -> ItemPaged[dict[str, Any]]: ... + ) -> CosmosItemPaged: ... @overload def query_items( self, query: str, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., continuation_token_limit: Optional[int] = ..., enable_cross_partition_query: Optional[bool] = ..., enable_scan_in_query: Optional[bool] = ..., feed_range: dict[str, Any], + full_text_score_scope: Optional[Literal[Local, Global]] = ..., initial_headers: Optional[dict[str, str]] = ..., max_integrated_cache_staleness_in_ms: Optional[int] = ..., max_item_count: Optional[int] = ..., parameters: Optional[list[dict[str, object]]] = ..., populate_index_metrics: Optional[bool] = ..., + populate_query_advice: Optional[bool] = ..., populate_query_metrics: Optional[bool] = ..., priority: Optional[Literal[High, Low]] = ..., response_hook: Optional[Callable[[Mapping[str, str], dict[str, Any]], None]] = ..., session_token: Optional[str] = ..., throughput_bucket: Optional[int] = ..., **kwargs: Any - ) -> ItemPaged[dict[str, Any]]: ... + ) -> CosmosItemPaged: ... @overload def query_items_change_feed( self, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., max_item_count: Optional[int] = ..., mode: Optional[Literal[LatestVersion, AllVersionsAndDeletes]] = ..., partition_key: PartitionKeyType, @@ -2515,6 +2574,7 @@ namespace azure.cosmos.container def query_items_change_feed( self, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., feed_range: dict[str, Any], max_item_count: Optional[int] = ..., mode: Optional[Literal[LatestVersion, AllVersionsAndDeletes]] = ..., @@ -2528,6 +2588,7 @@ namespace azure.cosmos.container def query_items_change_feed( self, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., continuation: str, max_item_count: Optional[int] = ..., priority: Optional[Literal[High, Low]] = ..., @@ -2539,6 +2600,7 @@ namespace azure.cosmos.container def query_items_change_feed( self, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., max_item_count: Optional[int] = ..., mode: Optional[Literal[LatestVersion, AllVersionsAndDeletes]] = ..., priority: Optional[Literal[High, Low]] = ..., @@ -2566,6 +2628,7 @@ namespace azure.cosmos.container max_item_count: Optional[int] = None, populate_query_metrics: Optional[bool] = None, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., excluded_locations: Optional[Sequence[str]] = ..., initial_headers: Optional[dict[str, str]] = ..., max_integrated_cache_staleness_in_ms: Optional[int] = ..., @@ -2592,6 +2655,7 @@ namespace azure.cosmos.container populate_query_metrics: Optional[bool] = None, post_trigger_include: Optional[str] = None, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., excluded_locations: Optional[Sequence[str]] = ..., initial_headers: Optional[dict[str, str]] = ..., max_integrated_cache_staleness_in_ms: Optional[int] = ..., @@ -2607,6 +2671,7 @@ namespace azure.cosmos.container self, items: Sequence[Tuple[str, PartitionKeyType]], *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., consistency_level: Optional[str] = ..., excluded_locations: Optional[list[str]] = ..., executor: Optional[ThreadPoolExecutor] = ..., @@ -2635,6 +2700,7 @@ namespace azure.cosmos.container pre_trigger_include: Optional[str] = None, post_trigger_include: Optional[str] = None, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., etag: Optional[str] = ..., excluded_locations: Optional[Sequence[str]] = ..., initial_headers: Optional[dict[str, str]] = ..., @@ -2674,6 +2740,7 @@ namespace azure.cosmos.container pre_trigger_include: Optional[str] = None, post_trigger_include: Optional[str] = None, *, + availability_strategy: Optional[Union[bool, dict[str, Any]]] = ..., etag: Optional[str] = ..., excluded_locations: Optional[Sequence[str]] = ..., initial_headers: Optional[dict[str, str]] = ..., @@ -2711,6 +2778,8 @@ namespace azure.cosmos.cosmos_client **kwargs ) -> CosmosClient: ... + def close(self) -> None: ... + @overload def create_database( self, @@ -3234,6 +3303,8 @@ namespace azure.cosmos.errors **kwargs ): ... + def __str__(self): ... + class azure.cosmos.errors.CosmosBatchOperationError(HttpResponseError): error_index: int @@ -3255,7 +3326,11 @@ namespace azure.cosmos.errors class azure.cosmos.errors.CosmosClientTimeoutError(AzureError): - def __init__(self, **kwargs): ... + def __init__( + self, + message = None, + **kwargs + ): ... class azure.cosmos.errors.CosmosHttpResponseError(HttpResponseError): @@ -3268,6 +3343,8 @@ namespace azure.cosmos.errors **kwargs ): ... + def __str__(self): ... + class azure.cosmos.errors.CosmosResourceExistsError(ResourceExistsError, CosmosHttpResponseError): @@ -3279,6 +3356,8 @@ namespace azure.cosmos.errors **kwargs ): ... + def __str__(self): ... + class azure.cosmos.errors.CosmosResourceNotFoundError(ResourceNotFoundError, CosmosHttpResponseError): @@ -3290,6 +3369,8 @@ namespace azure.cosmos.errors **kwargs ): ... + def __str__(self): ... + namespace azure.cosmos.exceptions @@ -3303,6 +3384,8 @@ namespace azure.cosmos.exceptions **kwargs ): ... + def __str__(self): ... + class azure.cosmos.exceptions.CosmosBatchOperationError(HttpResponseError): error_index: int @@ -3324,7 +3407,11 @@ namespace azure.cosmos.exceptions class azure.cosmos.exceptions.CosmosClientTimeoutError(AzureError): - def __init__(self, **kwargs): ... + def __init__( + self, + message = None, + **kwargs + ): ... class azure.cosmos.exceptions.CosmosHttpResponseError(HttpResponseError): @@ -3337,6 +3424,8 @@ namespace azure.cosmos.exceptions **kwargs ): ... + def __str__(self): ... + class azure.cosmos.exceptions.CosmosResourceExistsError(ResourceExistsError, CosmosHttpResponseError): @@ -3348,6 +3437,8 @@ namespace azure.cosmos.exceptions **kwargs ): ... + def __str__(self): ... + class azure.cosmos.exceptions.CosmosResourceNotFoundError(ResourceNotFoundError, CosmosHttpResponseError): @@ -3359,6 +3450,8 @@ namespace azure.cosmos.exceptions **kwargs ): ... + def __str__(self): ... + namespace azure.cosmos.http_constants @@ -3484,6 +3577,7 @@ namespace azure.cosmos.http_constants PhysicalPartitionId = x-ms-cosmos-physical-partition-id PopulateIndexMetrics = x-ms-cosmos-populateindexmetrics PopulatePartitionKeyRangeStatistics = x-ms-documentdb-populatepartitionstatistics + PopulateQueryAdvice = x-ms-cosmos-populatequeryadvice PopulateQueryMetrics = x-ms-documentdb-populatequerymetrics PopulateQuotaInfo = x-ms-documentdb-populatequotainfo PostTriggerExclude = x-ms-documentdb-post-trigger-exclude @@ -3496,6 +3590,7 @@ namespace azure.cosmos.http_constants ProxyAuthenticate = Proxy-Authenticate ProxyAuthorization = Proxy-Authorization Query = x-ms-documentdb-query + QueryAdvice = x-ms-cosmos-query-advice QueryExecutionInfo = x-ms-cosmos-query-execution-info QueryMetrics = x-ms-documentdb-query-metrics QueryVersion = x-ms-cosmos-query-version @@ -3622,6 +3717,11 @@ namespace azure.cosmos.http_constants def IsCollectionChild(resourceType: str) -> bool: ... + class azure.cosmos.http_constants.SDKSupportedCapabilities: + NONE = 0 + PARTITION_MERGE = 1 + + class azure.cosmos.http_constants.StatusCodes: ACCEPTED = 202 BAD_REQUEST = 400 @@ -3783,6 +3883,8 @@ namespace azure.cosmos.scripts auth: CredentialDict, connection_policy: Optional[ConnectionPolicy] = None, consistency_level: Optional[str] = None, + availability_strategy: Union[bool, dict[str, Any]] = False, + availability_strategy_executor: Optional[ThreadPoolExecutor] = None, **kwargs: Any ) -> None: ... @@ -4013,7 +4115,7 @@ namespace azure.cosmos.scripts partition_key: Optional[PartitionKeyType] = None, response_hook: Optional[Callable[[Mapping[str, Any], dict[str, Any]], None]] = None, **kwargs: Any - ) -> ItemPaged[dict[str, Any]]: ... + ) -> CosmosItemPaged: ... def QueryItemsChangeFeed( self, @@ -4357,6 +4459,12 @@ namespace azure.cosmos.scripts **kwargs: Any ) -> CosmosDict: ... + def health_check( + self, + url_connection: Optional[str] = None, + **kwargs: Any + ): ... + def read_items( self, collection_link: str, @@ -4367,7 +4475,12 @@ namespace azure.cosmos.scripts **kwargs: Any ) -> CosmosList: ... - def refresh_routing_map_provider(self) -> None: ... + def refresh_routing_map_provider( + self, + collection_link: Optional[str] = None, + previous_routing_map: Optional[Any] = None, + feed_options: Optional[dict[str, Any]] = None + ) -> None: ... class azure.cosmos.scripts.CosmosDict(dict[str, Any]): @@ -4564,6 +4677,8 @@ namespace azure.cosmos.user auth: CredentialDict, connection_policy: Optional[ConnectionPolicy] = None, consistency_level: Optional[str] = None, + availability_strategy: Union[bool, dict[str, Any]] = False, + availability_strategy_executor: Optional[ThreadPoolExecutor] = None, **kwargs: Any ) -> None: ... @@ -4794,7 +4909,7 @@ namespace azure.cosmos.user partition_key: Optional[PartitionKeyType] = None, response_hook: Optional[Callable[[Mapping[str, Any], dict[str, Any]], None]] = None, **kwargs: Any - ) -> ItemPaged[dict[str, Any]]: ... + ) -> CosmosItemPaged: ... def QueryItemsChangeFeed( self, @@ -5138,6 +5253,12 @@ namespace azure.cosmos.user **kwargs: Any ) -> CosmosDict: ... + def health_check( + self, + url_connection: Optional[str] = None, + **kwargs: Any + ): ... + def read_items( self, collection_link: str, @@ -5148,7 +5269,12 @@ namespace azure.cosmos.user **kwargs: Any ) -> CosmosList: ... - def refresh_routing_map_provider(self) -> None: ... + def refresh_routing_map_provider( + self, + collection_link: Optional[str] = None, + previous_routing_map: Optional[Any] = None, + feed_options: Optional[dict[str, Any]] = None + ) -> None: ... class azure.cosmos.user.CosmosDict(dict[str, Any]):