Freigeben über


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

Ausnahmen

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

Ausnahmen

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

Ausnahmen

Der Konflikt wurde nicht erfolgreich gelöscht.

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

Ausnahmen

Das Element wurde nicht erfolgreich gelöscht.

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

Ausnahmen

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

Ausnahmen

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

Ausnahmen

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

Ausnahmen

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

Ausnahmen

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

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

Ausnahmen

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

Ausnahmen

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

Ausnahmen

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

Ausnahmen

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

Ausnahmen

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

Ausnahmen

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

Ausnahmen

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

Ausnahmen

Das angegebene Element konnte nicht durch upsertiert werden.

Attribute

is_system_key

scripts