ContainerProxy Klas

Een interface voor interactie met een specifieke DB-container.

Deze klasse mag niet rechtstreeks worden geïnstantieerd. Gebruik in plaats daarvan de get_container_client methode om een bestaande container op te halen of de create_container methode om een nieuwe container te maken.

Een container in een Azure Cosmos DB SQL API-database is een verzameling documenten, die elk worden weergegeven als een item.

Overname

builtins.object

ContainerProxy

Constructor

ContainerProxy(client_connection: CosmosClientConnection, database_link: str, id: str, properties: Dict[str, Any] = None)

Parameters

client_connection

database_link

id

properties

standaardwaarde: None

Variabelen

id

str

Id (naam) van de container

session_token

str

Het sessietoken voor de container.

Methoden

create_item	Maak een item in de container. Gebruik de upsert_item methode om een bestaand item bij te werken of te vervangen.
delete_all_items_by_partition_key	De functie verwijderen op partitiesleutel is een asynchrone bewerking op de achtergrond waarmee u alle documenten met dezelfde logische partitiesleutelwaarde kunt verwijderen met behulp van de Cosmos SDK. De bewerking verwijderen via partitiesleutel is beperkt tot het verbruik van maximaal 10% van de totale beschikbare RU/s op de container elke seconde. Dit helpt bij het beperken van de resources die door deze achtergrondtaak worden gebruikt.
delete_conflict	Verwijder een opgegeven conflict uit de container. Als het conflict nog niet in de container bestaat, wordt er een uitzondering gegenereerd.
delete_item	Verwijder het opgegeven item uit de container. Als het item nog niet in de container bestaat, wordt er een uitzondering gegenereerd.
get_conflict	Haal het conflict op dat is geïdentificeerd door conflict.
get_throughput	Haal het object ThroughputProperties voor deze container op. Als er al geen ThroughputProperties voor de container bestaan, wordt er een uitzondering gegenereerd. :keyword Callable response_hook: een aanroepbare die wordt aangeroepen met de antwoordmetagegevens. :retourneert: Doorvoer voor de container. :genereert ~azure.cosmos.exceptions.CosmosHttpResponseError: er bestaan geen doorvoereigenschappen voor de container of de doorvoereigenschappen kunnen niet worden opgehaald.
list_conflicts	Alle conflicten in de container weergeven.
patch_item	Voorlopige methode Hiermee wordt het opgegeven item bijgewerkt met de opgegeven bewerkingen als dit in de container bestaat. Als het item nog niet in de container bestaat, wordt er een uitzondering gegenereerd.
query_conflicts	Alle conflicten retourneren die overeenkomen met een bepaalde query.
query_items	Retourneer alle resultaten die overeenkomen met de opgegeven query. U kunt elke waarde gebruiken voor de containernaam in de FROM-component, maar vaak wordt de containernaam gebruikt. In de onderstaande voorbeelden is de containernaam 'products' en is de alias 'p' voor eenvoudiger verwijzen in de WHERE-component. antwoord vervolgtoken in het queryantwoord. Geldige waarden zijn positieve gehele getallen. Een waarde van 0 is hetzelfde als het niet doorgeven van een waarde (standaard geen limiet). :keyword int max_integrated_cache_staleness_in_ms: De maximale cache veroudering voor de geïntegreerde cache in Milliseconden. Voor accounts die zijn geconfigureerd voor het gebruik van de geïntegreerde cache, met behulp van sessie- of uiteindelijkconsistentie, zijn antwoorden gegarandeerd niet verlopen dan deze waarde.
query_items_change_feed	Een gesorteerde lijst met items ophalen die zijn gewijzigd, in de volgorde waarin ze zijn gewijzigd.
read	Lees de containereigenschappen.
read_all_items	Alle items in de container weergeven.
read_item	Haal het item op dat is geïdentificeerd door item.
read_offer	Haal het object ThroughputProperties voor deze container op. Als er al geen ThroughputProperties voor de container bestaan, wordt er een uitzondering gegenereerd. :keyword Callable response_hook: een aanroepbare die wordt aangeroepen met de antwoordmetagegevens. :retourneert: Doorvoer voor de container. :genereert ~azure.cosmos.exceptions.CosmosHttpResponseError: er bestaan geen doorvoereigenschappen voor de container of de doorvoereigenschappen kunnen niet worden opgehaald.
replace_item	Vervangt het opgegeven item als dit in de container bestaat. Als het item nog niet in de container bestaat, wordt er een uitzondering gegenereerd.
replace_throughput	Vervang de doorvoer van de container. Als er al geen ThroughputProperties voor de container bestaan, wordt er een uitzondering gegenereerd.
upsert_item	Het opgegeven item invoegen of bijwerken. Als het item al in de container bestaat, wordt het vervangen. Als het item nog niet bestaat, wordt het ingevoegd.

create_item

Maak een item in de container.

Gebruik de upsert_item methode om een bestaand item bij te werken of te vervangen.

create_item(body: Dict[str, Any], populate_query_metrics: bool | None = None, pre_trigger_include: str | None = None, post_trigger_include: str | None = None, indexing_directive: Any | None = None, **kwargs: Any) -> Dict[str, Any]

Parameters

body

Vereist

Een dict-achtig object dat het item vertegenwoordigt dat moet worden gemaakt.

pre_trigger_include

Vereist

trigger-id die moet worden gebruikt als prebewerkingtrigger.

post_trigger_include

Vereist

trigger-id die moet worden gebruikt als trigger na de bewerking.

indexing_directive

Vereist

Geef aan of het document moet worden weggelaten voor indexering.

enable_automatic_id_generation

bool

Schakel het automatisch genereren van id's in als er geen id aanwezig is.

session_token

str

Token voor gebruik met sessieconsistentie.

initial_headers

dict[str,str]

Eerste headers die moeten worden verzonden als onderdeel van de aanvraag.

etag

str

Een ETag-waarde of het jokerteken (*). Wordt gebruikt om te controleren of de resource is gewijzigd en om te handelen volgens de voorwaarde die is opgegeven door de parameter match_condition .

match_condition

MatchConditions

De overeenkomstvoorwaarde die moet worden gebruikt voor de etag.

response_hook

Callable

Een aanroepbare aangeroepen met de antwoordmetagegevens.

Retouren

Een dict die het nieuwe item vertegenwoordigt.

Retourtype

dict[str, Any]

Uitzonderingen

CosmosHttpResponseError

Het item met de opgegeven id bestaat al.

delete_all_items_by_partition_key

De functie verwijderen op partitiesleutel is een asynchrone bewerking op de achtergrond waarmee u alle documenten met dezelfde logische partitiesleutelwaarde kunt verwijderen met behulp van de Cosmos SDK. De bewerking verwijderen via partitiesleutel is beperkt tot het verbruik van maximaal 10% van de totale beschikbare RU/s op de container elke seconde. Dit helpt bij het beperken van de resources die door deze achtergrondtaak worden gebruikt.

delete_all_items_by_partition_key(partition_key: str | int | float | bool, **kwargs: Any) -> None

Parameters

partition_key

Any

Vereist

Partitiesleutel voor de items die moeten worden verwijderd.

pre_trigger_include

str

trigger-id die moet worden gebruikt als prebewerkingtrigger.

post_trigger_include

str

trigger-id die moet worden gebruikt als trigger na de bewerking.

session_token

str

Token voor gebruik met sessieconsistentie.

etag

str

Een ETag-waarde of het jokerteken (*). Wordt gebruikt om te controleren of de resource is gewijzigd en om te handelen volgens de voorwaarde die is opgegeven door de parameter match_condition .

match_condition

MatchConditions

De overeenkomstvoorwaarde die moet worden gebruikt voor de etag.

response_hook

Callable

Een aanroepbare aangeroepen met de antwoordmetagegevens.

Retourtype

None

Uitzonderingen

CosmosHttpResponseError

Het item met de opgegeven id bestaat al.

delete_conflict

Verwijder een opgegeven conflict uit de container.

Als het conflict nog niet in de container bestaat, wordt er een uitzondering gegenereerd.

delete_conflict(conflict: str | Dict[str, Any], partition_key: Any, **kwargs: Any) -> None

Parameters

conflict

Vereist

De id (naam) of het dict die het conflict vertegenwoordigt dat moet worden verwijderd.

partition_key

Vereist

Partitiesleutel voor het conflict dat moet worden verwijderd.

response_hook

Callable

Een aanroepbare aangeroepen met de antwoordmetagegevens.

Retourtype

None

Uitzonderingen

CosmosHttpResponseError

Het conflict is niet verwijderd.

CosmosResourceNotFoundError

Het conflict bestaat niet in de container.

delete_item

Verwijder het opgegeven item uit de container.

Als het item nog niet in de container bestaat, wordt er een uitzondering gegenereerd.

delete_item(item: Dict[str, Any] | str, partition_key: Any, populate_query_metrics: bool | None = None, pre_trigger_include: str | None = None, post_trigger_include: str | None = None, **kwargs: Any) -> None

Parameters

item

Vereist

De id (naam) of het dict die het item vertegenwoordigt dat moet worden verwijderd.

partition_key

Vereist

Hiermee geeft u de partitiesleutelwaarde voor het item op.

pre_trigger_include

Vereist

trigger-id die moet worden gebruikt als prebewerkingtrigger.

post_trigger_include

Vereist

trigger-id die moet worden gebruikt als trigger na de bewerking.

session_token

str

Token voor gebruik met sessieconsistentie.

initial_headers

dict[str,str]

Eerste headers die moeten worden verzonden als onderdeel van de aanvraag.

etag

str

Een ETag-waarde of het jokerteken (*). Wordt gebruikt om te controleren of de resource is gewijzigd en om te handelen volgens de voorwaarde die is opgegeven door de parameter match_condition .

match_condition

MatchConditions

De overeenkomstvoorwaarde die moet worden gebruikt voor de etag.

response_hook

Callable

Een aanroepbare aangeroepen met de antwoordmetagegevens.

Retourtype

None

Uitzonderingen

CosmosHttpResponseError

Het item is niet verwijderd.

CosmosResourceNotFoundError

Het item bestaat niet in de container.

get_conflict

Haal het conflict op dat is geïdentificeerd door conflict.

get_conflict(conflict: str | Dict[str, Any], partition_key: Any, **kwargs: Any) -> Dict[str, Any]

Parameters

conflict

Vereist

De id (naam) of het dict die het conflict vertegenwoordigt dat moet worden opgehaald.

partition_key

Vereist

Partitiesleutel om het conflict op te halen.

response_hook

Callable

Een aanroepbare aangeroepen met de antwoordmetagegevens.

Retouren

Een dict die het opgehaalde conflict vertegenwoordigt.

Retourtype

dict[str, Any]

Uitzonderingen

CosmosHttpResponseError

Het opgegeven conflict kan niet worden opgehaald.

get_throughput

Haal het object ThroughputProperties voor deze container op.

Als er al geen ThroughputProperties voor de container bestaan, wordt er een uitzondering gegenereerd. :keyword Callable response_hook: een aanroepbare die wordt aangeroepen met de antwoordmetagegevens. :retourneert: Doorvoer voor de container. :genereert ~azure.cosmos.exceptions.CosmosHttpResponseError: er bestaan geen doorvoereigenschappen voor de container of

de doorvoereigenschappen kunnen niet worden opgehaald.

get_throughput(**kwargs: Any) -> ThroughputProperties

Retourtype

ThroughputProperties

Uitzonderingen

CosmosHttpResponseError

Het item met de opgegeven id bestaat al.

list_conflicts

Alle conflicten in de container weergeven.

list_conflicts(max_item_count: int | None = None, **kwargs: Any) -> Iterable[Dict[str, Any]]

Parameters

max_item_count

Vereist

Maximum aantal items dat moet worden geretourneerd in de opsommingsbewerking.

response_hook

Callable

Een aanroepbare aangeroepen met de antwoordmetagegevens.

Retouren

Een iterable van conflicten (dicteren).

Retourtype

Iterable[dict[str, Any]]

Uitzonderingen

CosmosHttpResponseError

Het item met de opgegeven id bestaat al.

patch_item

Voorlopige methode Hiermee wordt het opgegeven item bijgewerkt met de opgegeven bewerkingen als dit in de container bestaat.

Als het item nog niet in de container bestaat, wordt er een uitzondering gegenereerd.

patch_item(item: str | Dict[str, Any], partition_key: str | int | float | bool, patch_operations: List[Dict[str, Any]], **kwargs: Any) -> Dict[str, Any]

Parameters

item

Union[str, Dict[str, Any]]

Vereist

De id (naam) of het dict die het item vertegenwoordigt dat moet worden gepatcht.

partition_key

Union[str, int, float, bool]

Vereist

De partitiesleutel van het object dat moet worden gepatcht.

patch_operations

List[Dict[str, Any]]

Vereist

De lijst met patchbewerkingen die moeten worden toegepast op het item.

filter_predicate

str

voorwaardelijk filter om toe te passen op patchbewerkingen.

pre_trigger_include

str

trigger-id die moet worden gebruikt als prebewerkingtrigger.

post_trigger_include

str

trigger-id die moet worden gebruikt als trigger na de bewerking.

session_token

str

Token voor gebruik met sessieconsistentie.

etag

str

Een ETag-waarde of het jokerteken (*). Wordt gebruikt om te controleren of de resource is gewijzigd en om te handelen volgens de voorwaarde die is opgegeven door de parameter match_condition .

match_condition

MatchConditions

De overeenkomstvoorwaarde die moet worden gebruikt voor de etag.

response_hook

Callable

Een aanroepbare aangeroepen met de antwoordmetagegevens.

Retouren

Een dict die het item vertegenwoordigt nadat de patchbewerkingen zijn uitgevoerd.

Retourtype

dict[str, Any]

Uitzonderingen

CosmosHttpResponseError

De patchbewerkingen zijn mislukt of het item met de opgegeven id bestaat niet.

query_conflicts

Alle conflicten retourneren die overeenkomen met een bepaalde query.

query_conflicts(query: str, parameters: List[str] | None = None, enable_cross_partition_query: bool | None = None, partition_key: Any | None = None, max_item_count: int | None = None, **kwargs: Any) -> Iterable[Dict[str, Any]]

Parameters

query

Vereist

De Azure Cosmos DB SQL-query die moet worden uitgevoerd.

parameters

Vereist

Optionele matrix met parameters voor de query. Genegeerd als er geen query wordt opgegeven.

enable_cross_partition_query

Vereist

Hiermee kunt u meer dan één aanvraag verzenden om de query uit te voeren in de Azure Cosmos DB-service. Er is meer dan één aanvraag nodig als de query niet is gericht op één partitiesleutelwaarde.

partition_key

Vereist

Hiermee geeft u de partitiesleutelwaarde voor het item op.

max_item_count

Vereist

Maximum aantal items dat moet worden geretourneerd in de opsommingsbewerking.

response_hook

Callable

Een aanroepbare aangeroepen met de antwoordmetagegevens.

Retouren

Een iterable van conflicten (dicteren).

Retourtype

Iterable[dict[str, Any]]

Uitzonderingen

CosmosHttpResponseError

Het item met de opgegeven id bestaat al.

query_items

Retourneer alle resultaten die overeenkomen met de opgegeven query.

U kunt elke waarde gebruiken voor de containernaam in de FROM-component, maar vaak wordt de containernaam gebruikt. In de onderstaande voorbeelden is de containernaam 'products' en is de alias 'p' voor eenvoudiger verwijzen in de WHERE-component.

antwoord vervolgtoken in het queryantwoord. Geldige waarden zijn positieve gehele getallen. Een waarde van 0 is hetzelfde als het niet doorgeven van een waarde (standaard geen limiet). :keyword int max_integrated_cache_staleness_in_ms: De maximale cache veroudering voor de geïntegreerde cache in

Milliseconden. Voor accounts die zijn geconfigureerd voor het gebruik van de geïntegreerde cache, met behulp van sessie- of uiteindelijkconsistentie, zijn antwoorden gegarandeerd niet verlopen dan deze waarde.

query_items(query: str, parameters: List[Dict[str, object]] | None = None, partition_key: Any | None = None, enable_cross_partition_query: bool | None = None, max_item_count: int | None = None, enable_scan_in_query: bool | None = None, populate_query_metrics: bool | None = None, **kwargs: Any) -> Iterable[Dict[str, Any]]

Retouren

Een iterable van items (dicteren).

Retourtype

<xref:ItemPaged>[Dict[str, Any]]

Uitzonderingen

CosmosHttpResponseError

Het item met de opgegeven id bestaat al.

Voorbeelden

Download alle producten die niet zijn stopgezet:

   import json

   for item in container.query_items(
       query='SELECT * FROM products p WHERE p.productModel <> "DISCONTINUED"',
       enable_cross_partition_query=True,
   ):
       print(json.dumps(item, indent=True))

Query met parameters om alle producten op te halen die zijn stopgezet:

   discontinued_items = container.query_items(
       query='SELECT * FROM products p WHERE p.productModel = @model AND p.productName="Widget"',
       parameters=[dict(name="@model", value="DISCONTINUED")],
   )
   for item in discontinued_items:
       print(json.dumps(item, indent=True))

query_items_change_feed

Een gesorteerde lijst met items ophalen die zijn gewijzigd, in de volgorde waarin ze zijn gewijzigd.

query_items_change_feed(partition_key_range_id: str | None = None, is_start_from_beginning: bool = False, continuation: str | None = None, max_item_count: int | None = None, **kwargs: Any) -> Iterable[Dict[str, Any]]

Parameters

partition_key_range_id

Vereist

ChangeFeed-aanvragen kunnen worden uitgevoerd voor specifieke partitiesleutelbereiken. Dit wordt gebruikt om de wijzigingenfeed parallel te verwerken voor meerdere gebruikers.

partition_key

Vereist

partitiesleutel waarop ChangeFeed-aanvragen zijn gericht.

is_start_from_beginning

Vereist

Bekijk of de wijzigingenfeed moet beginnen vanaf het begin (waar) of vanaf het huidige (onwaar). Standaard wordt gestart vanaf de huidige waarde (onwaar).

continuation

Vereist

e_tag waarde die moet worden gebruikt als vervolg voor het lezen van de wijzigingenfeed.

max_item_count

Vereist

Maximum aantal items dat moet worden geretourneerd in de opsommingsbewerking.

response_hook

Callable

Een aanroepbare aangeroepen met de antwoordmetagegevens.

Retouren

Een iterable van items (dicteren).

Retourtype

Iterable[dict[str, Any]]

Uitzonderingen

CosmosHttpResponseError

Het item met de opgegeven id bestaat al.

read

Lees de containereigenschappen.

read(*, populate_partition_key_range_statistics: bool | None = None, populate_quota_info: bool | None = None, **kwargs)

Parameters

populate_partition_key_range_statistics

bool

Schakel geretourneerde statistieken over partitiesleutelbereiken in antwoordheaders in.

populate_quota_info

bool

Schakel het retourneren van opslagquotumgegevens voor verzamelingen in antwoordheaders in.

session_token

str

Token voor gebruik met sessieconsistentie.

initial_headers

dict[str,str]

Eerste headers die moeten worden verzonden als onderdeel van de aanvraag.

response_hook

Callable

Een aanroepbare aangeroepen met de antwoordmetagegevens.

Retouren

Dict die de opgehaalde container vertegenwoordigt.

Retourtype

dict[str, Any]

Uitzonderingen

CosmosHttpResponseError

Gegenereerd als de container niet kan worden opgehaald. Dit geldt ook als de container niet bestaat.

read_all_items

Alle items in de container weergeven.

read_all_items(max_item_count: int | None = None, populate_query_metrics: bool | None = None, **kwargs: Any) -> Iterable[Dict[str, Any]]

Parameters

max_item_count

Vereist

Maximum aantal items dat moet worden geretourneerd in de opsommingsbewerking.

session_token

str

Token voor gebruik met sessieconsistentie.

initial_headers

dict[str,str]

Eerste headers die moeten worden verzonden als onderdeel van de aanvraag.

response_hook

Callable

Een aanroepbare aangeroepen met de antwoordmetagegevens.

max_integrated_cache_staleness_in_ms

int

Het maximum aantal caches voor de geïntegreerde cache in milliseconden. Voor accounts die zijn geconfigureerd voor het gebruik van de geïntegreerde cache, met behulp van sessie- of uiteindelijkconsistentie, zijn antwoorden gegarandeerd niet verlopen dan deze waarde.

Retouren

Een iterable van items (dicteren).

Retourtype

Iterable[dict[str, Any]]

Uitzonderingen

CosmosHttpResponseError

Het item met de opgegeven id bestaat al.

read_item

Haal het item op dat is geïdentificeerd door item.

read_item(item: str | Dict[str, Any], partition_key: Any, populate_query_metrics: bool | None = None, post_trigger_include: str | None = None, **kwargs: Any) -> Dict[str, Any]

Parameters

item

Vereist

De id (naam) of dict die het item vertegenwoordigt dat moet worden opgehaald.

partition_key

Vereist

Partitiesleutel voor het item dat moet worden opgehaald.

post_trigger_include

Vereist

trigger-id die moet worden gebruikt als trigger na de bewerking.

session_token

str

Token voor gebruik met sessieconsistentie.

initial_headers

dict[str,str]

Eerste headers die moeten worden verzonden als onderdeel van de aanvraag.

response_hook

Callable

Een aanroepbare aangeroepen met de antwoordmetagegevens.

max_integrated_cache_staleness_in_ms

int

Het maximum aantal caches voor de geïntegreerde cache in milliseconden. Voor accounts die zijn geconfigureerd voor het gebruik van de geïntegreerde cache, met behulp van sessie- of uiteindelijkconsistentie, zijn antwoorden gegarandeerd niet verlopen dan deze waarde.

Retouren

Dict die het item vertegenwoordigt dat moet worden opgehaald.

Retourtype

dict[str, Any]

Uitzonderingen

CosmosHttpResponseError

Het opgegeven item kan niet worden opgehaald.

Voorbeelden

Haal een item op uit de database en werk een van de eigenschappen bij:

   item = container.read_item("item2", partition_key="Widget")
   item["productModel"] = "DISCONTINUED"
   updated_item = container.upsert_item(item)

read_offer

Haal het object ThroughputProperties voor deze container op. Als er al geen ThroughputProperties voor de container bestaan, wordt er een uitzondering gegenereerd. :keyword Callable response_hook: een aanroepbare die wordt aangeroepen met de antwoordmetagegevens. :retourneert: Doorvoer voor de container. :genereert ~azure.cosmos.exceptions.CosmosHttpResponseError: er bestaan geen doorvoereigenschappen voor de container of

de doorvoereigenschappen kunnen niet worden opgehaald.

read_offer(**kwargs: Any) -> Offer

Retourtype

ThroughputProperties

Uitzonderingen

CosmosHttpResponseError

Het item met de opgegeven id bestaat al.

replace_item

Vervangt het opgegeven item als dit in de container bestaat.

Als het item nog niet in de container bestaat, wordt er een uitzondering gegenereerd.

replace_item(item: str | Dict[str, Any], body: Dict[str, Any], populate_query_metrics: bool | None = None, pre_trigger_include: str | None = None, post_trigger_include: str | None = None, **kwargs: Any) -> Dict[str, Any]

Parameters

item

Vereist

De id (naam) of het dicteren die het te vervangen item vertegenwoordigt.

body

Vereist

Een dict-achtig object dat het te vervangen item vertegenwoordigt.

pre_trigger_include

Vereist

trigger-id die moet worden gebruikt als prebewerkingtrigger.

post_trigger_include

Vereist

trigger-id die moet worden gebruikt als trigger na de bewerking.

session_token

str

Token voor gebruik met sessieconsistentie.

initial_headers

dict[str,str]

Eerste headers die moeten worden verzonden als onderdeel van de aanvraag.

etag

str

Een ETag-waarde of het jokerteken (*). Wordt gebruikt om te controleren of de resource is gewijzigd en om te handelen volgens de voorwaarde die is opgegeven door de parameter match_condition .

match_condition

MatchConditions

De overeenkomstvoorwaarde die moet worden gebruikt voor de etag.

response_hook

Callable

Een aanroepbare aangeroepen met de antwoordmetagegevens.

Retouren

Een dict die het item aangeeft nadat de vervanging is uitgevoerd.

Retourtype

dict[str, Any]

Uitzonderingen

CosmosHttpResponseError

De vervanging is mislukt of het item met de opgegeven id bestaat niet.

replace_throughput

Vervang de doorvoer van de container.

Als er al geen ThroughputProperties voor de container bestaan, wordt er een uitzondering gegenereerd.

replace_throughput(throughput: int | ThroughputProperties | None, **kwargs: Any) -> ThroughputProperties

Parameters

throughput

Vereist

De in te stellen doorvoer (een geheel getal).

response_hook

Callable

Een aanroepbare aangeroepen met de antwoordmetagegevens.

Retouren

ThroughputProperties voor de container, bijgewerkt met nieuwe doorvoer.

Retourtype

ThroughputProperties

Uitzonderingen

CosmosHttpResponseError

Er zijn geen doorvoereigenschappen voor de container of de doorvoereigenschappen kunnen niet worden bijgewerkt.

upsert_item

Het opgegeven item invoegen of bijwerken.

Als het item al in de container bestaat, wordt het vervangen. Als het item nog niet bestaat, wordt het ingevoegd.

upsert_item(body: Dict[str, Any], populate_query_metrics: bool | None = None, pre_trigger_include: str | None = None, post_trigger_include: str | None = None, **kwargs: Any) -> Dict[str, Any]

Parameters

body

Vereist

Een dicterend object dat het item vertegenwoordigt dat moet worden bijgewerkt of ingevoegd.

pre_trigger_include

Vereist

trigger-id die moet worden gebruikt als prebewerkingtrigger.

post_trigger_include

Vereist

trigger-id die moet worden gebruikt als trigger na de bewerking.

session_token

str

Token voor gebruik met sessieconsistentie.

initial_headers

dict[str,str]

Eerste headers die moeten worden verzonden als onderdeel van de aanvraag.

etag

str

Een ETag-waarde of het jokerteken (*). Wordt gebruikt om te controleren of de resource is gewijzigd en om te handelen volgens de voorwaarde die is opgegeven door de parameter match_condition .

match_condition

MatchConditions

De overeenkomstvoorwaarde die moet worden gebruikt voor de etag.

response_hook

Callable

Een aanroepbare aangeroepen met de antwoordmetagegevens.

Retouren

Een dicteerfunctie die het opgeslagen item vertegenwoordigt.

Retourtype

dict[str, Any]

Uitzonderingen

CosmosHttpResponseError

Het opgegeven item kan niet worden onderbroken.

Kenmerken

is_system_key

scripts