CosmosAsyncContainer Clase
- java.
lang. Object - com.
azure. cosmos. CosmosAsyncContainer
- com.
public class CosmosAsyncContainer
Proporciona métodos para leer, eliminar y reemplazar contenedores existentes. Proporciona métodos para interactuar con recursos secundarios (elementos, scripts, conflictos)
Resumen del método
Métodos heredados de java.lang.Object
Detalles del método
createItem
public Mono
Crea un elemento.
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una única respuesta de recurso con el elemento de Cosmos creado. En caso de error, se producirá un Mono error.
Parameters:
Returns:
createItem
public Mono
Crea un elemento de Cosmos.
Parameters:
Returns:
createItem
public Mono
Crea un elemento.
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una única respuesta de recurso con el elemento de Cosmos creado. En caso de error, se producirá un Mono error.
Parameters:
Returns:
deleteItem
public Mono
Elimina el elemento.
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una única respuesta de elemento de Cosmos para el elemento eliminado.
Parameters:
Returns:
patchItem
public Mono
Ejecute una actualización parcial que modifique propiedades o campos específicos del elemento sin reemplazar todo el elemento.
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();
});
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una única respuesta de elemento de Cosmos con el elemento revisado.
Parameters:
Returns:
patchItem
public Mono
Ejecute una actualización parcial que modifique propiedades o campos específicos del elemento sin reemplazar todo el elemento.
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();
});
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una única respuesta de elemento de Cosmos con el elemento revisado.
Parameters:
Returns:
queryChangeFeed
public CosmosPagedFlux
Consulte los elementos de la fuente de cambios del contenedor actual mediante 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();
Después de la suscripción, se realizará la operación. Contendrá Flux una o varias respuestas de fuente de los elementos obtenidos. En caso de error, se producirá un CosmosPagedFlux<T> error.
Parameters:
Returns:
queryItems
public CosmosPagedFlux
Consulte los elementos del contenedor actual mediante y SqlQuerySpecCosmosQueryRequestOptions.
Después de la suscripción, se realizará la operación. Contendrá Flux una o varias respuestas de fuente de los elementos obtenidos. En caso de error, se producirá un CosmosPagedFlux<T> error.
Parameters:
Returns:
queryItems
public CosmosPagedFlux
Consulte los elementos del contenedor actual mediante .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();
Después de la suscripción, se realizará la operación. Contendrá CosmosPagedFlux<T> una o varias respuestas de fuente de los elementos obtenidos. En caso de error, se producirá un CosmosPagedFlux<T> error.
Parameters:
Returns:
queryItems
public CosmosPagedFlux
Consulte los elementos del contenedor actual mediante una cadena.
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();
Después de la suscripción, se realizará la operación. Contendrá CosmosPagedFlux<T> una o varias respuestas de fuente de los elementos obtenidos. En caso de error, se producirá un CosmosPagedFlux<T> error.
Parameters:
Returns:
queryItems
public CosmosPagedFlux
Consulte los elementos del contenedor actual.
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();
Después de la suscripción, se realizará la operación. Contendrá CosmosPagedFlux<T> una o varias respuestas de fuente de los elementos obtenidos. En caso de error, se producirá un CosmosPagedFlux<T> error.
Parameters:
Returns:
readAllItems
public CosmosPagedFlux
Lee todos los elementos de una partición lógica.
cosmosAsyncContainer
.readAllItems(new PartitionKey(partitionKey), Passenger.class)
.byPage(100)
.flatMap(passengerFeedResponse -> {
for (Passenger passenger : passengerFeedResponse.getResults()) {
System.out.println(passenger);
}
return Flux.empty();
})
.subscribe();
Después de la suscripción, se realizará la operación. CosmosPagedFlux<T> contendrá una o varias respuestas de fuente de los elementos de Cosmos de lectura. En caso de error, se producirá un CosmosPagedFlux<T> error.
Parameters:
Returns:
readAllItems
public CosmosPagedFlux
Lee todos los elementos de una partición lógica.
cosmosAsyncContainer
.readAllItems(new PartitionKey(partitionKey), Passenger.class)
.byPage(100)
.flatMap(passengerFeedResponse -> {
for (Passenger passenger : passengerFeedResponse.getResults()) {
System.out.println(passenger);
}
return Flux.empty();
})
.subscribe();
Después de la suscripción, se realizará la operación. CosmosPagedFlux<T> contendrá una o varias respuestas de fuente de los elementos de Cosmos de lectura. En caso de error, se producirá un CosmosPagedFlux<T> error.
Parameters:
Returns:
readItem
public Mono
Lee un elemento por itemId mediante un configurado CosmosItemRequestOptions. Esta operación se usa para recuperar un único elemento de un contenedor en función de su identificador único (ID) y clave de partición. La operación readItem proporciona acceso directo a un elemento específico mediante su identificador único, que consta del identificador del elemento y del valor de clave de partición. Esta operación es eficaz para recuperar un elemento conocido por su identificador y clave de partición sin necesidad de realizar consultas complejas.
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una respuesta de elemento de Cosmos con el elemento de lectura.
Parameters:
Returns:
readItem
public Mono
Lee un elemento por itemId. Esta operación se usa para recuperar un único elemento de un contenedor en función de su identificador único (ID) y clave de partición. La operación readItem proporciona acceso directo a un elemento específico mediante su identificador único, que consta del identificador del elemento y del valor de clave de partición. Esta operación es eficaz para recuperar un elemento conocido por su identificador y clave de partición sin necesidad de realizar consultas complejas.
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una respuesta de elemento con el elemento de lectura.
// 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
Lee muchos documentos. Resulta útil para leer muchos documentos con un identificador determinado y una clave de partición en una sola solicitud. Si falta algún documento de la lista, no se producirá ninguna excepción.
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
Lee muchos documentos. Resulta útil para leer muchos documentos con un identificador determinado y una clave de partición en una sola solicitud. Si falta algún documento de la lista, no se producirá ninguna excepción.
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
Reemplaza un elemento existente en un contenedor por un nuevo elemento. Realiza un reemplazo completo del elemento, reemplazando todas sus propiedades por las propiedades del nuevo elemento.
cosmosAsyncContainer.replaceItem(
newPassenger,
oldPassenger.getId(),
new PartitionKey(oldPassenger.getId()),
new CosmosItemRequestOptions())
.subscribe(response -> {
System.out.println(response);
}, throwable -> {
throwable.printStackTrace();
});
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una única respuesta de elemento de Cosmos con el elemento reemplazado.
Parameters:
Returns:
replaceItem
public Mono
Reemplaza un elemento existente en un contenedor por un nuevo elemento. Realiza un reemplazo completo del elemento, reemplazando todas sus propiedades por las propiedades del nuevo elemento.
cosmosAsyncContainer.replaceItem(
newPassenger,
oldPassenger.getId(),
new PartitionKey(oldPassenger.getId()),
new CosmosItemRequestOptions())
.subscribe(response -> {
System.out.println(response);
}, throwable -> {
throwable.printStackTrace();
});
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una única respuesta de elemento de Cosmos con el elemento reemplazado.
Parameters:
Returns:
upsertItem
public Mono
Upserts un elemento.
Después de la suscripción, se realizará la operación. Una Mono vez finalizada correctamente, contendrá una única respuesta de recurso con el elemento upserted. En caso de error, se producirá un Mono error.
Parameters:
Returns:
upsertItem
public Mono
Upserts un elemento.
Después de la suscripción, se realizará la operación. Una Mono vez finalizada correctamente, contendrá una única respuesta de recurso con el elemento upserted. En caso de error, se producirá un Mono error.
Parameters:
Returns:
upsertItem
public Mono
Upserts un elemento.
Después de la suscripción, se realizará la operación. Una Mono vez finalizada correctamente, contendrá una única respuesta de recurso con el elemento upserted. En caso de error, se producirá un Mono error.
Parameters:
Returns:
executeBulkOperations
public Flux
Ejecuta el flujo de operaciones en masa.
Parameters:
Returns:
executeBulkOperations
public Flux
Ejecuta el flujo de operaciones en masa.
Parameters:
Returns:
delete
public Mono
Elimina el contenedor actual.
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una única respuesta de contenedor de Cosmos para el contenedor eliminado. En caso de error, se producirá un Mono error.
Returns:
delete
public Mono
Elimina el contenedor.
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una única respuesta de contenedor de Cosmos para la base de datos eliminada. En caso de error, se producirá un Mono error.
Parameters:
Returns:
deleteAllItemsByPartitionKey
public Mono
Elimina todos los elementos del contenedor con el valor partitionKey especificado. Inicia una operación en segundo plano asincrónica de Cosmos DB que elimina todos los elementos del contenedor con el valor especificado. La operación en segundo plano asincrónica de Cosmos DB se ejecuta con un porcentaje de RU de usuario.
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una única respuesta de elemento de Cosmos para todos los elementos eliminados.
Parameters:
Returns:
deleteItem
public Mono
Elimina un elemento.
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una única respuesta de elemento de Cosmos para el elemento eliminado.
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
Elimina el elemento.
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una única respuesta de elemento de Cosmos para el elemento eliminado.
Parameters:
Returns:
enableGlobalThroughputControlGroup
public void enableGlobalThroughputControlGroup(ThroughputControlGroupConfig groupConfig, GlobalThroughputControlConfig globalControlConfig)
Habilite el grupo de control de rendimiento con el modo de control global. El límite de rendimiento definido se compartirá entre distintos clientes.
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)
Habilite el grupo de control de rendimiento con el modo de control local.
ThroughputControlGroupConfig groupConfig =
new ThroughputControlGroupConfigBuilder()
.groupName("localControlGroup")
.targetThroughputThreshold(0.1)
.build();
container.enableLocalThroughputControlGroup(groupConfig);
Parameters:
executeCosmosBatch
public Mono
Ejecuta el lote transaccional.
Parameters:
Returns:
Si el lote transaccional se ejecuta correctamente, el valor devuelto por CosmosBatchResponse#getStatusCode en la respuesta devuelta se establecerá en 200}.
Si se produce un error en una operación dentro del lote transaccional durante la ejecución, no se confirmará ningún cambio del lote y el estado de la operación con errores estará disponible por CosmosBatchResponse#getStatusCode o por la excepción. Para obtener información sobre las operaciones con errores en caso de algún error de usuario, como conflicto, no encontrado, etc., se puede enumerar la respuesta. Esto devuelve CosmosBatchOperationResult instancias correspondientes a cada operación del lote transaccional en el orden en que se agregaron al lote transaccional. Para obtener un resultado correspondiente a una operación dentro del lote transaccional, use CosmosBatchOperationResult#getStatusCode para acceder al estado de la operación. Si la operación no se ejecutó o se anuló debido al error de otra operación dentro del lote transaccional, el valor de este campo será 424; para la operación que provocó la anulación del lote, el valor de este campo indicará la causa del error.
Si hay problemas como los tiempos de espera de solicitud, Gone, session not available, network failure o if the service somehow returns 5xx then the Mono will return error instead of CosmosBatchResponse.
Use CosmosBatchResponse#isSuccessStatusCode en la respuesta devuelta para asegurarse de que el lote transaccional se realizó correctamente.
executeCosmosBatch
public Mono
Ejecuta el lote transaccional.
Parameters:
Returns:
Si el lote transaccional se ejecuta correctamente, el valor devuelto por CosmosBatchResponse#getStatusCode en la respuesta devuelta se establecerá en 200}.
Si se produce un error en una operación dentro del lote transaccional durante la ejecución, no se confirmará ningún cambio del lote y el estado de la operación con errores estará disponible por CosmosBatchResponse#getStatusCode o por la excepción. Para obtener información sobre las operaciones con errores en caso de algún error de usuario, como conflicto, no encontrado, etc., se puede enumerar la respuesta. Esto devuelve CosmosBatchOperationResult instancias correspondientes a cada operación del lote transaccional en el orden en que se agregaron al lote transaccional. Para obtener un resultado correspondiente a una operación dentro del lote transaccional, use CosmosBatchOperationResult#getStatusCode para acceder al estado de la operación. Si la operación no se ejecutó o se anuló debido al error de otra operación dentro del lote transaccional, el valor de este campo será 424; para la operación que provocó la anulación del lote, el valor de este campo indicará la causa del error.
Si hay problemas como los tiempos de espera de solicitud, Gone, session not available, network failure o if the service somehow returns 5xx then the Mono will return error instead of CosmosBatchResponse.
Use CosmosBatchResponse#isSuccessStatusCode en la respuesta devuelta para asegurarse de que el lote transaccional se realizó correctamente.
getConflict
public CosmosAsyncConflict getConflict(String id)
Obtiene un objeto mediante el CosmosAsyncConflict contenedor actual para el contexto.
Parameters:
Returns:
getDatabase
public CosmosAsyncDatabase getDatabase()
Obtiene el elemento primario CosmosAsyncDatabase del contenedor actual.
Returns:
getFeedRanges
public Mono
Obtiene una lista de FeedRange que se puede usar para paralelizar las operaciones de fuente.
cosmosAsyncContainer.getFeedRanges()
.subscribe(feedRanges -> {
for (FeedRange feedRange : feedRanges) {
System.out.println("Feed range: " + feedRange);
}
});
Returns:
getId
public String getId()
Obtenga el identificador de .CosmosAsyncContainer
Returns:
getScripts
public CosmosAsyncScripts getScripts()
Obtiene un CosmosAsyncScripts objeto que usa el contenedor actual como contexto.
Esto se puede usar aún más para realizar varias operaciones en scripts de Cosmos.
Returns:
openConnectionsAndInitCaches
@Deprecated
public Mono
Obsoleto
Mejor esfuerzo para inicializar el contenedor mediante el calentamiento de las memorias caché y las conexiones para la región de lectura actual.
Dependiendo de cuántas particiones tenga el contenedor, también cambiará el tiempo total necesario. Pero, por lo general, puede usar la fórmula siguiente para obtener un tiempo estimado: si tardó 200 ms en establecer una conexión y tiene 100 particiones en el contenedor, entonces tardará aproximadamente (100 * 4 / CPUCores) * 200 ms para abrir todas las conexiones después de obtener la lista de direcciones.
NOTA: Idealmente, se debe llamar a esta API solo una vez durante la inicialización de la aplicación antes de cualquier carga de trabajo. En caso de cualquier error transitorio, el autor de la llamada debe consumir el error y continuar con la carga de trabajo normal.
Returns:
openConnectionsAndInitCaches
@Deprecated
public Mono
Obsoleto
Mejor esfuerzo para inicializar el contenedor mediante el calentamiento de las memorias caché y las conexiones a un no. especificado de regiones de la lista preferida de regiones.
Dependiendo de cuántas particiones tenga el contenedor, también cambiará el tiempo total necesario. Pero generalmente puede usar la fórmula siguiente para obtener un tiempo estimado: si tardó 200 ms en establecer una conexión y tiene 100 particiones en el contenedor, entonces tardará aproximadamente (100 * 4 / (10 * CPUCores)) * 200 ms * RegionsWithProactiveConnections para abrir todas las conexiones después de obtener la lista de direcciones.
NOTA: Idealmente, se debe llamar a esta API solo una vez durante la inicialización de la aplicación antes de cualquier carga de trabajo. En caso de cualquier error transitorio, el autor de la llamada debe consumir el error y continuar con la carga de trabajo normal.
Para minimizar las latencias asociadas con el calentamiento de las memorias caché y la apertura de conexiones, el número de regiones de conexión proactivas no puede ser superior a CosmosContainerProactiveInitConfigBuilder#MAX_NO_OF_PROACTIVE_CONNECTION_REGIONS.
Parameters:
Returns:
queryConflicts
public CosmosPagedFlux
Consulta todos los conflictos del contenedor actual.
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
Consulta todos los conflictos del contenedor actual.
Parameters:
Returns:
read
public Mono
Lee el contenedor actual.
Después de la suscripción, se realizará la operación. Una Mono vez finalizada correctamente, contendrá una única respuesta de contenedor de Cosmos con el contenedor de lectura. En caso de error, se producirá un Mono error.
Returns:
read
public Mono
Lee el contenedor actual al especificar opciones adicionales, como If-Match.
Después de la suscripción, se realizará la operación. Una Mono vez finalizada correctamente, contendrá una única respuesta de contenedor de Cosmos con el contenedor de lectura. En caso de error, se producirá un Mono error.
Parameters:
Returns:
readAllConflicts
public CosmosPagedFlux
Enumera todos los conflictos del contenedor actual.
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
Lea el rendimiento aprovisionado para el contenedor actual.
Mono<ThroughputResponse> throughputResponseMono = cosmosAsyncContainer.readThroughput();
throughputResponseMono.subscribe(throughputResponse -> {
System.out.println(throughputResponse);
}, throwable -> {
throwable.printStackTrace();
});
Returns:
replace
public Mono
Reemplaza las propiedades del contenedor actual.
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una única respuesta de contenedor de Cosmos con las propiedades de contenedor reemplazadas. En caso de error, se producirá un Mono error.
Parameters:
Returns:
replace
public Mono
Reemplaza las propiedades de contenedor actuales mientras se usan opciones de solicitud no predeterminadas.
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una única respuesta de contenedor de Cosmos con las propiedades de contenedor reemplazadas. En caso de error, se producirá un Mono error.
Parameters:
Returns:
replaceThroughput
public Mono
Reemplace el rendimiento.
ThroughputProperties throughputProperties =
ThroughputProperties.createAutoscaledThroughput(1000);
cosmosAsyncContainer.replaceThroughput(throughputProperties)
.subscribe(throughputResponse -> {
System.out.println(throughputResponse);
},
throwable -> {
throwable.printStackTrace();
});
Parameters:
Returns:
Se aplica a
Azure SDK for Java