Share via


CosmosBulkExecutionOptions Classe

  • java.lang.Object
    • com.azure.cosmos.models.CosmosBulkExecutionOptions

public final class CosmosBulkExecutionOptions

Encapsule les options qui peuvent être spécifiées pour les opérations utilisées dans l’exécution en bloc. Il peut être transmis lors du traitement des opérations en bloc.

Récapitulatif du constructeur

Constructeur Description
CosmosBulkExecutionOptions()

Constructeur

CosmosBulkExecutionOptions(CosmosBulkExecutionThresholdsState thresholdsState)

Constructeur

Résumé de la méthode

Modificateur et type Méthode et description
List<String> getExcludedRegions()

Obtient la liste des régions à exclure pour la demande/les nouvelles tentatives.

int getInitialMicroBatchSize()

Obtient la taille initiale des micro-lots qui seront envoyés au back-end.

int getMaxMicroBatchConcurrency()

Concurrence maximale pour l’exécution des demandes pour une plage de clés de partition.

CosmosBulkExecutionThresholdsState getThresholdsState()

Retourne l’état de seuil qui peut être passé à d’autres options d’exécutionen blocCosmosà l’avenir

String getThroughputControlGroupName()

Obtient le nom du groupe de contrôle de débit.

CosmosBulkExecutionOptions setExcludedRegions(List<String> excludeRegions)

Liste des régions à exclure pour la demande/les nouvelles tentatives.

CosmosBulkExecutionOptions setInitialMicroBatchSize(int initialMicroBatchSize)

Définit la taille initiale des micro-lots qui seront envoyés au back-end.

CosmosBulkExecutionOptions setMaxMicroBatchConcurrency(int maxMicroBatchConcurrency)

Définissez la concurrence maximale pour l’exécution des demandes pour une plage de clés de partition.

CosmosBulkExecutionOptions setThroughputControlGroupName(String throughputControlGroupName)

Définit le nom du groupe de contrôle de débit.

Méthodes héritées de java.lang.Object

Détails du constructeur

CosmosBulkExecutionOptions

public CosmosBulkExecutionOptions()

Constructeur

CosmosBulkExecutionOptions

public CosmosBulkExecutionOptions(CosmosBulkExecutionThresholdsState thresholdsState)

Constructeur

Parameters:

thresholdsState - seuils

Détails de la méthode

getExcludedRegions

public List getExcludedRegions()

Obtient la liste des régions à exclure pour la demande/les nouvelles tentatives. Ces régions sont exclues de la liste des régions par défaut.

Returns:

liste des régions exclues

getInitialMicroBatchSize

public int getInitialMicroBatchSize()

Obtient la taille initiale des micro-lots qui seront envoyés au back-end. La taille des micro-lots sera ajustée dynamiquement en fonction du taux de limitation. La valeur par défaut est 100. Par conséquent, elle commence par des micro-lots relativement volumineux et lorsque le taux de limitation est trop élevé, la taille du lot est réduite. Lorsque les brefs pics de limitation avant de réduire dynamiquement la taille du lot initial entraînent des effets secondaires pour d’autres charges de travail, la taille du micro-lot initial peut être réduite ( par exemple définie sur 1), à partir de laquelle elle commence avec de petits micro-lots, puis augmente la taille du lot au fil du temps.

Returns:

taille du micro-lot initial

getMaxMicroBatchConcurrency

public int getMaxMicroBatchConcurrency()

Concurrence maximale pour l’exécution des demandes pour une plage de clés de partition. Par défaut, la valeur maxMicroBatchConcurrency est 1.

Returns:

concurrence maximale des micro-lots

getThresholdsState

public CosmosBulkExecutionThresholdsState getThresholdsState()

Retourne l’état de seuil qui peut être transmis à d’autres CosmosBulkExecutionOptions à l’avenir

Returns:

seuils

getThroughputControlGroupName

public String getThroughputControlGroupName()

Obtient le nom du groupe de contrôle de débit.

Returns:

nom du groupe de contrôle de débit.

setExcludedRegions

public CosmosBulkExecutionOptions setExcludedRegions(List excludeRegions)

Liste des régions à exclure pour la demande/les nouvelles tentatives. Exemple « USA Est » ou « USA Est, USA Ouest » Ces régions seront exclues de la liste des régions préférées

Parameters:

excludeRegions - liste des régions

Returns:

setInitialMicroBatchSize

public CosmosBulkExecutionOptions setInitialMicroBatchSize(int initialMicroBatchSize)

Définit la taille initiale des micro-lots qui seront envoyés au back-end. La taille des micro-lots sera ajustée dynamiquement en fonction du taux de limitation. La valeur par défaut est 100. Par conséquent, elle commence par des micro-lots relativement volumineux et lorsque le taux de limitation est trop élevé, la taille du lot est réduite. Lorsque les brefs pics de limitation avant de réduire dynamiquement la taille du lot initial entraînent des effets secondaires pour d’autres charges de travail, la taille du micro-lot initial peut être réduite ( par exemple définie sur 1), à partir de laquelle elle commence avec de petits micro-lots, puis augmente la taille du lot au fil du temps.

Parameters:

initialMicroBatchSize - taille du micro-lot initial à utiliser. Cette valeur doit être un entier positif.

Returns:

les options d’exécution en bloc.

setMaxMicroBatchConcurrency

public CosmosBulkExecutionOptions setMaxMicroBatchConcurrency(int maxMicroBatchConcurrency)

Définissez la concurrence maximale pour l’exécution des demandes pour une plage de clés de partition. Par défaut, la valeur maxMicroBatchConcurrency est 1. Elle autorise uniquement les valeurs ?1 et ?5. Attention ! Ajustez cette valeur avec précaution. En augmentant cette valeur, davantage de demandes simultanées seront autorisées à être envoyées au serveur, auquel cas 429 ou la demande peut être retardée en raison de la saturation des ressources locales, ce qui pourrait dégrader les performances.

Parameters:

maxMicroBatchConcurrency - concurrence des micro-lots.

Returns:

les options de traitement en bloc.

setThroughputControlGroupName

public CosmosBulkExecutionOptions setThroughputControlGroupName(String throughputControlGroupName)

Définit le nom du groupe de contrôle de débit.

Parameters:

throughputControlGroupName - nom du groupe de contrôle de débit.

Returns:

CosmosBulkExecutionOptions.

S’applique à