DatabaseProxy Klass
Ett gränssnitt för att interagera med en specifik databas.
Den här klassen ska inte instansieras direkt. Använd get_database_client i stället metoden .
En databas innehåller en eller flera containrar som var och en kan innehålla objekt, lagrade procedurer, utlösare och användardefinierade funktioner.
En databas kan också ha associerade användare, som var och en har konfigurerats med en uppsättning behörigheter för åtkomst till vissa containrar, lagrade procedurer, utlösare, användardefinierade funktioner eller objekt.
En Azure Cosmos DB SQL API-databas har följande systemgenererade egenskaper. Dessa egenskaper är skrivskyddade:
_rid: Resurs-ID.
_ts: När resursen senast uppdaterades. Värdet är en tidsstämpel.
_self: Resursens unika adresserbara URI.
_etag: Resursetaggar som krävs för optimistisk samtidighetskontroll.
_colls: Den adresserbara sökvägen för samlingsresursen.
_users: Den adresserbara sökvägen för användarresursen.
- Arv
-
builtins.objectDatabaseProxy
Konstruktor
DatabaseProxy(client_connection: CosmosClientConnection, id: str, properties: Dict[str, Any] = None)Parametrar
- client_connection
- <xref:ClientSession>
Klienten som den här databasen hämtades från.
- properties
Variabler
- id
Databasens ID (namn).
Metoder
| create_container |
Skapa en ny container med det angivna ID:t (namn). Om det redan finns en container med det angivna ID:t utlöses en CosmosResourceExistsError. |
| create_container_if_not_exists |
Skapa en container om den inte redan finns. Om containern redan finns returneras de befintliga inställningarna. Obs! Den kontrollerar eller uppdaterar inte befintliga containerinställningar eller erbjuder dataflöde om de skiljer sig från vad som skickades till metoden. |
| create_user |
Skapa en ny användare i containern. Om du vill uppdatera eller ersätta en befintlig användare använder du <xref:ContainerProxy.upsert_user> metoden . |
| delete_container |
Ta bort en container. |
| delete_user |
Ta bort den angivna användaren från containern. |
| get_container_client |
Hämta en ContainerProxy för en container med angivet ID (namn). |
| get_throughput |
Hämta objektet ThroughputProperties för den här databasen. Om det inte redan finns några dataflödesegenskaper för databasen utlöses ett undantag. :keyword Callable response_hook: En anropbar som anropas med svarsmetadata. :returns: DataflödeEgenskaper för databasen. :genererar ~azure.cosmos.exceptions.CosmosHttpResponseError: Det finns inga dataflödesegenskaper för containern eller Det gick inte att hämta dataflödesegenskaperna. |
| get_user_client |
Hämta en UserProxy för en användare med angivet ID. |
| list_containers |
Visa en lista över containrarna i databasen. |
| list_users |
Visa en lista över alla användare i containern. |
| query_containers |
Visa en lista över egenskaperna för containrar i den aktuella databasen. |
| query_users |
Returnera alla användare som matchar den angivna frågan. |
| read |
Läs databasegenskaperna. |
| read_offer |
Hämta objektet ThroughputProperties för den här databasen. Om det inte redan finns några dataflödesegenskaper för databasen utlöses ett undantag. :keyword Callable response_hook: En anropbar som anropas med svarsmetadata. :returns: DataflödeEgenskaper för databasen. :genererar ~azure.cosmos.exceptions.CosmosHttpResponseError: Det finns inga dataflödesegenskaper för containern eller Det gick inte att hämta dataflödesegenskaperna. |
| replace_container |
Återställ egenskaperna för containern. Egenskapsändringar sparas omedelbart. Alla egenskaper som inte anges återställs till standardvärdena. |
| replace_throughput |
Ersätt dataflödet på databasnivå. |
| replace_user |
Ersätter den angivna användaren om den finns i containern. |
| upsert_user |
Infoga eller uppdatera den angivna användaren. Om användaren redan finns i containern ersätts den. Om användaren inte redan finns infogas den. |
create_container
Skapa en ny container med det angivna ID:t (namn).
Om det redan finns en container med det angivna ID:t utlöses en CosmosResourceExistsError.
create_container(id: str, partition_key: Any, indexing_policy: Dict[str, Any] | None = None, default_ttl: int | None = None, populate_query_metrics: bool | None = None, offer_throughput: int | ThroughputProperties | None = None, unique_key_policy: Dict[str, Any] | None = None, conflict_resolution_policy: Dict[str, Any] | None = None, **kwargs: Any) -> ContainerProxyParametrar
- id
ID (namn) för container som ska skapas.
- partition_key
Partitionsnyckeln som ska användas för containern.
- indexing_policy
Indexeringsprincipen som ska tillämpas på containern.
- default_ttl
Standardtid att leva (TTL) för objekt i containern. Om objekten är ospecificerade upphör de inte att gälla.
- offer_throughput
- int eller <xref:azure.cosmos.ThroughputProperties.>
Det etablerade dataflödet för det här erbjudandet.
- unique_key_policy
Den unika nyckelprincip som ska tillämpas på containern.
- conflict_resolution_policy
Konfliktlösningsprincipen som ska tillämpas på containern.
- session_token
- str
Token för användning med sessionskonsekvens.
- etag
- str
Ett ETag-värde eller jokertecknet (*). Används för att kontrollera om resursen har ändrats och agera enligt villkoret som anges av parametern match_condition .
- match_condition
- MatchConditions
Matchningsvillkoret som ska användas på etag.
- response_hook
- Callable
En anropsbar anropad med svarsmetadata.
- analytical_storage_ttl
- int
TTL (Analytical Store Time to Live) för objekt i containern. Värdet None lämnar analyslagringen inaktiverad och värdet -1 aktiverar analyslagring utan TTL. Observera att analyslagring endast kan aktiveras på Synapse Link aktiverade konton.
Returer
En ContainerProxy-instans som representerar den nya containern.
Returtyp
Undantag
Det gick inte att skapa containern.
Exempel
Skapa en container med standardinställningar:
container_name = "products"
try:
container = database.create_container(
id=container_name, partition_key=PartitionKey(path="/productName")
)
except exceptions.CosmosResourceExistsError:
container = database.get_container_client(container_name)
Skapa en container med specifika inställningar. i det här fallet en anpassad partitionsnyckel:
customer_container_name = "customers"
try:
customer_container = database.create_container(
id=customer_container_name,
partition_key=PartitionKey(path="/city"),
default_ttl=200,
)
except exceptions.CosmosResourceExistsError:
customer_container = database.get_container_client(customer_container_name)
create_container_if_not_exists
Skapa en container om den inte redan finns.
Om containern redan finns returneras de befintliga inställningarna. Obs! Den kontrollerar eller uppdaterar inte befintliga containerinställningar eller erbjuder dataflöde om de skiljer sig från vad som skickades till metoden.
create_container_if_not_exists(id: str, partition_key: Any, indexing_policy: Dict[str, Any] | None = None, default_ttl: int | None = None, populate_query_metrics: bool | None = None, offer_throughput: int | ThroughputProperties | None = None, unique_key_policy: Dict[str, Any] | None = None, conflict_resolution_policy: Dict[str, Any] | None = None, **kwargs: Any) -> ContainerProxyParametrar
- id
ID (namn) för container som ska läsas eller skapas.
- partition_key
Partitionsnyckeln som ska användas för containern.
- indexing_policy
Indexeringsprincipen som ska tillämpas på containern.
- default_ttl
Standardtid att leva (TTL) för objekt i containern. Om objekten är ospecificerade upphör de inte att gälla.
- populate_query_metrics
Aktivera returnerade frågemått i svarshuvuden.
- offer_throughput
Det etablerade dataflödet för det här erbjudandet.
- unique_key_policy
Den unika nyckelprincip som ska tillämpas på containern.
- conflict_resolution_policy
Konfliktlösningsprincipen som ska tillämpas på containern.
- session_token
- str
Token för användning med sessionskonsekvens.
- etag
- str
Ett ETag-värde eller jokertecknet (*). Används för att kontrollera om resursen har ändrats och agera enligt villkoret som anges av parametern match_condition .
- match_condition
- MatchConditions
Matchningsvillkoret som ska användas på etag.
- response_hook
- Callable
En anropsbar anropad med svarsmetadata.
- analytical_storage_ttl
- int
TTL (Analytical Store Time to Live) för objekt i containern. Värdet None lämnar analyslagringen inaktiverad och värdet -1 aktiverar analyslagring utan TTL. Observera att analyslagring endast kan aktiveras på Synapse Link aktiverade konton.
Returer
En ContainerProxy-instans som representerar containern.
Returtyp
Undantag
Det gick inte att läsa eller skapa containern.
create_user
Skapa en ny användare i containern.
Om du vill uppdatera eller ersätta en befintlig användare använder du <xref:ContainerProxy.upsert_user> metoden .
create_user(body: Dict[str, Any], **kwargs: Any) -> UserProxyParametrar
- body
Ett diktaliknande objekt med en ID-nyckel och ett värde som representerar användaren som ska skapas. Användar-ID:t måste vara unikt i databasen och bestå av högst 255 tecken.
- response_hook
- Callable
En anropsbar anropad med svarsmetadata.
Returer
En UserProxy-instans som representerar den nya användaren.
Returtyp
Undantag
Om det inte gick att skapa den angivna användaren.
Exempel
Skapa en databasanvändare:
try:
database.create_user(dict(id="Walter Harp"))
except exceptions.CosmosResourceExistsError:
print("A user with that ID already exists.")
except exceptions.CosmosHttpResponseError as failure:
print("Failed to create user. Status code:{}".format(failure.status_code))
delete_container
Ta bort en container.
delete_container(container: str | ContainerProxy | Dict[str, Any], populate_query_metrics: bool | None = None, **kwargs: Any) -> NoneParametrar
- container
ID:t (namn) för containern som ska tas bort. Du kan antingen skicka ID:t för containern för att ta bort, en ContainerProxy instans eller en diktamen som representerar containerns egenskaper.
- session_token
- str
Token för användning med sessionskonsekvens.
- etag
- str
Ett ETag-värde eller jokertecknet (*). Används för att kontrollera om resursen har ändrats och agera enligt villkoret som anges av parametern match_condition .
- match_condition
- MatchConditions
Matchningsvillkoret som ska användas på etag.
- response_hook
- Callable
En anropsbar anropad med svarsmetadata.
Returtyp
Undantag
Om containern inte kunde tas bort.
delete_user
Ta bort den angivna användaren från containern.
delete_user(user: str | UserProxy | Dict[str, Any], **kwargs: Any) -> NoneParametrar
- user
ID:t (namn), diktat som representerar egenskaperna eller UserProxy instansen för den användare som ska tas bort.
- response_hook
- Callable
En anropsbar anropad med svarsmetadata.
Returtyp
Undantag
Användaren har inte tagits bort.
Användaren finns inte i containern.
get_container_client
Hämta en ContainerProxy för en container med angivet ID (namn).
get_container_client(container: str | ContainerProxy | Dict[str, Any]) -> ContainerProxyParametrar
- container
ID:t (namn) för containern, en ContainerProxy instans eller en diktamen som representerar egenskaperna för containern som ska hämtas.
Returer
En ContainerProxy-instans som representerar den hämtade databasen.
Returtyp
Undantag
Det gick inte att skapa containern.
Exempel
Hämta en befintlig container, hantera ett fel om det påträffas:
database = client.get_database_client(database_name)
container = database.get_container_client(container_name)
get_throughput
Hämta objektet ThroughputProperties för den här databasen. Om det inte redan finns några dataflödesegenskaper för databasen utlöses ett undantag. :keyword Callable response_hook: En anropbar som anropas med svarsmetadata. :returns: DataflödeEgenskaper för databasen. :genererar ~azure.cosmos.exceptions.CosmosHttpResponseError: Det finns inga dataflödesegenskaper för containern eller
Det gick inte att hämta dataflödesegenskaperna.
get_throughput(**kwargs: Any) -> ThroughputPropertiesReturtyp
Undantag
Det gick inte att skapa containern.
get_user_client
Hämta en UserProxy för en användare med angivet ID.
get_user_client(user: str | UserProxy | Dict[str, Any]) -> UserProxyParametrar
- user
ID :t (namn), diktat som representerar egenskaperna eller UserProxy instansen för den användare som ska hämtas.
Returer
En UserProxy-instans som representerar den hämtade användaren.
Returtyp
Undantag
Det gick inte att skapa containern.
list_containers
Visa en lista över containrarna i databasen.
list_containers(max_item_count: int | None = None, populate_query_metrics: bool | None = None, **kwargs: Any) -> Iterable[Dict[str, Any]]Parametrar
- max_item_count
Maximalt antal objekt som ska returneras i uppräkningsåtgärden.
- session_token
- str
Token för användning med sessionskonsekvens.
- response_hook
- Callable
En anropsbar anropad med svarsmetadata.
Returer
En iterabel av containeregenskaper (dikteringar).
Returtyp
Undantag
Det gick inte att skapa containern.
Exempel
Visa en lista över alla containrar i databasen:
database = client.get_database_client(database_name)
for container in database.list_containers():
print("Container ID: {}".format(container['id']))
list_users
Visa en lista över alla användare i containern.
list_users(max_item_count: int | None = None, **kwargs: Any) -> Iterable[Dict[str, Any]]Parametrar
- max_item_count
Maximalt antal användare som ska returneras i uppräkningsåtgärden.
- response_hook
- Callable
En anropsbar anropad med svarsmetadata.
Returer
En iterabel av användaregenskaper (dikteringar).
Returtyp
Undantag
Det gick inte att skapa containern.
query_containers
Visa en lista över egenskaperna för containrar i den aktuella databasen.
query_containers(query: str | None = None, parameters: List[str] | None = None, max_item_count: int | None = None, populate_query_metrics: bool | None = None, **kwargs: Any) -> Iterable[Dict[str, Any]]Parametrar
- query
Azure Cosmos DB SQL-frågan som ska köras.
- parameters
Valfri matris med parametrar i frågan. Ignoreras om ingen fråga har angetts.
- max_item_count
Maximalt antal objekt som ska returneras i uppräkningsåtgärden.
- session_token
- str
Token för användning med sessionskonsekvens.
- response_hook
- Callable
En anropsbar anropad med svarsmetadata.
Returer
En iterabel av containeregenskaper (dikteringar).
Returtyp
Undantag
Det gick inte att skapa containern.
query_users
Returnera alla användare som matchar den angivna frågan.
query_users(query: str, parameters: List[str] | None = None, max_item_count: int | None = None, **kwargs: Any) -> Iterable[Dict[str, Any]]Parametrar
- query
Azure Cosmos DB SQL-frågan som ska köras.
- parameters
Valfri matris med parametrar i frågan. Ignoreras om ingen fråga har angetts.
- max_item_count
Maximalt antal användare som ska returneras i uppräkningsåtgärden.
- response_hook
- Callable
En anropsbar anropad med svarsmetadata.
Returer
En iterabel av användaregenskaper (dikteringar).
Returtyp
Undantag
Det gick inte att skapa containern.
read
Läs databasegenskaperna.
read(populate_query_metrics: bool | None = None, **kwargs: Any) -> Dict[str, Any]Parametrar
- session_token
- str
Token för användning med sessionskonsekvens.
- response_hook
- Callable
En anropsbar anropad med svarsmetadata.
Returtyp
Undantag
Om den angivna databasen inte kunde hämtas.
read_offer
Hämta objektet ThroughputProperties för den här databasen. Om det inte redan finns några dataflödesegenskaper för databasen utlöses ett undantag. :keyword Callable response_hook: En anropbar som anropas med svarsmetadata. :returns: DataflödeEgenskaper för databasen. :genererar ~azure.cosmos.exceptions.CosmosHttpResponseError: Det finns inga dataflödesegenskaper för containern eller
Det gick inte att hämta dataflödesegenskaperna.
read_offer(**kwargs: Any) -> ThroughputPropertiesReturtyp
Undantag
Det gick inte att skapa containern.
replace_container
Återställ egenskaperna för containern.
Egenskapsändringar sparas omedelbart. Alla egenskaper som inte anges återställs till standardvärdena.
replace_container(container: str | ContainerProxy | Dict[str, Any], partition_key: Any, indexing_policy: Dict[str, Any] | None = None, default_ttl: int | None = None, conflict_resolution_policy: Dict[str, Any] | None = None, populate_query_metrics: bool | None = None, **kwargs: Any) -> ContainerProxyParametrar
- container
ID:t (namn), diktamen som representerar egenskaperna eller ContainerProxy instansen av containern som ska ersättas.
- partition_key
Partitionsnyckeln som ska användas för containern.
- indexing_policy
Indexeringsprincipen som ska tillämpas på containern.
- default_ttl
Standardtid att leva (TTL) för objekt i containern. Om objekten är ospecificerade upphör de inte att gälla.
- conflict_resolution_policy
Konfliktlösningsprincipen som ska tillämpas på containern.
- populate_query_metrics
Aktivera returnerade frågemått i svarshuvuden.
- session_token
- str
Token för användning med sessionskonsekvens.
- etag
- str
Ett ETag-värde eller jokertecknet (*). Används för att kontrollera om resursen har ändrats och agera enligt villkoret som anges av parametern match_condition .
- match_condition
- MatchConditions
Matchningsvillkoret som ska användas på etag.
- response_hook
- Callable
En anropsbar anropad med svarsmetadata.
- analytical_storage_ttl
- int
TTL (Analytical Store Time to Live) för objekt i containern. Värdet None lämnar analyslagringen inaktiverad och värdet -1 aktiverar analyslagring utan TTL. Observera att analyslagring endast kan aktiveras på Synapse Link aktiverade konton.
Returer
En ContainerProxy-instans som representerar containern efter att ersättningen har slutförts.
Returtyp
Undantag
Upphöjt om containern inte kunde ersättas. Detta inkluderar om containern med angivet ID inte finns.
Exempel
Återställ TTL-egenskapen i en container och visa de uppdaterade egenskaperna:
# Set the TTL on the container to 3600 seconds (one hour)
database.replace_container(container, partition_key=PartitionKey(path='/productName'), default_ttl=3600)
# Display the new TTL setting for the container
container_props = database.get_container_client(container_name).read()
print("New container TTL: {}".format(json.dumps(container_props['defaultTtl'])))
replace_throughput
Ersätt dataflödet på databasnivå.
replace_throughput(throughput: int | ThroughputProperties | None, **kwargs: Any) -> ThroughputPropertiesParametrar
- throughput
Det dataflöde som ska anges (ett heltal).
- response_hook
- Callable
En anropsbar anropad med svarsmetadata.
Returer
DataflödeEgenskaper för databasen, uppdaterade med nytt dataflöde.
Returtyp
Undantag
Om det inte finns några dataflödesegenskaper för databasen eller om dataflödesegenskaperna inte kunde uppdateras.
replace_user
Ersätter den angivna användaren om den finns i containern.
replace_user(user: str | UserProxy | Dict[str, Any], body: Dict[str, Any], **kwargs: Any) -> UserProxyParametrar
- user
ID:t (namn), diktat som representerar egenskaperna eller UserProxy instansen för den användare som ska ersättas.
- body
Ett diktaliknande objekt som representerar användaren som ska ersättas.
- response_hook
- Callable
En anropsbar anropad med svarsmetadata.
Returer
En UserProxy-instans som representerar användaren efter ersättningen gick igenom.
Returtyp
Undantag
Om ersättningen misslyckades eller om användaren med angivet ID inte finns.
upsert_user
Infoga eller uppdatera den angivna användaren.
Om användaren redan finns i containern ersätts den. Om användaren inte redan finns infogas den.
upsert_user(body: Dict[str, Any], **kwargs: Any) -> UserProxyParametrar
- body
Ett diktaliknande objekt som representerar användaren att uppdatera eller infoga.
- response_hook
- Callable
En anropsbar anropad med svarsmetadata.
Returer
En UserProxy-instans som representerar den upserted användaren.
Returtyp
Undantag
Om den angivna användaren inte kunde upserted.
Azure SDK for Python