ContainerProxy Klasse

Eine Schnittstelle für die Interaktion mit einem bestimmten DB-Container.

Diese Klasse sollte nicht direkt instanziiert werden. Verwenden Sie stattdessen die get_container_client -Methode, um einen vorhandenen Container abzurufen, oder die create_container -Methode, um einen neuen Container zu erstellen.

Ein Container in einer Azure Cosmos DB SQL-API-Datenbank ist eine Sammlung von Dokumenten, die jeweils als Element dargestellt werden.

Vererbung

builtins.object

ContainerProxy

Konstruktor

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

Parameter

client_connection

database_link

id

properties

Standardwert: None

Variablen

id

str

ID (Name) des Containers

session_token

str

Das Sitzungstoken für den Container.

Methoden

create_item	Erstellen Sie ein Element im Container. Verwenden Sie die upsert_item -Methode, um ein vorhandenes Element zu aktualisieren oder zu ersetzen.
delete_all_items_by_partition_key	Das Feature „Löschen nach Partitionsschlüssel“ ist ein asynchroner Hintergrundvorgang, mit dem Sie alle Dokumente mit demselben logischen Partitionsschlüsselwert löschen können, indem Sie das Cosmos SDK verwenden. Der Vorgang „Löschen nach Partitionsschlüssel“ ist darauf beschränkt, pro Sekunde höchstens 10 % der insgesamt verfügbaren RU/s (Anforderungseinheiten pro Sekunde) des Containers zu verbrauchen. Dies hilft dabei, die von dieser Hintergrundaufgabe verwendeten Ressourcen einzuschränken.
delete_conflict	Löschen Sie einen angegebenen Konflikt aus dem Container. Wenn der Konflikt noch nicht im Container vorhanden ist, wird eine Ausnahme ausgelöst.
delete_item	Löschen Sie das angegebene Element aus dem Container. Wenn das Element noch nicht im Container vorhanden ist, wird eine Ausnahme ausgelöst.
get_conflict	Rufen Sie den Konflikt ab, der durch den Konflikt identifiziert wird.
get_throughput	Rufen Sie das ThroughputProperties-Objekt für diesen Container ab. Wenn für den Container bereits keine ThroughputProperties vorhanden sind, wird eine Ausnahme ausgelöst. :Schlüsselwort (keyword) Aufrufbare response_hook: Ein aufrufbarer Aufruf, der mit den Antwortmetadaten aufgerufen wird. :returns: Durchsatz für den Container. :löst ~azure.cosmos.exceptions.CosmosHttpResponseError: Für den Container oder sind keine Durchsatzeigenschaften vorhanden. die Durchsatzeigenschaften konnten nicht abgerufen werden.
list_conflicts	Listet alle Konflikte im Container auf.
patch_item	Vorläufige Methode Patcht das angegebene Element mit den bereitgestellten Vorgängen, sofern es im Container vorhanden ist. Wenn das Element noch nicht im Container vorhanden ist, wird eine Ausnahme ausgelöst.
query_conflicts	Gibt alle Konflikte zurück, die einer bestimmten Abfrage entsprechen.
query_items	Gibt alle Ergebnisse zurück, die der angegebenen Abfrage entsprechen. Sie können einen beliebigen Wert für den Containernamen in der FROM-Klausel verwenden, aber häufig wird der Containername verwendet. In den folgenden Beispielen lautet der Containername "products" und wird als "p" aliasiert, um in der WHERE-Klausel leichter auf verweisen zu können. Antwortfortsetzungstoken in der Abfrageantwort. Gültige Werte sind positive ganze Zahlen. Ein Wert von 0 ist identisch mit dem Nichtübergaben eines Werts (standardmäßig kein Grenzwert). :Schlüsselwort (keyword) int max_integrated_cache_staleness_in_ms: Die maximale Cacheveraltung für den integrierten Cache in Millisekunden. Für Konten, die für die Verwendung des integrierten Caches mit Sitzungs- oder Eventualkonsistenz konfiguriert sind, werden Antworten garantiert nicht als dieser Wert verwendet.
query_items_change_feed	Rufen Sie eine sortierte Liste der Geänderten Elemente in der Reihenfolge ab, in der sie geändert wurden.
read	Lesen Sie die Containereigenschaften.
read_all_items	Listet alle Elemente im Container auf.
read_item	Rufen Sie das durch Element identifizierte Element ab.
read_offer	Rufen Sie das ThroughputProperties-Objekt für diesen Container ab. Wenn für den Container bereits keine ThroughputProperties vorhanden sind, wird eine Ausnahme ausgelöst. :Schlüsselwort (keyword) Aufrufbare response_hook: Ein aufrufbarer Aufruf, der mit den Antwortmetadaten aufgerufen wird. :returns: Durchsatz für den Container. :raises ~azure.cosmos.exceptions.CosmosHttpResponseError: Keine Durchsatzeigenschaften für den Container oder die Durchsatzeigenschaften konnten nicht abgerufen werden.
replace_item	Ersetzt das angegebene Element, wenn es im Container vorhanden ist. Wenn das Element noch nicht im Container vorhanden ist, wird eine Ausnahme ausgelöst.
replace_throughput	Ersetzen Sie den Durchsatz des Containers. Wenn für den Container bereits keine ThroughputProperties vorhanden sind, wird eine Ausnahme ausgelöst.
upsert_item	Fügen Sie das angegebene Element ein, oder aktualisieren Sie es. Wenn das Element bereits im Container vorhanden ist, wird es ersetzt. Wenn das Element noch nicht vorhanden ist, wird es eingefügt.

create_item

Erstellen Sie ein Element im Container.

Verwenden Sie die upsert_item -Methode, um ein vorhandenes Element zu aktualisieren oder zu ersetzen.

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]

Parameter

body

Erforderlich

Ein diktierähnliches Objekt, das das zu erstellende Element darstellt.

pre_trigger_include

Erforderlich

Trigger-ID, die als Prävorgangstrigger verwendet werden soll.

post_trigger_include

Erforderlich

Trigger-ID, die als Trigger nach dem Vorgang verwendet werden soll.

indexing_directive

Erforderlich

Geben Sie an, ob das Dokument bei der Indizierung ausgelassen werden soll.

enable_automatic_id_generation

bool

Aktivieren Sie die automatische ID-Generierung, wenn keine ID vorhanden ist.

session_token

str

Token zur Verwendung mit Sitzungskonsistenz.

initial_headers

dict[str,str]

Anfängliche Header, die als Teil der Anforderung gesendet werden sollen.

etag

str

Ein ETag-Wert oder das Platzhalterzeichen (*). Wird verwendet, um zu überprüfen, ob sich die Ressource geändert hat, und handelt gemäß der Bedingung, die vom parameter match_condition angegeben wird.

match_condition

MatchConditions

Die Übereinstimmungsbedingung, die für das etag verwendet werden soll.

response_hook

Callable

Ein aufrufbarer, der mit den Antwortmetadaten aufgerufen wird.

Gibt zurück

Ein Diktat, das das neue Element darstellt.

Rückgabetyp

dict[str, Any]

Ausnahmen

CosmosHttpResponseError

Das Element mit der angegebenen ID ist bereits vorhanden.

delete_all_items_by_partition_key

Das Feature „Löschen nach Partitionsschlüssel“ ist ein asynchroner Hintergrundvorgang, mit dem Sie alle Dokumente mit demselben logischen Partitionsschlüsselwert löschen können, indem Sie das Cosmos SDK verwenden. Der Vorgang „Löschen nach Partitionsschlüssel“ ist darauf beschränkt, pro Sekunde höchstens 10 % der insgesamt verfügbaren RU/s (Anforderungseinheiten pro Sekunde) des Containers zu verbrauchen. Dies hilft dabei, die von dieser Hintergrundaufgabe verwendeten Ressourcen einzuschränken.

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

Parameter

partition_key

Any

Erforderlich

Partitionsschlüssel für die zu löschenden Elemente.

pre_trigger_include

str

Trigger-ID, die als Prävorgangstrigger verwendet werden soll.

post_trigger_include

str

Trigger-ID, die als Trigger nach dem Vorgang verwendet werden soll.

session_token

str

Token zur Verwendung mit Sitzungskonsistenz.

etag

str

Ein ETag-Wert oder das Platzhalterzeichen (*). Wird verwendet, um zu überprüfen, ob sich die Ressource geändert hat, und handelt gemäß der Bedingung, die vom parameter match_condition angegeben wird.

match_condition

MatchConditions

Die Übereinstimmungsbedingung, die für das etag verwendet werden soll.

response_hook

Callable

Ein aufrufbarer, der mit den Antwortmetadaten aufgerufen wird.

Rückgabetyp

None

Ausnahmen

CosmosHttpResponseError

Das Element mit der angegebenen ID ist bereits vorhanden.

delete_conflict

Löschen Sie einen angegebenen Konflikt aus dem Container.

Wenn der Konflikt noch nicht im Container vorhanden ist, wird eine Ausnahme ausgelöst.

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

Parameter

conflict

Erforderlich

Die ID (Name) oder das Diktat, das den zu löschenden Konflikt darstellt.

partition_key

Erforderlich

Partitionsschlüssel für den zu löschenden Konflikt.

response_hook

Callable

Ein aufrufbarer, der mit den Antwortmetadaten aufgerufen wird.

Rückgabetyp

None

Ausnahmen

CosmosHttpResponseError

Der Konflikt wurde nicht erfolgreich gelöscht.

CosmosResourceNotFoundError

Der Konflikt ist im Container nicht vorhanden.

delete_item

Löschen Sie das angegebene Element aus dem Container.

Wenn das Element noch nicht im Container vorhanden ist, wird eine Ausnahme ausgelöst.

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

Parameter

item

Erforderlich

Die ID (Name) oder das Diktat, das das zu löschende Element darstellt.

partition_key

Erforderlich

Gibt den Partitionsschlüsselwert für das Element an.

pre_trigger_include

Erforderlich

Trigger-ID, die als Prävorgangstrigger verwendet werden soll.

post_trigger_include

Erforderlich

Trigger-ID, die als Trigger nach dem Vorgang verwendet werden soll.

session_token

str

Token zur Verwendung mit Sitzungskonsistenz.

initial_headers

dict[str,str]

Anfängliche Header, die als Teil der Anforderung gesendet werden sollen.

etag

str

Ein ETag-Wert oder das Platzhalterzeichen (*). Wird verwendet, um zu überprüfen, ob sich die Ressource geändert hat, und handelt gemäß der Bedingung, die vom parameter match_condition angegeben wird.

match_condition

MatchConditions

Die Übereinstimmungsbedingung, die für das etag verwendet werden soll.

response_hook

Callable

Ein aufrufbarer, der mit den Antwortmetadaten aufgerufen wird.

Rückgabetyp

None

Ausnahmen

CosmosHttpResponseError

Das Element wurde nicht erfolgreich gelöscht.

CosmosResourceNotFoundError

Das Element ist im Container nicht vorhanden.

get_conflict

Rufen Sie den Konflikt ab, der durch den Konflikt identifiziert wird.

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

Parameter

conflict

Erforderlich

Die ID (Name) oder das Diktat, das den abzurufenden Konflikt darstellt.

partition_key

Erforderlich

Partitionsschlüssel für den abzurufenden Konflikt.

response_hook

Callable

Ein aufrufbarer, der mit den Antwortmetadaten aufgerufen wird.

Gibt zurück

Ein Diktat, das den abgerufenen Konflikt darstellt.

Rückgabetyp

dict[str, Any]

Ausnahmen

CosmosHttpResponseError

Der angegebene Konflikt konnte nicht abgerufen werden.

get_throughput

Rufen Sie das ThroughputProperties-Objekt für diesen Container ab.

Wenn für den Container bereits keine ThroughputProperties vorhanden sind, wird eine Ausnahme ausgelöst. :Schlüsselwort (keyword) Aufrufbare response_hook: Ein aufrufbarer Aufruf, der mit den Antwortmetadaten aufgerufen wird. :returns: Durchsatz für den Container. :löst ~azure.cosmos.exceptions.CosmosHttpResponseError: Für den Container oder sind keine Durchsatzeigenschaften vorhanden.

die Durchsatzeigenschaften konnten nicht abgerufen werden.

get_throughput(**kwargs: Any) -> ThroughputProperties

Rückgabetyp

ThroughputProperties

Ausnahmen

CosmosHttpResponseError

Das Element mit der angegebenen ID ist bereits vorhanden.

list_conflicts

Listet alle Konflikte im Container auf.

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

Parameter

max_item_count

Erforderlich

Maximale Anzahl von Elementen, die im Enumerationsvorgang zurückgegeben werden sollen.

response_hook

Callable

Ein aufrufbarer, der mit den Antwortmetadaten aufgerufen wird.

Gibt zurück

Eine Iterable von Konflikten (Diktaten).

Rückgabetyp

Iterable[dict[str, Any]]

Ausnahmen

CosmosHttpResponseError

Das Element mit der angegebenen ID ist bereits vorhanden.

patch_item

Vorläufige Methode Patcht das angegebene Element mit den bereitgestellten Vorgängen, sofern es im Container vorhanden ist.

Wenn das Element noch nicht im Container vorhanden ist, wird eine Ausnahme ausgelöst.

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

Parameter

item

Union[str, Dict[str, Any]]

Erforderlich

Die ID (Name) oder das Diktat, das das zu patchende Element darstellt.

partition_key

Union[str, int, float, bool]

Erforderlich

Der Partitionsschlüssel des zu patchenden Objekts.

patch_operations

List[Dict[str, Any]]

Erforderlich

Die Liste der Patchvorgänge, die auf das Element angewendet werden sollen.

filter_predicate

str

bedingter Filter, der auf Patchvorgänge angewendet werden soll.

pre_trigger_include

str

Trigger-ID, die als Prävorgangstrigger verwendet werden soll.

post_trigger_include

str

Trigger-ID, die als Trigger nach dem Vorgang verwendet werden soll.

session_token

str

Token zur Verwendung mit Sitzungskonsistenz.

etag

str

Ein ETag-Wert oder das Platzhalterzeichen (*). Wird verwendet, um zu überprüfen, ob sich die Ressource geändert hat, und handelt gemäß der Bedingung, die vom parameter match_condition angegeben wird.

match_condition

MatchConditions

Die Übereinstimmungsbedingung, die für das etag verwendet werden soll.

response_hook

Callable

Ein aufrufbarer, der mit den Antwortmetadaten aufgerufen wird.

Gibt zurück

Ein Diktat, das das Element darstellt, nachdem die Patchvorgänge durchlaufen wurden.

Rückgabetyp

dict[str, Any]

Ausnahmen

CosmosHttpResponseError

Die Patchvorgänge sind fehlgeschlagen, oder das Element mit der angegebenen ID ist nicht vorhanden.

query_conflicts

Gibt alle Konflikte zurück, die einer bestimmten Abfrage entsprechen.

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]]

Parameter

query

Erforderlich

Die auszuführende Azure Cosmos DB-SQL-Abfrage.

parameters

Erforderlich

Optionales Array von Parametern für die Abfrage. Wird ignoriert, wenn keine Abfrage bereitgestellt wird.

enable_cross_partition_query

Erforderlich

Ermöglicht das Senden mehrerer Anforderungen zum Ausführen der Abfrage im Azure Cosmos DB-Dienst. Wenn die Abfrage nicht auf den Wert eines einzelnen Partitionsschlüssels festgelegt ist, sind mehrere Anforderungen erforderlich.

partition_key

Erforderlich

Gibt den Partitionsschlüsselwert für das Element an.

max_item_count

Erforderlich

Maximale Anzahl von Elementen, die im Enumerationsvorgang zurückgegeben werden sollen.

response_hook

Callable

Ein aufrufbarer, der mit den Antwortmetadaten aufgerufen wird.

Gibt zurück

Eine Iterable von Konflikten (Diktaten).

Rückgabetyp

Iterable[dict[str, Any]]

Ausnahmen

CosmosHttpResponseError

Das Element mit der angegebenen ID ist bereits vorhanden.

query_items

Gibt alle Ergebnisse zurück, die der angegebenen Abfrage entsprechen.

Sie können einen beliebigen Wert für den Containernamen in der FROM-Klausel verwenden, aber häufig wird der Containername verwendet. In den folgenden Beispielen lautet der Containername "products" und wird als "p" aliasiert, um in der WHERE-Klausel leichter auf verweisen zu können.

Antwortfortsetzungstoken in der Abfrageantwort. Gültige Werte sind positive ganze Zahlen. Ein Wert von 0 ist identisch mit dem Nichtübergaben eines Werts (standardmäßig kein Grenzwert). :Schlüsselwort (keyword) int max_integrated_cache_staleness_in_ms: Die maximale Cacheveraltung für den integrierten Cache in

Millisekunden. Für Konten, die für die Verwendung des integrierten Caches mit Sitzungs- oder Eventualkonsistenz konfiguriert sind, werden Antworten garantiert nicht als dieser Wert verwendet.

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]]

Gibt zurück

Eine Iterable von Elementen (Dicts).

Rückgabetyp

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

Ausnahmen

CosmosHttpResponseError

Das Element mit der angegebenen ID ist bereits vorhanden.

Beispiele

Erhalten Sie alle Produkte, die nicht eingestellt wurden:

   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))

Parametrisierte Abfrage zum Abrufen aller Produkte, die eingestellt wurden:

   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

Rufen Sie eine sortierte Liste der Geänderten Elemente in der Reihenfolge ab, in der sie geändert wurden.

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]]

Parameter

partition_key_range_id

Erforderlich

ChangeFeed-Anforderungen können für bestimmte Partitionsschlüsselbereiche ausgeführt werden. Dies wird verwendet, um den Änderungsfeed parallel über mehrere Consumer hinweg zu verarbeiten.

partition_key

Erforderlich

Partitionsschlüssel, auf den ChangeFeed-Anforderungen ausgerichtet sind.

is_start_from_beginning

Erforderlich

Ermitteln Sie, ob der Änderungsfeed von anfang (true) oder von aktuell (false) beginnen soll. Standardmäßig wird mit "current" (false) gestartet.

continuation

Erforderlich

e_tag Wert, der als Fortsetzung zum Lesen des Änderungsfeeds verwendet werden soll.

max_item_count

Erforderlich

Maximale Anzahl von Elementen, die im Enumerationsvorgang zurückgegeben werden sollen.

response_hook

Callable

Ein aufrufbarer Aufruf, der mit den Antwortmetadaten aufgerufen wird.

Gibt zurück

Eine Iterable von Elementen (Dicts).

Rückgabetyp

Iterable[dict[str, Any]]

Ausnahmen

CosmosHttpResponseError

Das Element mit der angegebenen ID ist bereits vorhanden.

read

Lesen Sie die Containereigenschaften.

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

Parameter

populate_partition_key_range_statistics

bool

Aktivieren Sie die Rückgabe von Partitionsschlüsselbereichsstatistiken in Antwortheadern.

populate_quota_info

bool

Aktivieren Sie die Rückgabe von Sammlungsspeicherkontingentinformationen in Antwortheadern.

session_token

str

Token zur Verwendung mit Sitzungskonsistenz.

initial_headers

dict[str,str]

Anfängliche Header, die als Teil der Anforderung gesendet werden sollen.

response_hook

Callable

Ein aufrufbarer Aufruf, der mit den Antwortmetadaten aufgerufen wird.

Gibt zurück

Dict, das den abgerufenen Container darstellt.

Rückgabetyp

dict[str, Any]

Ausnahmen

CosmosHttpResponseError

Wird ausgelöst, wenn der Container nicht abgerufen werden konnte. Dies schließt ein, wenn der Container nicht vorhanden ist.

read_all_items

Listet alle Elemente im Container auf.

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

Parameter

max_item_count

Erforderlich

Maximale Anzahl von Elementen, die im Enumerationsvorgang zurückgegeben werden sollen.

session_token

str

Token zur Verwendung mit Sitzungskonsistenz.

initial_headers

dict[str,str]

Anfängliche Header, die als Teil der Anforderung gesendet werden sollen.

response_hook

Callable

Ein aufrufbarer Aufruf, der mit den Antwortmetadaten aufgerufen wird.

max_integrated_cache_staleness_in_ms

int

Die maximale Cacheveraltung für den integrierten Cache in Millisekunden. Für Konten, die für die Verwendung des integrierten Caches mit Sitzungs- oder Eventualkonsistenz konfiguriert sind, werden Antworten garantiert nicht als dieser Wert verwendet.

Gibt zurück

Eine Iterable von Elementen (Dicts).

Rückgabetyp

Iterable[dict[str, Any]]

Ausnahmen

CosmosHttpResponseError

Das Element mit der angegebenen ID ist bereits vorhanden.

read_item

Rufen Sie das durch Element identifizierte Element ab.

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]

Parameter

item

Erforderlich

Die ID (Name) oder das Diktat, das das abzurufende Element darstellt.

partition_key

Erforderlich

Partitionsschlüssel für das abzurufende Element.

post_trigger_include

Erforderlich

Trigger-ID, die als Trigger nach dem Vorgang verwendet werden soll.

session_token

str

Token zur Verwendung mit Sitzungskonsistenz.

initial_headers

dict[str,str]

Anfängliche Header, die als Teil der Anforderung gesendet werden sollen.

response_hook

Callable

Ein aufrufbarer Aufruf, der mit den Antwortmetadaten aufgerufen wird.

max_integrated_cache_staleness_in_ms

int

Die maximale Cacheveraltung für den integrierten Cache in Millisekunden. Für Konten, die für die Verwendung des integrierten Caches mit Sitzungs- oder Eventualkonsistenz konfiguriert sind, werden Antworten garantiert nicht als dieser Wert verwendet.

Gibt zurück

Dict, das das abzurufende Element darstellt.

Rückgabetyp

dict[str, Any]

Ausnahmen

CosmosHttpResponseError

Das angegebene Element konnte nicht abgerufen werden.

Beispiele

Rufen Sie ein Element aus der Datenbank ab, und aktualisieren Sie eine der zugehörigen Eigenschaften:

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

read_offer

Rufen Sie das ThroughputProperties-Objekt für diesen Container ab. Wenn für den Container bereits keine ThroughputProperties vorhanden sind, wird eine Ausnahme ausgelöst. :Schlüsselwort (keyword) Aufrufbare response_hook: Ein aufrufbarer Aufruf, der mit den Antwortmetadaten aufgerufen wird. :returns: Durchsatz für den Container. :raises ~azure.cosmos.exceptions.CosmosHttpResponseError: Keine Durchsatzeigenschaften für den Container oder

die Durchsatzeigenschaften konnten nicht abgerufen werden.

read_offer(**kwargs: Any) -> Offer

Rückgabetyp

ThroughputProperties

Ausnahmen

CosmosHttpResponseError

Das Element mit der angegebenen ID ist bereits vorhanden.

replace_item

Ersetzt das angegebene Element, wenn es im Container vorhanden ist.

Wenn das Element noch nicht im Container vorhanden ist, wird eine Ausnahme ausgelöst.

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]

Parameter

item

Erforderlich

Die ID (Name) oder das Dict, das das zu ersetzende Element darstellt.

body

Erforderlich

Ein dict-ähnliches Objekt, das das zu ersetzende Element darstellt.

pre_trigger_include

Erforderlich

Trigger-ID, die als Pre-Operation-Trigger verwendet werden soll.

post_trigger_include

Erforderlich

Trigger-ID, die als Trigger nach dem Vorgang verwendet werden soll.

session_token

str

Token zur Verwendung mit Sitzungskonsistenz.

initial_headers

dict[str,str]

Anfängliche Header, die als Teil der Anforderung gesendet werden sollen.

etag

str

Ein ETag-Wert oder das Platzhalterzeichen (*). Wird verwendet, um zu überprüfen, ob sich die Ressource geändert hat, und handelt gemäß der Bedingung, die vom parameter match_condition angegeben wird.

match_condition

MatchConditions

Die Übereinstimmungsbedingung, die für das etag verwendet werden soll.

response_hook

Callable

Ein aufrufbarer Aufruf, der mit den Antwortmetadaten aufgerufen wird.

Gibt zurück

Ein Diktat, das das Element nach dem Ersetzen darstellt, wurde durchlaufen.

Rückgabetyp

dict[str, Any]

Ausnahmen

CosmosHttpResponseError

Fehler beim Ersetzen, oder das Element mit der angegebenen ID ist nicht vorhanden.

replace_throughput

Ersetzen Sie den Durchsatz des Containers.

Wenn für den Container bereits keine ThroughputProperties vorhanden sind, wird eine Ausnahme ausgelöst.

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

Parameter

throughput

Erforderlich

Der festzulegende Durchsatz (eine ganze Zahl).

response_hook

Callable

Ein aufrufbarer Aufruf, der mit den Antwortmetadaten aufgerufen wird.

Gibt zurück

ThroughputProperties für den Container, aktualisiert mit neuem Durchsatz.

Rückgabetyp

ThroughputProperties

Ausnahmen

CosmosHttpResponseError

Für den Container sind keine Durchsatzeigenschaften vorhanden, oder die Durchsatzeigenschaften konnten nicht aktualisiert werden.

upsert_item

Fügen Sie das angegebene Element ein, oder aktualisieren Sie es.

Wenn das Element bereits im Container vorhanden ist, wird es ersetzt. Wenn das Element noch nicht vorhanden ist, wird es eingefügt.

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]

Parameter

body

Erforderlich

Ein dict-ähnliches Objekt, das das zu aktualisierende oder einzufügende Element darstellt.

pre_trigger_include

Erforderlich

Trigger-ID, die als Pre-Operation-Trigger verwendet werden soll.

post_trigger_include

Erforderlich

Trigger-ID, die als Trigger nach dem Vorgang verwendet werden soll.

session_token

str

Token zur Verwendung mit Sitzungskonsistenz.

initial_headers

dict[str,str]

Anfängliche Header, die als Teil der Anforderung gesendet werden sollen.

etag

str

Ein ETag-Wert oder das Platzhalterzeichen (*). Wird verwendet, um zu überprüfen, ob sich die Ressource geändert hat, und handelt gemäß der Bedingung, die vom parameter match_condition angegeben wird.

match_condition

MatchConditions

Die Übereinstimmungsbedingung, die für das etag verwendet werden soll.

response_hook

Callable

Ein aufrufbarer Aufruf, der mit den Antwortmetadaten aufgerufen wird.

Gibt zurück

Ein Diktat, das das upsertierte Element darstellt.

Rückgabetyp

dict[str, Any]

Ausnahmen

CosmosHttpResponseError

Das angegebene Element konnte nicht durch upsertiert werden.

Attribute

is_system_key

scripts