Freigeben über


CosmosAsyncContainer Klasse

  • java.lang.Object
    • com.azure.cosmos.CosmosAsyncContainer

public class CosmosAsyncContainer

Stellt Methoden zum Lesen, Löschen und Ersetzen vorhandener Container bereit. Stellt Methoden für die Interaktion mit untergeordneten Ressourcen bereit (Elemente, Skripts, Konflikte)

Methodenzusammenfassung

Modifizierer und Typ Methode und Beschreibung
Mono<CosmosItemResponse<T>> createItem(T item)

Erstellt ein Element.

Mono<CosmosItemResponse<T>> createItem(T item, CosmosItemRequestOptions options)

Erstellt ein Cosmos-Element.

Mono<CosmosItemResponse<T>> createItem(T item, PartitionKey partitionKey, CosmosItemRequestOptions options)

Erstellt ein Element.

Mono<CosmosItemResponse<Object>> deleteItem(T item, CosmosItemRequestOptions options)

Löscht das Element.

Mono<CosmosItemResponse<T>> patchItem(String itemId, PartitionKey partitionKey, CosmosPatchOperations cosmosPatchOperations, CosmosPatchItemRequestOptions options, Class<T> itemType)

Führen Sie ein partielles Update aus, das bestimmte Eigenschaften oder Felder des Elements ändert, ohne das gesamte Element zu ersetzen.

Mono<CosmosItemResponse<T>> patchItem(String itemId, PartitionKey partitionKey, CosmosPatchOperations cosmosPatchOperations, Class<T> itemType)

Führen Sie ein partielles Update aus, das bestimmte Eigenschaften oder Felder des Elements ändert, ohne das gesamte Element zu ersetzen.

CosmosPagedFlux<T> queryChangeFeed(CosmosChangeFeedRequestOptions options, Class<T> classType)

Abfragen von Elementen im Änderungsfeed des aktuellen Containers mithilfe von CosmosChangeFeedRequestOptions.

CosmosPagedFlux<T> queryItems(SqlQuerySpec querySpec, CosmosQueryRequestOptions options, Class<T> classType)

Abfragen von Elementen im aktuellen Container mithilfe von und SqlQuerySpecCosmosQueryRequestOptions.

CosmosPagedFlux<T> queryItems(SqlQuerySpec querySpec, Class<T> classType)

Abfragen nach Elementen im aktuellen Container mithilfe von SqlQuerySpec.

CosmosPagedFlux<T> queryItems(String query, CosmosQueryRequestOptions options, Class<T> classType)

Abfragen nach Elementen im aktuellen Container mithilfe einer Zeichenfolge.

CosmosPagedFlux<T> queryItems(String query, Class<T> classType)

Abfragen nach Elementen im aktuellen Container.

CosmosPagedFlux<T> readAllItems(PartitionKey partitionKey, CosmosQueryRequestOptions options, Class<T> classType)

Liest alle Elemente einer logischen Partition

CosmosPagedFlux<T> readAllItems(PartitionKey partitionKey, Class<T> classType)

Liest alle Elemente einer logischen Partition

Mono<CosmosItemResponse<T>> readItem(String itemId, PartitionKey partitionKey, CosmosItemRequestOptions options, Class<T> itemType)

Liest eine Element-nach-Element-IDmithilfe eines konfigurierten CosmosItemRequestOptions.

Mono<CosmosItemResponse<T>> readItem(String itemId, PartitionKey partitionKey, Class<T> itemType)

Liest ein Element nach Element-ID.

Mono<FeedResponse<T>> readMany(List<CosmosItemIdentity> itemIdentityList, Class<T> classType)

Liest viele Dokumente.

Mono<FeedResponse<T>> readMany(List<CosmosItemIdentity> itemIdentityList, String sessionToken, Class<T> classType)

Liest viele Dokumente.

Mono<CosmosItemResponse<T>> replaceItem(T item, String itemId, PartitionKey partitionKey)

Ersetzt ein vorhandenes Element in einem Container durch ein neues Element.

Mono<CosmosItemResponse<T>> replaceItem(T item, String itemId, PartitionKey partitionKey, CosmosItemRequestOptions options)

Ersetzt ein vorhandenes Element in einem Container durch ein neues Element.

Mono<CosmosItemResponse<T>> upsertItem(T item)

Upsert ein Element.

Mono<CosmosItemResponse<T>> upsertItem(T item, CosmosItemRequestOptions options)

Upsert ein Element.

Mono<CosmosItemResponse<T>> upsertItem(T item, PartitionKey partitionKey, CosmosItemRequestOptions options)

Upsert ein Element.

Flux<CosmosBulkOperationResponse<TContext>> executeBulkOperations(Flux<CosmosItemOperation> operations)

Führt den Fluss von Vorgängen in Bulk aus.

Flux<CosmosBulkOperationResponse<TContext>> executeBulkOperations(Flux<CosmosItemOperation> operations, CosmosBulkExecutionOptions bulkOptions)

Führt den Fluss von Vorgängen in Bulk aus.

Mono<CosmosContainerResponse> delete()

Löscht den aktuellen Container.

Mono<CosmosContainerResponse> delete(CosmosContainerRequestOptions options)

Löscht den Container.

Mono<CosmosItemResponse<Object>> deleteAllItemsByPartitionKey(PartitionKey partitionKey, CosmosItemRequestOptions options)

Löscht alle Elemente im Container mit dem angegebenen Partitionsschlüsselwert.

Mono<CosmosItemResponse<Object>> deleteItem(String itemId, PartitionKey partitionKey)

Löscht ein Element.

Mono<CosmosItemResponse<Object>> deleteItem(String itemId, PartitionKey partitionKey, CosmosItemRequestOptions options)

Löscht das Element.

void enableGlobalThroughputControlGroup(ThroughputControlGroupConfig groupConfig, GlobalThroughputControlConfig globalControlConfig)

Aktivieren Sie die Durchsatzsteuerungsgruppe mit dem globalen Steuerungsmodus.

void enableLocalThroughputControlGroup(ThroughputControlGroupConfig groupConfig)

Aktivieren Sie die Durchsatzsteuerungsgruppe mit dem lokalen Steuerungsmodus.

Mono<CosmosBatchResponse> executeCosmosBatch(CosmosBatch cosmosBatch)

Führt den Transaktionsbatch aus.

Mono<CosmosBatchResponse> executeCosmosBatch(CosmosBatch cosmosBatch, CosmosBatchRequestOptions requestOptions)

Führt den Transaktionsbatch aus.

CosmosAsyncConflict getConflict(String id)

Ruft ein CosmosAsyncConflict Objekt ab, das den aktuellen Container als Kontext verwendet.

CosmosAsyncDatabase getDatabase()

Ruft das übergeordnete Element CosmosAsyncDatabase für den aktuellen Container ab.

Mono<List<FeedRange>> getFeedRanges()

Ruft eine Liste von ab, die zum Parallelisieren von FeedRange Feedvorgängen verwendet werden kann.

String getId()

Rufen Sie die ID von ab CosmosAsyncContainer.

CosmosAsyncScripts getScripts()

Ruft einen CosmosAsyncScripts ab, der den aktuellen Container als Kontext verwendet.

Mono<Void> openConnectionsAndInitCaches()

Als veraltet markiert

Am besten initialisieren Sie den Container, indem Sie die Caches und Verbindungen für den aktuellen Lesebereich aufwärmen.

Mono<Void> openConnectionsAndInitCaches(int numProactiveConnectionRegions)

Als veraltet markiert

Versuchen Sie, den Container zu initialisieren, indem Sie die Caches und Verbindungen mit einem angegebenen Nein aufwärmen.

CosmosPagedFlux<CosmosConflictProperties> queryConflicts(String query)

Fragt alle Konflikte im aktuellen Container ab.

CosmosPagedFlux<CosmosConflictProperties> queryConflicts(String query, CosmosQueryRequestOptions options)

Fragt alle Konflikte im aktuellen Container ab.

Mono<CosmosContainerResponse> read()

Liest den aktuellen Container.

Mono<CosmosContainerResponse> read(CosmosContainerRequestOptions options)

Liest den aktuellen Container, während zusätzliche Optionen wie If-Match angegeben werden.

CosmosPagedFlux<CosmosConflictProperties> readAllConflicts(CosmosQueryRequestOptions options)

Listet alle Konflikte im aktuellen Container auf.

Mono<ThroughputResponse> readThroughput()

Lesen Sie den für den aktuellen Container bereitgestellten Durchsatz.

Mono<CosmosContainerResponse> replace(CosmosContainerProperties containerProperties)

Ersetzt die Eigenschaften des aktuellen Containers.

Mono<CosmosContainerResponse> replace(CosmosContainerProperties containerProperties, CosmosContainerRequestOptions options)

Ersetzt die aktuellen Containereigenschaften, während nicht standardmäßige Anforderungsoptionen verwendet werden.

Mono<ThroughputResponse> replaceThroughput(ThroughputProperties throughputProperties)

Ersetzen Sie den Durchsatz.

Geerbte Methoden von java.lang.Object

Details zur Methode

createItem

public Mono> createItem(T item)

Erstellt ein Element.

Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit dem erstellten Cosmos-Element. Im Falle eines Fehlers wird der Mono Fehler angezeigt.

Parameters:

item - das Cosmos-Element, das als POJO- oder Cosmos-Elementobjekt dargestellt wird.

Returns:

eine Mono , die die einzelne Ressourcenantwort mit dem erstellten Cosmos-Element oder einem Fehler enthält.

createItem

public Mono> createItem(T item, CosmosItemRequestOptions options)

Erstellt ein Cosmos-Element.

Parameters:

item - das Element.
options - die Optionen für die Elementanforderung.

Returns:

eine Mono , die die einzelne Ressourcenantwort mit dem erstellten Cosmos-Element oder einem Fehler enthält.

createItem

public Mono> createItem(T item, PartitionKey partitionKey, CosmosItemRequestOptions options)

Erstellt ein Element.

Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit dem erstellten Cosmos-Element. Im Falle eines Fehlers wird der Mono Fehler angezeigt.

Parameters:

item - das Cosmos-Element, das als POJO- oder Cosmos-Elementobjekt dargestellt wird.
partitionKey - der Partitionsschlüssel.
options - die Anforderungsoptionen.

Returns:

eine Mono , die die einzelne Ressourcenantwort mit dem erstellten Cosmos-Element oder einem Fehler enthält.

deleteItem

public Mono> deleteItem(T item, CosmosItemRequestOptions options)

Löscht das Element.

Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreicher Fertigstellung enthält eine einzelne Cosmos-Elementantwort für das gelöschte Element.

Parameters:

item - Element, das gelöscht werden soll.
options - die Anforderungsoptionen.

Returns:

eine Mono , die die Cosmos-Elementressourcenantwort enthält.

patchItem

public Mono> patchItem(String itemId, PartitionKey partitionKey, CosmosPatchOperations cosmosPatchOperations, CosmosPatchItemRequestOptions options, Class itemType)

Führen Sie ein partielles Update aus, das bestimmte Eigenschaften oder Felder des Elements ändert, ohne das gesamte Element zu ersetzen.

CosmosPatchOperations cosmosPatchOperations = CosmosPatchOperations.create();

 cosmosPatchOperations
     .add("/departure", "SEA")
     .increment("/trips", 1);

 cosmosAsyncContainer.patchItem(
         passenger.getId(),
         new PartitionKey(passenger.getId()),
         cosmosPatchOperations,
         Passenger.class)
     .subscribe(response -> {
         System.out.println(response);
     }, throwable -> {
         throwable.printStackTrace();
     });

Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreicher Fertigstellung enthält eine einzelne Cosmos-Elementantwort mit dem gepatchten Element.

Parameters:

itemId - die Element-ID.
partitionKey - der Partitionsschlüssel.
cosmosPatchOperations - Stellt einen Container mit einer Liste von Vorgängen dar, die sequenziell auf das verwiesene Cosmos-Element angewendet werden sollen.
options - die Anforderungsoptionen.
itemType - der Elementtyp.

Returns:

eine Mono , die die Cosmos-Elementressourcenantwort mit dem gepatchten Element oder einem Fehler enthält.

patchItem

public Mono> patchItem(String itemId, PartitionKey partitionKey, CosmosPatchOperations cosmosPatchOperations, Class itemType)

Führen Sie ein partielles Update aus, das bestimmte Eigenschaften oder Felder des Elements ändert, ohne das gesamte Element zu ersetzen.

CosmosPatchOperations cosmosPatchOperations = CosmosPatchOperations.create();

 cosmosPatchOperations
     .add("/departure", "SEA")
     .increment("/trips", 1);

 cosmosAsyncContainer.patchItem(
         passenger.getId(),
         new PartitionKey(passenger.getId()),
         cosmosPatchOperations,
         Passenger.class)
     .subscribe(response -> {
         System.out.println(response);
     }, throwable -> {
         throwable.printStackTrace();
     });

Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreicher Fertigstellung enthält eine einzelne Cosmos-Elementantwort mit dem gepatchten Element.

Parameters:

itemId - die Element-ID.
partitionKey - der Partitionsschlüssel.
cosmosPatchOperations - Stellt einen Container mit einer Liste von Vorgängen dar, die sequenziell auf das verwiesene Cosmos-Element angewendet werden sollen.
itemType - der Elementtyp.

Returns:

eine Mono , die die Cosmos-Elementressourcenantwort mit dem gepatchten Element oder einem Fehler enthält.

queryChangeFeed

public CosmosPagedFlux queryChangeFeed(CosmosChangeFeedRequestOptions options, Class classType)

Abfragen von Elementen im Änderungsfeed des aktuellen Containers mithilfe von CosmosChangeFeedRequestOptions.

CosmosChangeFeedRequestOptions options = CosmosChangeFeedRequestOptions
     .createForProcessingFromNow(FeedRange.forFullRange())
     .allVersionsAndDeletes();

 cosmosAsyncContainer.queryChangeFeed(options, Passenger.class)
     .byPage()
     .flatMap(passengerFeedResponse -> {
         for (Passenger passenger : passengerFeedResponse.getResults()) {
             System.out.println(passenger);
         }
         return Flux.empty();
     })
     .subscribe();

Nach dem Abonnement wird der Vorgang ausgeführt. Die Flux enthält eine oder mehrere Feedantworten der abgerufenen Elemente. Im Falle eines Fehlers wird der CosmosPagedFlux<T> Fehler angezeigt.

Parameters:

options - die Optionen für die Änderungsfeedanforderung.
classType - der Klassentyp.

Returns:

eine CosmosPagedFlux<T> , die eine oder mehrere Feedantwortseiten der abgerufenen Elemente oder einen Fehler enthält.

queryItems

public CosmosPagedFlux queryItems(SqlQuerySpec querySpec, CosmosQueryRequestOptions options, Class classType)

Abfragen von Elementen im aktuellen Container mithilfe von und SqlQuerySpecCosmosQueryRequestOptions.

Nach dem Abonnement wird der Vorgang ausgeführt. Die Flux enthält eine oder mehrere Feedantworten der abgerufenen Elemente. Im Falle eines Fehlers wird der CosmosPagedFlux<T> Fehler angezeigt.

Parameters:

querySpec - die SQL-Abfragespezifikation.
options - die Abfrageanforderungsoptionen.
classType - der Klassentyp.

Returns:

eine CosmosPagedFlux<T> , die eine oder mehrere Feedantwortseiten der abgerufenen Elemente oder einen Fehler enthält.

queryItems

public CosmosPagedFlux queryItems(SqlQuerySpec querySpec, Class classType)

Abfragen nach Elementen im aktuellen Container mithilfe von SqlQuerySpec.

CosmosQueryRequestOptions options = new CosmosQueryRequestOptions();

 String query = "SELECT * FROM Passenger p WHERE (p.departure = @departure)";
 List<SqlParameter> parameters = Collections.singletonList(new SqlParameter("@departure", "SEA"));
 SqlQuerySpec sqlQuerySpec = new SqlQuerySpec(query, parameters);

 cosmosAsyncContainer.queryItems(sqlQuerySpec, options, Passenger.class)
     .byPage()
     .flatMap(passengerFeedResponse -> {
         for (Passenger passenger : passengerFeedResponse.getResults()) {
             System.out.println(passenger);
         }
         return Flux.empty();
     })
     .subscribe();

Nach dem Abonnement wird der Vorgang ausgeführt. Die CosmosPagedFlux<T> enthält eine oder mehrere Feedantworten der abgerufenen Elemente. Im Falle eines Fehlers wird der CosmosPagedFlux<T> Fehler angezeigt.

Parameters:

querySpec - die SQL-Abfragespezifikation.
classType - der Klassentyp.

Returns:

eine CosmosPagedFlux<T> , die eine oder mehrere Feedantwortseiten der abgerufenen Elemente oder einen Fehler enthält.

queryItems

public CosmosPagedFlux queryItems(String query, CosmosQueryRequestOptions options, Class classType)

Abfragen nach Elementen im aktuellen Container mithilfe einer Zeichenfolge.

CosmosQueryRequestOptions options = new CosmosQueryRequestOptions();
 String query = "SELECT * FROM Passenger WHERE Passenger.departure IN ('SEA', 'IND')";
 cosmosAsyncContainer.queryItems(query, options, Passenger.class)
     .byPage()
     .flatMap(passengerFeedResponse -> {
         for (Passenger passenger : passengerFeedResponse.getResults()) {
             System.out.println(passenger);
         }
         return Flux.empty();
     })
     .subscribe();

Nach dem Abonnement wird der Vorgang ausgeführt. Die CosmosPagedFlux<T> enthält eine oder mehrere Feedantworten der abgerufenen Elemente. Im Falle eines Fehlers wird der CosmosPagedFlux<T> Fehler angezeigt.

Parameters:

query - die Abfrage.
options - die Abfrageanforderungsoptionen.
classType - der Klassentyp.

Returns:

eine CosmosPagedFlux<T> , die eine oder mehrere Feedantwortseiten der abgerufenen Elemente oder einen Fehler enthält.

queryItems

public CosmosPagedFlux queryItems(String query, Class classType)

Abfragen nach Elementen im aktuellen Container.

CosmosQueryRequestOptions options = new CosmosQueryRequestOptions();
 String query = "SELECT * FROM Passenger WHERE Passenger.departure IN ('SEA', 'IND')";
 cosmosAsyncContainer.queryItems(query, options, Passenger.class)
     .byPage()
     .flatMap(passengerFeedResponse -> {
         for (Passenger passenger : passengerFeedResponse.getResults()) {
             System.out.println(passenger);
         }
         return Flux.empty();
     })
     .subscribe();

Nach dem Abonnement wird der Vorgang ausgeführt. Die CosmosPagedFlux<T> enthält eine oder mehrere Feedantworten der abgerufenen Elemente. Im Falle eines Fehlers wird der CosmosPagedFlux<T> Fehler angezeigt.

Parameters:

query - die Abfrage.
classType - der Klassentyp.

Returns:

eine CosmosPagedFlux<T> , die eine oder mehrere Feedantwortseiten der abgerufenen Elemente oder einen Fehler enthält.

readAllItems

public CosmosPagedFlux readAllItems(PartitionKey partitionKey, CosmosQueryRequestOptions options, Class classType)

Liest alle Elemente einer logischen Partition

cosmosAsyncContainer
     .readAllItems(new PartitionKey(partitionKey), Passenger.class)
     .byPage(100)
     .flatMap(passengerFeedResponse -> {
         for (Passenger passenger : passengerFeedResponse.getResults()) {
             System.out.println(passenger);
         }
         return Flux.empty();
     })
     .subscribe();

Nach dem Abonnement wird der Vorgang ausgeführt. Enthält CosmosPagedFlux<T> eine oder mehrere Feedantworten der gelesenen Cosmos-Elemente. Im Falle eines Fehlers wird der CosmosPagedFlux<T> Fehler angezeigt.

Parameters:

partitionKey - Der Partitionsschlüsselwert der Dokumente, die gelesen werden müssen
options - die Feedoptionen (Optional).
classType - der Klassentyp.

Returns:

eine CosmosPagedFlux<T> , die eine oder mehrere Feedantwortseiten der gelesenen Cosmos-Elemente oder einen Fehler enthält.

readAllItems

public CosmosPagedFlux readAllItems(PartitionKey partitionKey, Class classType)

Liest alle Elemente einer logischen Partition

cosmosAsyncContainer
     .readAllItems(new PartitionKey(partitionKey), Passenger.class)
     .byPage(100)
     .flatMap(passengerFeedResponse -> {
         for (Passenger passenger : passengerFeedResponse.getResults()) {
             System.out.println(passenger);
         }
         return Flux.empty();
     })
     .subscribe();

Nach dem Abonnement wird der Vorgang ausgeführt. Enthält CosmosPagedFlux<T> eine oder mehrere Feedantworten der gelesenen Cosmos-Elemente. Im Falle eines Fehlers wird der CosmosPagedFlux<T> Fehler angezeigt.

Parameters:

partitionKey - Der Partitionsschlüsselwert der Dokumente, die gelesen werden müssen
classType - der Klassentyp.

Returns:

eine CosmosPagedFlux<T> , die eine oder mehrere Feedantwortseiten der gelesenen Cosmos-Elemente oder einen Fehler enthält.

readItem

public Mono> readItem(String itemId, PartitionKey partitionKey, CosmosItemRequestOptions options, Class itemType)

Liest ein Element nach itemId mithilfe eines konfigurierten CosmosItemRequestOptions. Dieser Vorgang wird verwendet, um ein einzelnes Element aus einem Container basierend auf dem eindeutigen Bezeichner (ID) und dem Partitionsschlüssel abzurufen. Der readItem-Vorgang ermöglicht den direkten Zugriff auf ein bestimmtes Element mithilfe des eindeutigen Bezeichners, der aus der ID des Elements und dem Partitionsschlüsselwert besteht. Dieser Vorgang ist effizient, um ein bekanntes Element anhand seiner ID und des Partitionsschlüssels abzurufen, ohne dass eine komplexe Abfrage erforderlich ist.

Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreicher Fertigstellung enthält eine Cosmos-Elementantwort mit dem Leseelement.

Parameters:

itemId - die Element-ID.
partitionKey - der Partitionsschlüssel.
options - die Anforderung (Optional) CosmosItemRequestOptions.
itemType - der Elementtyp.

Returns:

eine Mono , die die Cosmos-Elementantwort mit dem Leseelement oder einem Fehler enthält.

readItem

public Mono> readItem(String itemId, PartitionKey partitionKey, Class itemType)

Liest ein Element nach itemId. Dieser Vorgang wird verwendet, um ein einzelnes Element aus einem Container basierend auf dem eindeutigen Bezeichner (ID) und dem Partitionsschlüssel abzurufen. Der readItem-Vorgang ermöglicht den direkten Zugriff auf ein bestimmtes Element mithilfe des eindeutigen Bezeichners, der aus der ID des Elements und dem Partitionsschlüsselwert besteht. Dieser Vorgang ist effizient, um ein bekanntes Element anhand seiner ID und des Partitionsschlüssels abzurufen, ohne dass eine komplexe Abfrage erforderlich ist.

Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreicher Fertigstellung enthält eine Elementantwort mit dem gelesenen Element.

// Read an item
 cosmosAsyncContainer.readItem(passenger.getId(), new PartitionKey(passenger.getId()), Passenger.class)
     .flatMap(response -> Mono.just(response.getItem()))
     .subscribe(passengerItem -> System.out.println(passengerItem), throwable -> {
         CosmosException cosmosException = (CosmosException) throwable;
         cosmosException.printStackTrace();
     });
 // ...

Parameters:

itemId - die Element-ID.
partitionKey - der Partitionsschlüssel.
itemType - der Elementtyp.

Returns:

eine Mono , die die Cosmos-Elementantwort mit dem Leseelement oder einem Fehler enthält.

readMany

public Mono> readMany(List itemIdentityList, Class classType)

Liest viele Dokumente. Nützlich zum Lesen vieler Dokumente mit einer bestimmten ID und einem bestimmten Partitionsschlüssel in einer einzelnen Anforderung. Wenn ein Dokument aus der Liste fehlt, wird keine Ausnahme ausgelöst.

List<CosmosItemIdentity> itemIdentityList = new ArrayList<>();
 itemIdentityList.add(new CosmosItemIdentity(new PartitionKey(passenger1Id), passenger1Id));
 itemIdentityList.add(new CosmosItemIdentity(new PartitionKey(passenger2Id), passenger2Id));

 cosmosAsyncContainer.readMany(itemIdentityList, Passenger.class)
     .flatMap(passengerFeedResponse -> {
         for (Passenger passenger : passengerFeedResponse.getResults()) {
             System.out.println(passenger);
         }
         return Mono.empty();
     })
     .subscribe();

Parameters:

itemIdentityList - CosmosItem-ID und Partitionsschlüsseltupel von Elementen, die gelesen werden müssen
classType - Klassentyp

Returns:

Mono mit Feedantwort von Cosmos-Elementen

readMany

public Mono> readMany(List itemIdentityList, String sessionToken, Class classType)

Liest viele Dokumente. Nützlich zum Lesen vieler Dokumente mit einer bestimmten ID und einem bestimmten Partitionsschlüssel in einer einzelnen Anforderung. Wenn ein Dokument aus der Liste fehlt, wird keine Ausnahme ausgelöst.

List<CosmosItemIdentity> itemIdentityList = new ArrayList<>();
 itemIdentityList.add(new CosmosItemIdentity(new PartitionKey(passenger1Id), passenger1Id));
 itemIdentityList.add(new CosmosItemIdentity(new PartitionKey(passenger2Id), passenger2Id));

 cosmosAsyncContainer.readMany(itemIdentityList, Passenger.class)
     .flatMap(passengerFeedResponse -> {
         for (Passenger passenger : passengerFeedResponse.getResults()) {
             System.out.println(passenger);
         }
         return Mono.empty();
     })
     .subscribe();

Parameters:

itemIdentityList - CosmosItem-ID und Partitionsschlüsseltupel von Elementen, die gelesen werden müssen
sessionToken - das optionale Sitzungstoken – NULL, wenn der Lesevorgang ohne bestimmtes Sitzungstoken erfolgen kann
classType - Klassentyp

Returns:

Mono mit Feedantwort von Cosmos-Elementen oder Fehler

replaceItem

public Mono> replaceItem(T item, String itemId, PartitionKey partitionKey)

Ersetzt ein vorhandenes Element in einem Container durch ein neues Element. Es führt einen vollständigen Ersatz des Elements durch und ersetzt alle zugehörigen Eigenschaften durch die Eigenschaften des neuen Elements.

cosmosAsyncContainer.replaceItem(
         newPassenger,
         oldPassenger.getId(),
         new PartitionKey(oldPassenger.getId()),
         new CosmosItemRequestOptions())
     .subscribe(response -> {
         System.out.println(response);
     }, throwable -> {
         throwable.printStackTrace();
     });

Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreicher Fertigstellung enthält eine einzelne Cosmos-Elementantwort mit dem ersetzten Element.

Parameters:

item - das zu ersetzende Element (mit der Element-ID).
itemId - die Element-ID.
partitionKey - der Partitionsschlüssel.

Returns:

eine Mono , die die Cosmos-Elementressourcenantwort mit dem ersetzten Element oder einem Fehler enthält.

replaceItem

public Mono> replaceItem(T item, String itemId, PartitionKey partitionKey, CosmosItemRequestOptions options)

Ersetzt ein vorhandenes Element in einem Container durch ein neues Element. Es führt einen vollständigen Ersatz des Elements durch und ersetzt alle zugehörigen Eigenschaften durch die Eigenschaften des neuen Elements.

cosmosAsyncContainer.replaceItem(
         newPassenger,
         oldPassenger.getId(),
         new PartitionKey(oldPassenger.getId()),
         new CosmosItemRequestOptions())
     .subscribe(response -> {
         System.out.println(response);
     }, throwable -> {
         throwable.printStackTrace();
     });

Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreicher Fertigstellung enthält eine einzelne Cosmos-Elementantwort mit dem ersetzten Element.

Parameters:

item - das zu ersetzende Element (mit der Element-ID).
itemId - die Element-ID.
partitionKey - der Partitionsschlüssel.
options - die Anforderung comosItemRequestOptions (Optional).

Returns:

eine Mono , die die Cosmos-Elementressourcenantwort mit dem ersetzten Element oder einem Fehler enthält.

upsertItem

public Mono> upsertItem(T item)

Upsert ein Element.

Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit dem hocherstierten Element. Im Falle eines Fehlers wird der Mono Fehler angezeigt.

Parameters:

item - das Element, das als POJO- oder Item-Objekt dargestellt wird, um upsert zu werden.

Returns:

eine Mono , die die Antwort einer einzelnen Ressource mit dem aktualisierten Element oder einem Fehler enthält.

upsertItem

public Mono> upsertItem(T item, CosmosItemRequestOptions options)

Upsert ein Element.

Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit dem hocherstierten Element. Im Falle eines Fehlers wird der Mono Fehler angezeigt.

Parameters:

item - das Element, das als POJO- oder Item-Objekt dargestellt wird, um upsert zu werden.
options - die Anforderungsoptionen.

Returns:

eine Mono , die die Antwort einer einzelnen Ressource mit dem aktualisierten Element oder einem Fehler enthält.

upsertItem

public Mono> upsertItem(T item, PartitionKey partitionKey, CosmosItemRequestOptions options)

Upsert ein Element.

Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit dem hocherstierten Element. Im Falle eines Fehlers wird der Mono Fehler angezeigt.

Parameters:

item - das Element, das als POJO- oder Item-Objekt dargestellt wird, um upsert zu werden.
partitionKey - der Partitionsschlüssel.
options - die Anforderungsoptionen.

Returns:

eine Mono , die die Antwort einer einzelnen Ressource mit dem aktualisierten Element oder einem Fehler enthält.

executeBulkOperations

public Flux> executeBulkOperations(Flux operations)

Führt den Fluss von Vorgängen in Bulk aus.

Parameters:

operations - Fluss des Vorgangs, der von diesem Container ausgeführt wird.

Returns:

Ein Flux von, dessen CosmosBulkOperationResponse<TContext> Vorgang und seine Antwort oder Ausnahme enthält. Verwenden CosmosBulkOperationsSie zum Erstellen eines Vorgangs, der hier ausgeführt werden kann. Beispiel: für einen Upsert-Vorgang verwenden com.azure.cosmos.models.CosmosBulkOperations#getUpsertItemOperation(Object, PartitionKey) Wir können den entsprechenden Vorgang mithilfe der getOperation() Antwort getResponse()abrufen. Wenn der Vorgang erfolgreich ausgeführt wurde, ist der von isSuccessStatusCode() zurückgegebene Wert true. Verwenden getStatusCode()Sie zum Abrufen der tatsächlichen status . Verwenden Sie zum Abrufen der Ausnahme, um zu überprüfen, getException() ob der Vorgang eine Ausnahme aufweist.

executeBulkOperations

public Flux> executeBulkOperations(Flux operations, CosmosBulkExecutionOptions bulkOptions)

Führt den Fluss von Vorgängen in Bulk aus.

Parameters:

operations - Fluss des Vorgangs, der von diesem Container ausgeführt wird.
bulkOptions - Optionen, die für diese Massenanforderung gelten, die Optionen für die Ausführung wie Parallelität, Batchgröße, Intervall und Kontext angibt.

Returns:

Ein Flux von, dessen CosmosBulkOperationResponse<TContext> Vorgang und seine Antwort oder Ausnahme enthält. Verwenden CosmosBulkOperationsSie zum Erstellen eines Vorgangs, der hier ausgeführt werden kann. Beispiel: für einen Upsert-Vorgang verwenden com.azure.cosmos.models.CosmosBulkOperations#getUpsertItemOperation(Object, PartitionKey) Wir können den entsprechenden Vorgang mithilfe der getOperation() Antwort getResponse()abrufen. Wenn der Vorgang erfolgreich ausgeführt wurde, ist der von isSuccessStatusCode() zurückgegebene Wert true. Verwenden getStatusCode()Sie zum Abrufen der tatsächlichen status . Verwenden Sie zum Abrufen der Ausnahme, um zu überprüfen, getException() ob der Vorgang eine Ausnahme aufweist.

delete

public Mono delete()

Löscht den aktuellen Container.

Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreicher Fertigstellung enthält eine einzelne Cosmos-Containerantwort für den gelöschten Container. Im Falle eines Fehlers wird der Mono Fehler angezeigt.

Returns:

eine Mono , die die einzelne Cosmos-Containerantwort für den gelöschten Container oder einen Fehler enthält.

delete

public Mono delete(CosmosContainerRequestOptions options)

Löscht den Container.

Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreicher Fertigstellung enthält eine einzelne Cosmos-Containerantwort für die gelöschte Datenbank. Im Falle eines Fehlers wird der Mono Fehler angezeigt.

Parameters:

options - die Anforderungsoptionen.

Returns:

eine Mono , die die einzelne Cosmos-Containerantwort für die gelöschte Datenbank oder einen Fehler enthält.

deleteAllItemsByPartitionKey

public Mono> deleteAllItemsByPartitionKey(PartitionKey partitionKey, CosmosItemRequestOptions options)

Löscht alle Elemente im Container mit dem angegebenen wert partitionKey. Startet einen asynchronen Cosmos DB-Hintergrundvorgang, der alle Elemente im Container mit dem angegebenen Wert löscht. Der asynchrone Cosmos DB-Hintergrundvorgang wird mit einem Prozentsatz der Benutzer-RUs ausgeführt.

Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreicher Fertigstellung enthält eine einzelne Cosmos-Elementantwort für alle gelöschten Elemente.

Parameters:

partitionKey - partitionKey des Elements.
options - die Anforderungsoptionen.

Returns:

eine Mono , die die Cosmos-Elementressourcenantwort enthält.

deleteItem

public Mono> deleteItem(String itemId, PartitionKey partitionKey)

Löscht ein Element.

Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreicher Fertigstellung enthält eine einzelne Cosmos-Elementantwort für das gelöschte Element.

cosmosAsyncContainer.deleteItem(
     passenger.getId(),
     new PartitionKey(passenger.getId())
 ).subscribe(response -> {
     System.out.println(response);
 }, throwable -> {
     CosmosException cosmosException = (CosmosException) throwable;
     cosmosException.printStackTrace();
 });

Parameters:

itemId - die Element-ID.
partitionKey - der Partitionsschlüssel.

Returns:

eine Mono , die die Cosmos-Elementressourcenantwort enthält.

deleteItem

public Mono> deleteItem(String itemId, PartitionKey partitionKey, CosmosItemRequestOptions options)

Löscht das Element.

Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreicher Fertigstellung enthält eine einzelne Cosmos-Elementantwort für das gelöschte Element.

Parameters:

itemId - id des Elements.
partitionKey - partitionKey des Elements.
options - die Anforderungsoptionen (Optional).

Returns:

eine Mono , die die Cosmos-Elementressourcenantwort enthält.

enableGlobalThroughputControlGroup

public void enableGlobalThroughputControlGroup(ThroughputControlGroupConfig groupConfig, GlobalThroughputControlConfig globalControlConfig)

Aktivieren Sie die Durchsatzsteuerungsgruppe mit dem globalen Steuerungsmodus. Das definierte Durchsatzlimit wird für verschiedene Clients freigegeben.

ThroughputControlGroupConfig groupConfig =
     new ThroughputControlGroupConfigBuilder()
         .groupName("localControlGroup")
         .targetThroughputThreshold(0.1)
         .build();

 GlobalThroughputControlConfig globalControlConfig =
     this.client.createGlobalThroughputControlConfigBuilder(database.getId(), container.getId())
         .setControlItemRenewInterval(Duration.ofSeconds(5))
         .setControlItemExpireInterval(Duration.ofSeconds(10))
         .build();

 container.enableGlobalThroughputControlGroup(groupConfig, globalControlConfig);

Parameters:

groupConfig - Die Konfiguration der Durchsatzsteuerungsgruppe finden Sie unter GlobalThroughputControlGroup.
globalControlConfig - Die Konfiguration der globalen Durchsatzsteuerung finden Sie unter GlobalThroughputControlConfig.

enableLocalThroughputControlGroup

public void enableLocalThroughputControlGroup(ThroughputControlGroupConfig groupConfig)

Aktivieren Sie die Durchsatzsteuerungsgruppe mit dem lokalen Steuerungsmodus.

ThroughputControlGroupConfig groupConfig =
     new ThroughputControlGroupConfigBuilder()
         .groupName("localControlGroup")
         .targetThroughputThreshold(0.1)
         .build();

 container.enableLocalThroughputControlGroup(groupConfig);

Parameters:

groupConfig - einen ThroughputControlGroupConfig

executeCosmosBatch

public Mono executeCosmosBatch(CosmosBatch cosmosBatch)

Führt den Transaktionsbatch aus.

Parameters:

cosmosBatch - Batch mit liste des Vorgangs und Partitionsschlüssels, die von diesem Container ausgeführt werden.

Returns:

Eine Mono-Antwort, die Details zur Ausführung des Transaktionsbatches enthält.

Wenn der Transaktionsbatch erfolgreich ausgeführt wird, wird der von für CosmosBatchResponse#getStatusCode die zurückgegebene Antwort zurückgegebene Wert auf 200} festgelegt.

Wenn ein Vorgang innerhalb des Transaktionsbatches während der Ausführung fehlschlägt, werden keine Änderungen des Batches committet, und die status des fehlerhaften Vorgangs wird von oder durch CosmosBatchResponse#getStatusCode die Ausnahme verfügbar gemacht. Um Informationen zu den Vorgängen abzurufen, die bei einem Benutzerfehler wie Konflikt, nicht gefunden usw. fehlgeschlagen sind, kann die Antwort aufgelistet werden. Dadurch werden Instanzen zurückgegeben CosmosBatchOperationResult , die den einzelnen Vorgängen im Transaktionsbatch in der Reihenfolge entsprechen, in der sie dem Transaktionsbatch hinzugefügt wurden. Verwenden Sie CosmosBatchOperationResult#getStatusCode für ein Ergebnis, das einem Vorgang innerhalb des Transaktionsbatches entspricht, um auf die status des Vorgangs zuzugreifen. Wenn der Vorgang nicht ausgeführt wurde oder aufgrund des Fehlers eines anderen Vorgangs im Transaktionsbatch abgebrochen wurde, ist der Wert dieses Felds 424; Für den Vorgang, der zum Abbrechen des Batches geführt hat, gibt der Wert dieses Felds die Fehlerursache an.

Wenn Probleme wie Anforderungstimeouts, Weg, Sitzung nicht verfügbar, Netzwerkfehler oder der Dienst irgendwie 5xx zurückgibt, gibt der Mono anstelle von CosmosBatchResponse den Fehler zurück.

Verwenden Sie CosmosBatchResponse#isSuccessStatusCode für die zurückgegebene Antwort, um sicherzustellen, dass der Transaktionsbatch erfolgreich war.

executeCosmosBatch

public Mono executeCosmosBatch(CosmosBatch cosmosBatch, CosmosBatchRequestOptions requestOptions)

Führt den Transaktionsbatch aus.

Parameters:

cosmosBatch - Batch mit liste des Vorgangs und Partitionsschlüssels, die von diesem Container ausgeführt werden.
requestOptions - Optionen, die speziell für Batchanforderungen gelten.

Returns:

Eine Mono-Antwort, die Details zur Ausführung des Transaktionsbatches enthält.

Wenn der Transaktionsbatch erfolgreich ausgeführt wird, wird der von für CosmosBatchResponse#getStatusCode die zurückgegebene Antwort zurückgegebene Wert auf 200} festgelegt.

Wenn ein Vorgang innerhalb des Transaktionsbatches während der Ausführung fehlschlägt, werden keine Änderungen des Batches committet, und die status des fehlerhaften Vorgangs wird von oder durch CosmosBatchResponse#getStatusCode die Ausnahme verfügbar gemacht. Um Informationen zu den Vorgängen abzurufen, die bei einem Benutzerfehler wie Konflikt, nicht gefunden usw. fehlgeschlagen sind, kann die Antwort aufgelistet werden. Dadurch werden Instanzen zurückgegeben CosmosBatchOperationResult , die den einzelnen Vorgängen im Transaktionsbatch in der Reihenfolge entsprechen, in der sie dem Transaktionsbatch hinzugefügt wurden. Verwenden Sie CosmosBatchOperationResult#getStatusCode für ein Ergebnis, das einem Vorgang innerhalb des Transaktionsbatches entspricht, um auf die status des Vorgangs zuzugreifen. Wenn der Vorgang nicht ausgeführt wurde oder aufgrund des Fehlers eines anderen Vorgangs im Transaktionsbatch abgebrochen wurde, ist der Wert dieses Felds 424; Für den Vorgang, der zum Abbrechen des Batches geführt hat, gibt der Wert dieses Felds die Fehlerursache an.

Wenn Probleme wie Anforderungstimeouts, Weg, Sitzung nicht verfügbar, Netzwerkfehler oder der Dienst irgendwie 5xx zurückgibt, gibt der Mono anstelle von CosmosBatchResponse den Fehler zurück.

Verwenden Sie CosmosBatchResponse#isSuccessStatusCode für die zurückgegebene Antwort, um sicherzustellen, dass der Transaktionsbatch erfolgreich war.

getConflict

public CosmosAsyncConflict getConflict(String id)

Ruft ein CosmosAsyncConflict Objekt ab, das den aktuellen Container als Kontext verwendet.

Parameters:

id - die ID des Cosmos-Konflikts.

Returns:

ein Cosmos-Konflikt.

getDatabase

public CosmosAsyncDatabase getDatabase()

Ruft das übergeordnete Element CosmosAsyncDatabase für den aktuellen Container ab.

Returns:

getFeedRanges

public Mono> getFeedRanges()

Ruft eine Liste von ab, die zum Parallelisieren von FeedRange Feedvorgängen verwendet werden kann.

cosmosAsyncContainer.getFeedRanges()
     .subscribe(feedRanges -> {
         for (FeedRange feedRange : feedRanges) {
             System.out.println("Feed range: " + feedRange);
         }
     });

Returns:

Eine nicht veränderbare Liste von FeedRange

getId

public String getId()

Rufen Sie die ID von ab CosmosAsyncContainer.

Returns:

getScripts

public CosmosAsyncScripts getScripts()

Ruft einen CosmosAsyncScripts ab, der den aktuellen Container als Kontext verwendet.

Dies kann weiter verwendet werden, um verschiedene Vorgänge in Cosmos-Skripts auszuführen.

Returns:

openConnectionsAndInitCaches

@Deprecated
public Mono openConnectionsAndInitCaches()

Als veraltet markiert

Am besten initialisieren Sie den Container, indem Sie die Caches und Verbindungen für den aktuellen Lesebereich aufwärmen.

Je nachdem, wie viele Partitionen der Container aufweist, ändert sich auch die gesamt benötigte Zeit. Im Allgemeinen können Sie jedoch die folgende Formel verwenden, um eine geschätzte Zeit zu erhalten: Wenn es 200 ms dauerte, eine Verbindung herzustellen, und Sie 100 Partitionen in Ihrem Container haben, dauert es ungefähr (100 * 4 / CPU-Kerne) * 200 ms, um alle Verbindungen nach dem Abrufen der Adressliste zu öffnen.

HINWEIS: Diese API sollte idealerweise nur einmal während der Anwendungsinitialisierung vor jeder Workload aufgerufen werden. Im Falle eines vorübergehenden Fehlers sollte der Aufrufer den Fehler nutzen und die reguläre Workload fortsetzen.

Returns:

Mono von Void.

openConnectionsAndInitCaches

@Deprecated
public Mono openConnectionsAndInitCaches(int numProactiveConnectionRegions)

Als veraltet markiert

Versuchen Sie, den Container zu initialisieren, indem Sie die Caches und Verbindungen mit einer angegebenen Anzahl von Regionen aus der liste der bevorzugten Regionen aufwärmen.

Je nachdem, wie viele Partitionen der Container aufweist, ändert sich auch die gesamt benötigte Zeit. Im Allgemeinen können Sie jedoch die folgende Formel verwenden, um eine geschätzte Zeit zu erhalten: Wenn es 200 ms dauerte, eine Verbindung herzustellen, und Sie 100 Partitionen in Ihrem Container haben, dauert es ungefähr (100 * 4 / (10 * CPUCores)) * 200 ms * RegionsWithProactiveConnections, um alle Verbindungen nach dem Abrufen der Adressliste zu öffnen.

HINWEIS: Diese API sollte idealerweise nur einmal während der Anwendungsinitialisierung vor jeder Workload aufgerufen werden. Im Falle eines vorübergehenden Fehlers sollte der Aufrufer den Fehler nutzen und die reguläre Workload fortsetzen.

Um Latenzen zu minimieren, die mit dem Aufwärmen von Caches und dem Öffnen von Verbindungen verbunden sind, darf die Anzahl der proaktiven Verbindungsregionen nicht größer als CosmosContainerProactiveInitConfigBuilder#MAX_NO_OF_PROACTIVE_CONNECTION_REGIONSsein.

Parameters:

numProactiveConnectionRegions - Die Anzahl der Regionen, mit der eine proaktive Verbindung hergestellt werden soll

Returns:

Mono von Void.

queryConflicts

public CosmosPagedFlux queryConflicts(String query)

Fragt alle Konflikte im aktuellen Container ab.

try {
     cosmosAsyncContainer.queryConflicts(query).
         byPage(100)
         .subscribe(response -> {
             for (CosmosConflictProperties conflictProperties : response.getResults()) {
                 System.out.println(conflictProperties);
             }
         }, throwable -> {
             throwable.printStackTrace();
         });
 } catch (CosmosException ce) {
     ce.printStackTrace();
 } catch (Exception e) {
     e.printStackTrace();
 }

Parameters:

query - die Abfrage.

Returns:

ein , CosmosPagedFlux<T> das eine oder mehrere Feedantwortseiten der erhaltenen Konflikte oder einen Fehler enthält.

queryConflicts

public CosmosPagedFlux queryConflicts(String query, CosmosQueryRequestOptions options)

Fragt alle Konflikte im aktuellen Container ab.

Parameters:

query - die Abfrage.
options - die Abfrageanforderungsoptionen (optional).

Returns:

ein , CosmosPagedFlux<T> das eine oder mehrere Feedantwortseiten der erhaltenen Konflikte oder einen Fehler enthält.

read

public Mono read()

Liest den aktuellen Container.

Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreichem Abschluss enthält eine einzelne Cosmos-Containerantwort mit dem Lesecontainer. Im Falle eines Fehlers wird der Mono fehler.

Returns:

eine Mono , die die einzelne Cosmos-Containerantwort mit dem Lesecontainer oder einem Fehler enthält.

read

public Mono read(CosmosContainerRequestOptions options)

Liest den aktuellen Container, während zusätzliche Optionen wie If-Match angegeben werden.

Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreichem Abschluss enthält eine einzelne Cosmos-Containerantwort mit dem Lesecontainer. Im Falle eines Fehlers wird der Mono fehler.

Parameters:

options - die Cosmos-Containeranforderungsoptionen.

Returns:

eine Mono , die die einzelne Cosmos-Containerantwort mit dem Lesecontainer oder einem Fehler enthält.

readAllConflicts

public CosmosPagedFlux readAllConflicts(CosmosQueryRequestOptions options)

Listet alle Konflikte im aktuellen Container auf.

try {
     cosmosAsyncContainer.readAllConflicts(options).
         byPage(100)
         .subscribe(response -> {
             for (CosmosConflictProperties conflictProperties : response.getResults()) {
                 System.out.println(conflictProperties);
             }
         }, throwable -> {
             throwable.printStackTrace();
         });
 } catch (CosmosException ce) {
     ce.printStackTrace();
 } catch (Exception e) {
     e.printStackTrace();
 }

Parameters:

options - Die Abfrageanforderungsoptionen

Returns:

ein , CosmosPagedFlux<T> das eine oder mehrere Feedantwortseiten der erhaltenen Konflikte oder einen Fehler enthält.

readThroughput

public Mono readThroughput()

Lesen Sie den für den aktuellen Container bereitgestellten Durchsatz.

Mono<ThroughputResponse> throughputResponseMono = cosmosAsyncContainer.readThroughput();
 throughputResponseMono.subscribe(throughputResponse -> {
     System.out.println(throughputResponse);
 }, throwable -> {
     throwable.printStackTrace();
 });

Returns:

das Mono mit der Antwort auf den Durchsatz.

replace

public Mono replace(CosmosContainerProperties containerProperties)

Ersetzt die Eigenschaften des aktuellen Containers.

Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreichem Abschluss enthält eine einzelne Cosmos-Containerantwort mit den ersetzten Containereigenschaften. Im Falle eines Fehlers wird der Mono fehler.

Parameters:

containerProperties - die Containereigenschaften

Returns:

eine Mono , die die einzelne Cosmos-Containerantwort mit den ersetzten Containereigenschaften oder einem Fehler enthält.

replace

public Mono replace(CosmosContainerProperties containerProperties, CosmosContainerRequestOptions options)

Ersetzt die aktuellen Containereigenschaften, während nicht standardmäßige Anforderungsoptionen verwendet werden.

Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreichem Abschluss enthält eine einzelne Cosmos-Containerantwort mit den ersetzten Containereigenschaften. Im Falle eines Fehlers wird der Mono fehler.

Parameters:

containerProperties - die Containereigenschaften
options - die Cosmos-Containeranforderungsoptionen.

Returns:

eine Mono , die die einzelne Cosmos-Containerantwort mit den ersetzten Containereigenschaften oder einem Fehler enthält.

replaceThroughput

public Mono replaceThroughput(ThroughputProperties throughputProperties)

Ersetzen Sie den Durchsatz.

ThroughputProperties throughputProperties =
     ThroughputProperties.createAutoscaledThroughput(1000);

 cosmosAsyncContainer.replaceThroughput(throughputProperties)
     .subscribe(throughputResponse -> {
             System.out.println(throughputResponse);
         },
         throwable -> {
             throwable.printStackTrace();
         });

Parameters:

throughputProperties - die Durchsatzeigenschaften.

Returns:

das Mono mit der Antwort auf den Durchsatz.

Gilt für: