CosmosAsyncContainer Classe
- java.
lang. Object - com.
azure. cosmos. CosmosAsyncContainer
- com.
public class CosmosAsyncContainer
Fournit des méthodes pour lire, supprimer et remplacer des conteneurs existants. Fournit des méthodes pour interagir avec les ressources enfants (éléments, scripts, conflits)
Résumé de la méthode
Méthodes héritées de java.lang.Object
Détails de la méthode
createItem
public Mono
Crée un élément.
Après l’abonnement, l’opération est effectuée. En Mono cas de réussite de l’exécution, le contient une seule réponse de ressource avec l’élément Cosmos créé. En cas d’échec, l’erreur Mono sera générée.
Parameters:
Returns:
createItem
public Mono
Crée un élément Cosmos.
Parameters:
Returns:
createItem
public Mono
Crée un élément.
Après l’abonnement, l’opération est effectuée. En Mono cas de réussite de l’exécution, le contient une seule réponse de ressource avec l’élément Cosmos créé. En cas d’échec, l’erreur Mono sera générée.
Parameters:
Returns:
deleteItem
public Mono
Supprime l’élément.
Après l’abonnement, l’opération est effectuée. En Mono cas de réussite de l’exécution, le contient une seule réponse d’élément Cosmos pour l’élément supprimé.
Parameters:
Returns:
patchItem
public Mono
Exécutez une mise à jour partielle qui modifie des propriétés ou des champs spécifiques de l’élément sans remplacer l’élément entier.
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();
});
Après l’abonnement, l’opération est effectuée. En Mono cas de réussite de l’exécution, le contient une seule réponse d’élément Cosmos avec l’élément corrigé.
Parameters:
Returns:
patchItem
public Mono
Exécutez une mise à jour partielle qui modifie des propriétés ou des champs spécifiques de l’élément sans remplacer l’élément entier.
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();
});
Après l’abonnement, l’opération est effectuée. En Mono cas de réussite de l’exécution, le contient une seule réponse d’élément Cosmos avec l’élément corrigé.
Parameters:
Returns:
queryChangeFeed
public CosmosPagedFlux
Recherchez des éléments dans le flux de modification du conteneur actuel à l’aide de 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();
Après l’abonnement, l’opération est effectuée. Contient Flux une ou plusieurs réponses de flux des éléments obtenus. En cas d’échec, l’erreur CosmosPagedFlux<T> sera générée.
Parameters:
Returns:
queryItems
public CosmosPagedFlux
Interrogez les éléments du conteneur actuel à l’aide d’un SqlQuerySpec et CosmosQueryRequestOptions.
Après l’abonnement, l’opération est effectuée. Contient Flux une ou plusieurs réponses de flux des éléments obtenus. En cas d’échec, l’erreur CosmosPagedFlux<T> sera générée.
Parameters:
Returns:
queryItems
public CosmosPagedFlux
Interrogez les éléments du conteneur actuel à l’aide d’un 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();
Après l’abonnement, l’opération est effectuée. Contient CosmosPagedFlux<T> une ou plusieurs réponses de flux des éléments obtenus. En cas d’échec, l’erreur CosmosPagedFlux<T> sera générée.
Parameters:
Returns:
queryItems
public CosmosPagedFlux
Recherchez les éléments du conteneur actuel à l’aide d’une chaîne.
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();
Après l’abonnement, l’opération est effectuée. Contient CosmosPagedFlux<T> une ou plusieurs réponses de flux des éléments obtenus. En cas d’échec, l’erreur CosmosPagedFlux<T> sera générée.
Parameters:
Returns:
queryItems
public CosmosPagedFlux
Recherchez des éléments dans le conteneur actuel.
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();
Après l’abonnement, l’opération est effectuée. Contient CosmosPagedFlux<T> une ou plusieurs réponses de flux des éléments obtenus. En cas d’échec, l’erreur CosmosPagedFlux<T> sera générée.
Parameters:
Returns:
readAllItems
public CosmosPagedFlux
Lit tous les éléments d’une partition logique
cosmosAsyncContainer
.readAllItems(new PartitionKey(partitionKey), Passenger.class)
.byPage(100)
.flatMap(passengerFeedResponse -> {
for (Passenger passenger : passengerFeedResponse.getResults()) {
System.out.println(passenger);
}
return Flux.empty();
})
.subscribe();
Après l’abonnement, l’opération est effectuée. le CosmosPagedFlux<T> contient une ou plusieurs réponses de flux des éléments Cosmos lus. En cas d’échec, l’erreur CosmosPagedFlux<T> sera générée.
Parameters:
Returns:
readAllItems
public CosmosPagedFlux
Lit tous les éléments d’une partition logique
cosmosAsyncContainer
.readAllItems(new PartitionKey(partitionKey), Passenger.class)
.byPage(100)
.flatMap(passengerFeedResponse -> {
for (Passenger passenger : passengerFeedResponse.getResults()) {
System.out.println(passenger);
}
return Flux.empty();
})
.subscribe();
Après l’abonnement, l’opération est effectuée. le CosmosPagedFlux<T> contient une ou plusieurs réponses de flux des éléments Cosmos lus. En cas d’échec, l’erreur CosmosPagedFlux<T> sera générée.
Parameters:
Returns:
readItem
public Mono
Lit un élément par itemId à l’aide d’un configuré CosmosItemRequestOptions. Cette opération permet de récupérer un seul élément d’un conteneur en fonction de son identificateur unique (ID) et de sa clé de partition. L’opération readItem fournit un accès direct à un élément spécifique à l’aide de son identificateur unique, qui se compose de l’ID de l’élément et de la valeur de clé de partition. Cette opération est efficace pour récupérer un élément connu par son ID et sa clé de partition sans qu’il soit nécessaire d’effectuer des requêtes complexes.
Après l’abonnement, l’opération est effectuée. En Mono cas de réussite de l’exécution, le contient une réponse d’élément Cosmos avec l’élément lu.
Parameters:
Returns:
readItem
public Mono
Lit un élément par itemId. Cette opération permet de récupérer un seul élément d’un conteneur en fonction de son identificateur unique (ID) et de sa clé de partition. L’opération readItem fournit un accès direct à un élément spécifique à l’aide de son identificateur unique, qui se compose de l’ID de l’élément et de la valeur de clé de partition. Cette opération est efficace pour récupérer un élément connu par son ID et sa clé de partition sans qu’il soit nécessaire d’effectuer des requêtes complexes.
Après l’abonnement, l’opération est effectuée. En Mono cas de réussite de l’exécution, le contient une réponse d’élément avec l’élément lu.
// 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:
Returns:
readMany
public Mono
Lit de nombreux documents. Utile pour lire de nombreux documents avec un ID et une clé de partition particuliers dans une seule requête. Si un document de la liste est manquant, aucune exception n’est levée.
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:
Returns:
readMany
public Mono
Lit de nombreux documents. Utile pour lire de nombreux documents avec un ID et une clé de partition particuliers dans une seule requête. Si un document de la liste est manquant, aucune exception n’est levée.
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:
Returns:
replaceItem
public Mono
Remplace un élément existant dans un conteneur par un nouvel élément. Il effectue un remplacement complet de l’élément, en remplaçant toutes ses propriétés par les propriétés du nouvel élément
cosmosAsyncContainer.replaceItem(
newPassenger,
oldPassenger.getId(),
new PartitionKey(oldPassenger.getId()),
new CosmosItemRequestOptions())
.subscribe(response -> {
System.out.println(response);
}, throwable -> {
throwable.printStackTrace();
});
Après l’abonnement, l’opération est effectuée. En Mono cas de réussite de l’exécution, le contient une seule réponse d’élément Cosmos avec l’élément remplacé.
Parameters:
Returns:
replaceItem
public Mono
Remplace un élément existant dans un conteneur par un nouvel élément. Il effectue un remplacement complet de l’élément, en remplaçant toutes ses propriétés par les propriétés du nouvel élément
cosmosAsyncContainer.replaceItem(
newPassenger,
oldPassenger.getId(),
new PartitionKey(oldPassenger.getId()),
new CosmosItemRequestOptions())
.subscribe(response -> {
System.out.println(response);
}, throwable -> {
throwable.printStackTrace();
});
Après l’abonnement, l’opération est effectuée. En Mono cas de réussite de l’exécution, le contient une seule réponse d’élément Cosmos avec l’élément remplacé.
Parameters:
Returns:
upsertItem
public Mono
Upserts un élément.
Après l’abonnement, l’opération est effectuée. En Mono cas de réussite de l’exécution, le contient une seule réponse de ressource avec l’élément upserted. En cas d’échec, l’erreur Mono sera générée.
Parameters:
Returns:
upsertItem
public Mono
Upserts un élément.
Après l’abonnement, l’opération est effectuée. En Mono cas de réussite de l’exécution, le contient une seule réponse de ressource avec l’élément upserted. En cas d’échec, l’erreur Mono sera générée.
Parameters:
Returns:
upsertItem
public Mono
Upserts un élément.
Après l’abonnement, l’opération est effectuée. En Mono cas de réussite de l’exécution, le contient une seule réponse de ressource avec l’élément upserted. En cas d’échec, l’erreur Mono sera générée.
Parameters:
Returns:
executeBulkOperations
public Flux
Exécute un flux d’opérations en bloc.
Parameters:
Returns:
executeBulkOperations
public Flux
Exécute le flux d’opérations en bloc.
Parameters:
Returns:
delete
public Mono
Supprime le conteneur actuel.
Après l’abonnement, l’opération est effectuée. Une Mono fois la saisie terminée, le contient une seule réponse de conteneur Cosmos pour le conteneur supprimé. En cas d’échec, l’erreur Mono will.
Returns:
delete
public Mono
Supprime le conteneur
Après l’abonnement, l’opération est effectuée. Une Mono fois la saisie terminée, le contient une seule réponse de conteneur Cosmos pour la base de données supprimée. En cas d’échec, l’erreur Mono will.
Parameters:
Returns:
deleteAllItemsByPartitionKey
public Mono
Supprime tous les éléments du conteneur avec la valeur partitionKey spécifiée. Démarre une opération asynchrone en arrière-plan Cosmos DB qui supprime tous les éléments du conteneur avec la valeur spécifiée. L’opération asynchrone en arrière-plan Cosmos DB s’exécute à l’aide d’un pourcentage d’unités de requête utilisateur.
Après l’abonnement, l’opération est effectuée. Une Mono fois la saisie terminée, le contient une seule réponse d’élément Cosmos pour tous les éléments supprimés.
Parameters:
Returns:
deleteItem
public Mono
Supprime un élément.
Après l’abonnement, l’opération est effectuée. Une Mono fois la saisie terminée, le contient une seule réponse d’élément Cosmos pour l’élément supprimé.
cosmosAsyncContainer.deleteItem(
passenger.getId(),
new PartitionKey(passenger.getId())
).subscribe(response -> {
System.out.println(response);
}, throwable -> {
CosmosException cosmosException = (CosmosException) throwable;
cosmosException.printStackTrace();
});
Parameters:
Returns:
deleteItem
public Mono
Supprime l’élément.
Après l’abonnement, l’opération est effectuée. Une Mono fois la saisie terminée, le contient une seule réponse d’élément Cosmos pour l’élément supprimé.
Parameters:
Returns:
enableGlobalThroughputControlGroup
public void enableGlobalThroughputControlGroup(ThroughputControlGroupConfig groupConfig, GlobalThroughputControlConfig globalControlConfig)
Activez le groupe de contrôle de débit avec le mode de contrôle global. La limite de débit définie sera partagée entre différents clients.
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:
enableLocalThroughputControlGroup
public void enableLocalThroughputControlGroup(ThroughputControlGroupConfig groupConfig)
Activez le groupe de contrôle de débit en mode de contrôle local.
ThroughputControlGroupConfig groupConfig =
new ThroughputControlGroupConfigBuilder()
.groupName("localControlGroup")
.targetThroughputThreshold(0.1)
.build();
container.enableLocalThroughputControlGroup(groupConfig);
Parameters:
executeCosmosBatch
public Mono
Exécute le lot transactionnel.
Parameters:
Returns:
Si le lot transactionnel s’exécute correctement, la valeur retournée par CosmosBatchResponse#getStatusCode sur la réponse retournée est définie sur 200}.
Si une opération dans le lot transactionnel échoue pendant l’exécution, aucune modification du lot n’est validée et la status de l’opération défaillante est rendue disponible par CosmosBatchResponse#getStatusCode ou par l’exception. Pour obtenir des informations sur les opérations qui ont échoué en cas d’erreur utilisateur comme un conflit, introuvable, etc., vous pouvez énumérer la réponse. Cela retourne CosmosBatchOperationResult des instances correspondant à chaque opération du lot transactionnel dans l’ordre dans lequel elles ont été ajoutées au lot transactionnel. Pour un résultat correspondant à une opération dans le lot transactionnel, utilisez CosmosBatchOperationResult#getStatusCode pour accéder au status de l’opération. Si l’opération n’a pas été exécutée ou si elle a été abandonnée en raison de l’échec d’une autre opération dans le lot transactionnel, la valeur de ce champ est 424 ; pour l’opération qui a provoqué l’abandon du lot, la valeur de ce champ indique la cause de l’échec.
S’il existe des problèmes tels que les délais d’expiration de la demande, la session non disponible, une défaillance réseau ou si le service retourne d’une manière ou d’une autre 5xx, le Mono retourne l’erreur au lieu de CosmosBatchResponse.
Utilisez CosmosBatchResponse#isSuccessStatusCode sur la réponse retournée pour vous assurer que le lot transactionnel a réussi.
executeCosmosBatch
public Mono
Exécute le lot transactionnel.
Parameters:
Returns:
Si le lot transactionnel s’exécute correctement, la valeur retournée par CosmosBatchResponse#getStatusCode sur la réponse retournée est définie sur 200}.
Si une opération dans le lot transactionnel échoue pendant l’exécution, aucune modification du lot n’est validée et la status de l’opération défaillante est rendue disponible par CosmosBatchResponse#getStatusCode ou par l’exception. Pour obtenir des informations sur les opérations qui ont échoué en cas d’erreur utilisateur comme un conflit, introuvable, etc., vous pouvez énumérer la réponse. Cela retourne CosmosBatchOperationResult des instances correspondant à chaque opération du lot transactionnel dans l’ordre dans lequel elles ont été ajoutées au lot transactionnel. Pour un résultat correspondant à une opération dans le lot transactionnel, utilisez CosmosBatchOperationResult#getStatusCode pour accéder au status de l’opération. Si l’opération n’a pas été exécutée ou si elle a été abandonnée en raison de l’échec d’une autre opération dans le lot transactionnel, la valeur de ce champ est 424 ; pour l’opération qui a provoqué l’abandon du lot, la valeur de ce champ indique la cause de l’échec.
S’il existe des problèmes tels que les délais d’expiration de la demande, la session non disponible, une défaillance réseau ou si le service retourne d’une manière ou d’une autre 5xx, le Mono retourne l’erreur au lieu de CosmosBatchResponse.
Utilisez CosmosBatchResponse#isSuccessStatusCode sur la réponse retournée pour vous assurer que le lot transactionnel a réussi.
getConflict
public CosmosAsyncConflict getConflict(String id)
Obtient un CosmosAsyncConflict objet à l’aide du conteneur actuel pour le contexte.
Parameters:
Returns:
getDatabase
public CosmosAsyncDatabase getDatabase()
Obtient le parent CosmosAsyncDatabase du conteneur actuel.
Returns:
getFeedRanges
public Mono
Obtient une liste de FeedRange qui peuvent être utilisées pour paralléliser les opérations de flux.
cosmosAsyncContainer.getFeedRanges()
.subscribe(feedRanges -> {
for (FeedRange feedRange : feedRanges) {
System.out.println("Feed range: " + feedRange);
}
});
Returns:
getId
getScripts
public CosmosAsyncScripts getScripts()
Obtient un CosmosAsyncScripts en utilisant le conteneur actuel comme contexte.
Cela peut être utilisé pour effectuer différentes opérations sur des scripts Cosmos.
Returns:
openConnectionsAndInitCaches
@Deprecated
public Mono
Déprécié
Meilleur effort pour initialiser le conteneur en réchauffant les caches et les connexions pour la région de lecture actuelle.
Selon le nombre de partitions dont dispose le conteneur, le temps total nécessaire change également. Mais en règle générale, vous pouvez utiliser la formule suivante pour obtenir une durée estimée : s’il a fallu 200 ms pour établir une connexion et que vous avez 100 partitions dans votre conteneur, il faudra environ (100 * 4 / CPUCores) * 200 ms pour ouvrir toutes les connexions après avoir obtenu la liste d’adresses
REMARQUE : dans l’idéal, cette API ne doit être appelée qu’une seule fois lors de l’initialisation de l’application avant toute charge de travail. En cas d’erreur temporaire, l’appelant doit consommer l’erreur et continuer la charge de travail régulière.
Returns:
openConnectionsAndInitCaches
@Deprecated
public Mono
Déprécié
Nous vous recommandons d’initialiser le conteneur en réchauffant les caches et les connexions à un nombre spécifié de régions à partir de la liste de régions par défaut.
Selon le nombre de partitions dont dispose le conteneur, le temps total nécessaire change également. Mais en règle générale, vous pouvez utiliser la formule suivante pour obtenir une durée estimée : s’il a fallu 200 ms pour établir une connexion et que vous avez 100 partitions dans votre conteneur, il faudra environ (100 * 4 / (10 * CPUCores)) * 200 ms * RegionsWithProactiveConnections pour ouvrir toutes les connexions après avoir obtenu la liste d’adresses
REMARQUE : dans l’idéal, cette API ne doit être appelée qu’une seule fois lors de l’initialisation de l’application avant toute charge de travail. En cas d’erreur temporaire, l’appelant doit consommer l’erreur et continuer la charge de travail régulière.
Afin de réduire les latences associées à l’échauffement des caches et à l’ouverture des connexions, le non des régions de connexion proactive ne peut pas être supérieur CosmosContainerProactiveInitConfigBuilder#MAX_NO_OF_PROACTIVE_CONNECTION_REGIONSà .
Parameters:
Returns:
queryConflicts
public CosmosPagedFlux
Interroge tous les conflits dans le conteneur actuel.
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:
Returns:
queryConflicts
public CosmosPagedFlux
Interroge tous les conflits dans le conteneur actuel.
Parameters:
Returns:
read
public Mono
Lit le conteneur actuel.
Après l’abonnement, l’opération est effectuée. Une Mono fois la saisie terminée, le contient une seule réponse de conteneur Cosmos avec le conteneur de lecture. En cas d’échec, l’erreur Mono will.
Returns:
read
public Mono
Lit le conteneur actuel tout en spécifiant des options supplémentaires telles que If-Match.
Après l’abonnement, l’opération est effectuée. Une Mono fois la saisie terminée, le contient une seule réponse de conteneur Cosmos avec le conteneur de lecture. En cas d’échec, l’erreur Mono will.
Parameters:
Returns:
readAllConflicts
public CosmosPagedFlux
Répertorie tous les conflits dans le conteneur actuel.
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:
Returns:
readThroughput
public Mono
Lisez le débit provisionné pour le conteneur actuel.
Mono<ThroughputResponse> throughputResponseMono = cosmosAsyncContainer.readThroughput();
throughputResponseMono.subscribe(throughputResponse -> {
System.out.println(throughputResponse);
}, throwable -> {
throwable.printStackTrace();
});
Returns:
replace
public Mono
Remplace les propriétés du conteneur actuel.
Après l’abonnement, l’opération est effectuée. Une Mono fois la saisie terminée, le contient une seule réponse de conteneur Cosmos avec les propriétés de conteneur remplacées. En cas d’échec, l’erreur Mono will.
Parameters:
Returns:
replace
public Mono
Remplace les propriétés de conteneur actuelles lors de l’utilisation d’options de requête autres que les options par défaut.
Après l’abonnement, l’opération est effectuée. Une Mono fois la saisie terminée, le contient une seule réponse de conteneur Cosmos avec les propriétés de conteneur remplacées. En cas d’échec, l’erreur Mono will.
Parameters:
Returns:
replaceThroughput
public Mono
Remplacez le débit.
ThroughputProperties throughputProperties =
ThroughputProperties.createAutoscaledThroughput(1000);
cosmosAsyncContainer.replaceThroughput(throughputProperties)
.subscribe(throughputResponse -> {
System.out.println(throughputResponse);
},
throwable -> {
throwable.printStackTrace();
});
Parameters:
Returns:
S’applique à
Azure SDK for Java