CosmosAsyncContainer クラス
- java.
lang. Object - com.
azure. cosmos. CosmosAsyncContainer
- com.
public class CosmosAsyncContainer
既存のコンテナーの読み取り、削除、置換を行うメソッドを提供します。 子リソース (項目、スクリプト、競合) と対話するためのメソッドを提供します
メソッドの概要
メソッドの継承元: java.lang.Object
メソッドの詳細
createItem
public Mono<>
項目を作成します。
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、作成された Cosmos アイテムを含む 1 つのリソース応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
Parameters:
Returns:
createItem
public Mono<>
Cosmos アイテムを作成します。
Parameters:
Returns:
createItem
public Mono<>
項目を作成します。
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、作成された Cosmos アイテムを含む 1 つのリソース応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
Parameters:
Returns:
deleteItem
public Mono<>
アイテムを削除します。
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、削除されたアイテムに対する 1 つの Cosmos アイテム応答が含まれます。
Parameters:
Returns:
patchItem
public Mono<>
アイテム全体を置き換えることなく、アイテムの特定のプロパティまたはフィールドを変更する部分更新を実行します。
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();
});
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、修正プログラムが適用された項目を含む 1 つの Cosmos 項目応答が含まれます。
Parameters:
Returns:
patchItem
public Mono<>
アイテム全体を置き換えることなく、アイテムの特定のプロパティまたはフィールドを変更する部分更新を実行します。
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();
});
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、修正プログラムが適用された項目を含む 1 つの Cosmos 項目応答が含まれます。
Parameters:
Returns:
queryChangeFeed
public CosmosPagedFlux
を使用して、現在のコンテナーの変更フィード内の項目を照会します 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();
サブスクリプションが完了すると、操作が実行されます。 には Flux 、取得した項目の 1 つまたは複数のフィード応答が含まれます。 エラーが発生した場合は、 CosmosPagedFlux<T> がエラーになります。
Parameters:
Returns:
queryItems
public CosmosPagedFlux
と CosmosQueryRequestOptionsを使用して、現在のコンテナー内の項目のクエリをSqlQuerySpec実行します。
サブスクリプションが完了すると、操作が実行されます。 には Flux 、取得した項目の 1 つまたは複数のフィード応答が含まれます。 エラーが発生した場合は、 CosmosPagedFlux<T> がエラーになります。
Parameters:
Returns:
queryItems
public CosmosPagedFlux
を使用して、現在のコンテナー内の項目のクエリを 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();
サブスクリプションが完了すると、操作が実行されます。 には CosmosPagedFlux<T> 、取得した項目の 1 つまたは複数のフィード応答が含まれます。 エラーが発生した場合は、 CosmosPagedFlux<T> がエラーになります。
Parameters:
Returns:
queryItems
public CosmosPagedFlux
文字列を使用して、現在のコンテナー内の項目のクエリを実行します。
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();
サブスクリプションが完了すると、操作が実行されます。 には CosmosPagedFlux<T> 、取得した項目の 1 つまたは複数のフィード応答が含まれます。 エラーが発生した場合は、 CosmosPagedFlux<T> がエラーになります。
Parameters:
Returns:
queryItems
public CosmosPagedFlux
現在のコンテナー内の項目のクエリを実行します。
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();
サブスクリプションが完了すると、操作が実行されます。 には CosmosPagedFlux<T> 、取得した項目の 1 つまたは複数のフィード応答が含まれます。 エラーが発生した場合は、 CosmosPagedFlux<T> がエラーになります。
Parameters:
Returns:
readAllItems
public CosmosPagedFlux
論理パーティションのすべての項目を読み取ります
cosmosAsyncContainer
.readAllItems(new PartitionKey(partitionKey), Passenger.class)
.byPage(100)
.flatMap(passengerFeedResponse -> {
for (Passenger passenger : passengerFeedResponse.getResults()) {
System.out.println(passenger);
}
return Flux.empty();
})
.subscribe();
サブスクリプションが完了すると、操作が実行されます。 には CosmosPagedFlux<T> 、読み取られた Cosmos アイテムの 1 つまたは複数のフィード応答が含まれます。 エラーが発生した場合は、 CosmosPagedFlux<T> がエラーになります。
Parameters:
Returns:
readAllItems
public CosmosPagedFlux
論理パーティションのすべての項目を読み取ります
cosmosAsyncContainer
.readAllItems(new PartitionKey(partitionKey), Passenger.class)
.byPage(100)
.flatMap(passengerFeedResponse -> {
for (Passenger passenger : passengerFeedResponse.getResults()) {
System.out.println(passenger);
}
return Flux.empty();
})
.subscribe();
サブスクリプションが完了すると、操作が実行されます。 には CosmosPagedFlux<T> 、読み取られた Cosmos アイテムの 1 つまたは複数のフィード応答が含まれます。 エラーが発生した場合は、 CosmosPagedFlux<T> がエラーになります。
Parameters:
Returns:
readItem
public Mono<>
構成された CosmosItemRequestOptionsを使用して itemId で項目を読み取ります。 この操作は、一意識別子 (ID) とパーティション キーに基づいてコンテナーから 1 つの項目を取得するために使用されます。 readItem 操作では、項目の ID とパーティション キー値で構成される一意識別子を使用して、特定の項目に直接アクセスできます。 この操作は、複雑なクエリを実行することなく、ID とパーティション キーによって既知の項目を取得する場合に効率的です。
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、読み取り項目を含む Cosmos 項目の応答が含まれます。
Parameters:
Returns:
readItem
public Mono<>
itemId で項目を読み取ります。 この操作は、一意識別子 (ID) とパーティション キーに基づいてコンテナーから 1 つの項目を取得するために使用されます。 readItem 操作では、項目の ID とパーティション キー値で構成される一意識別子を使用して、特定の項目に直接アクセスできます。 この操作は、複雑なクエリを実行することなく、ID とパーティション キーによって既知の項目を取得する場合に効率的です。
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、読み取り項目を含む項目の応答が含まれます。
// 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<>
多くのドキュメントを読み取ります。 1 つの要求で特定の ID とパーティション キーを持つ多くのドキュメントを読み取る場合に便利です。 リストのドキュメントが見つからない場合、例外はスローされません。
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<>
多くのドキュメントを読み取ります。 1 つの要求で特定の ID とパーティション キーを持つ多くのドキュメントを読み取る場合に便利です。 リストのドキュメントが見つからない場合、例外はスローされません。
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<>
コンテナー内の既存の項目を新しい項目に置き換えます。 項目の完全な置換が実行され、そのすべてのプロパティが新しい項目のプロパティに置き換えられます。
cosmosAsyncContainer.replaceItem(
newPassenger,
oldPassenger.getId(),
new PartitionKey(oldPassenger.getId()),
new CosmosItemRequestOptions())
.subscribe(response -> {
System.out.println(response);
}, throwable -> {
throwable.printStackTrace();
});
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、置換された項目を含む 1 つの Cosmos 項目応答が含まれます。
Parameters:
Returns:
replaceItem
public Mono<>
コンテナー内の既存の項目を新しい項目に置き換えます。 項目の完全な置換が実行され、そのすべてのプロパティが新しい項目のプロパティに置き換えられます。
cosmosAsyncContainer.replaceItem(
newPassenger,
oldPassenger.getId(),
new PartitionKey(oldPassenger.getId()),
new CosmosItemRequestOptions())
.subscribe(response -> {
System.out.println(response);
}, throwable -> {
throwable.printStackTrace();
});
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、置換された項目を含む 1 つの Cosmos 項目応答が含まれます。
Parameters:
Returns:
upsertItem
public Mono<>
アイテムをアップサートします。
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、アップサートされた項目を含む 1 つのリソース応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
Parameters:
Returns:
upsertItem
public Mono<>
アイテムをアップサートします。
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、アップサートされた項目を含む 1 つのリソース応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
Parameters:
Returns:
upsertItem
public Mono<>
アイテムをアップサートします。
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、アップサートされた項目を含む 1 つのリソース応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
Parameters:
Returns:
executeBulkOperations
public Flux<>
一括操作の Flux を実行します。
Parameters:
Returns:
executeBulkOperations
public Flux<>
一括操作の Flux を実行します。
Parameters:
Returns:
delete
public Mono
現在のコンテナーを削除します。
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、削除されたコンテナーに対する 1 つの Cosmos コンテナー応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
Returns:
delete
public Mono
コンテナーを削除します
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、削除されたデータベースに対する 1 つの Cosmos コンテナー応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
Parameters:
Returns:
deleteAllItemsByPartitionKey
public Mono<>
指定した partitionKey 値を持つコンテナー内のすべての項目を削除します。 指定した値を持つコンテナー内のすべての項目を削除する非同期 Cosmos DB バックグラウンド操作を開始します。 非同期 Cosmos DB バックグラウンド操作は、ユーザー RU の割合を使用して実行されます。
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、削除されたすべてのアイテムに対する 1 つの Cosmos アイテム応答が含まれます。
Parameters:
Returns:
deleteItem
public Mono<>
アイテムを削除します。
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、削除されたアイテムに対する 1 つの Cosmos アイテム応答が含まれます。
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<>
アイテムを削除します。
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、削除されたアイテムに対する 1 つの Cosmos アイテム応答が含まれます。
Parameters:
Returns:
enableGlobalThroughputControlGroup
public void enableGlobalThroughputControlGroup(ThroughputControlGroupConfig groupConfig, GlobalThroughputControlConfig globalControlConfig)
グローバル制御モードでスループット制御グループを有効にします。 定義されたスループット制限は、異なるクライアント間で共有されます。
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)
ローカル制御モードでスループット制御グループを有効にします。
ThroughputControlGroupConfig groupConfig =
new ThroughputControlGroupConfigBuilder()
.groupName("localControlGroup")
.targetThroughputThreshold(0.1)
.build();
container.enableLocalThroughputControlGroup(groupConfig);
Parameters:
executeCosmosBatch
public Mono
トランザクション バッチを実行します。
Parameters:
Returns:
トランザクション バッチが正常に実行された場合、返される応答で によって CosmosBatchResponse#getStatusCode 返される値は 200} に設定されます。
実行中にトランザクション バッチ内の操作が失敗した場合、バッチからの変更はコミットされません。失敗した操作の状態は、例外によってまたは例外によって CosmosBatchResponse#getStatusCode 使用可能になります。 競合、見つからないなどのユーザー エラーが発生した場合に失敗した操作に関する情報を取得するには、応答を列挙できます。 これにより、トランザクション バッチ内の CosmosBatchOperationResult 各操作に対応するインスタンスが、トランザクション バッチに追加された順序で返されます。 トランザクション バッチ内の操作に対応する結果の場合は、 を使用 CosmosBatchOperationResult#getStatusCode して操作の状態にアクセスします。 操作が実行されなかったか、トランザクション バッチ内の別の操作が失敗したために中止された場合、このフィールドの値は 424 になります。バッチが中止される原因となった操作の場合、このフィールドの値はエラーの原因を示します。
要求タイムアウト、ゴーン、セッションが使用できない、ネットワークエラーなどの問題がある場合、またはサービスが何らかの方法で 5xx を返した場合、Mono は CosmosBatchResponse の代わりにエラーを返します。
返された応答で を使用 CosmosBatchResponse#isSuccessStatusCode して、トランザクション バッチが成功したことを確認します。
executeCosmosBatch
public Mono
トランザクション バッチを実行します。
Parameters:
Returns:
トランザクション バッチが正常に実行された場合、返される応答で によって CosmosBatchResponse#getStatusCode 返される値は 200} に設定されます。
実行中にトランザクション バッチ内の操作が失敗した場合、バッチからの変更はコミットされません。失敗した操作の状態は、例外によってまたは例外によって CosmosBatchResponse#getStatusCode 使用可能になります。 競合、見つからないなどのユーザー エラーが発生した場合に失敗した操作に関する情報を取得するには、応答を列挙できます。 これにより、トランザクション バッチ内の CosmosBatchOperationResult 各操作に対応するインスタンスが、トランザクション バッチに追加された順序で返されます。 トランザクション バッチ内の操作に対応する結果の場合は、 を使用 CosmosBatchOperationResult#getStatusCode して操作の状態にアクセスします。 操作が実行されなかったか、トランザクション バッチ内の別の操作が失敗したために中止された場合、このフィールドの値は 424 になります。バッチが中止される原因となった操作の場合、このフィールドの値はエラーの原因を示します。
要求タイムアウト、ゴーン、セッションが使用できない、ネットワークエラーなどの問題がある場合、またはサービスが何らかの方法で 5xx を返した場合、Mono は CosmosBatchResponse の代わりにエラーを返します。
返された応答で を使用 CosmosBatchResponse#isSuccessStatusCode して、トランザクション バッチが成功したことを確認します。
getConflict
public CosmosAsyncConflict getConflict(String id)
コンテキストに現在の CosmosAsyncConflict コンテナーを使用して オブジェクトを取得します。
Parameters:
Returns:
getDatabase
getFeedRanges
getId
getScripts
public CosmosAsyncScripts getScripts()
現在のコンテナーをコンテキストとして使用して を CosmosAsyncScripts 取得します。
これをさらに使用して、Cosmos スクリプトに対してさまざまな操作を実行できます。
Returns:
openConnectionsAndInitCaches
@Deprecated
public Mono
非推奨
現在の読み取りリージョンのキャッシュと接続をウォームアップしてコンテナーを初期化するためのベスト エフォート。
コンテナーに含まれるパーティションの数に応じて、必要な合計時間も変わります。 ただし、一般に、次の式を使用して推定時間を取得できます。接続を確立するのに 200 ミリ秒かかり、コンテナーに 100 個のパーティションがある場合は、約 (100 * 4 / CPUCores) * 200 ミリ秒でアドレス一覧を取得した後にすべての接続を開くことができます
注: この API は、ワークロードの前にアプリケーションの初期化中に 1 回だけ呼び出すのが理想的です。 一時的なエラーが発生した場合、呼び出し元はエラーを使用し、通常のワークロードを続行する必要があります。
Returns:
openConnectionsAndInitCaches
@Deprecated
public Mono
非推奨
推奨されるリージョンの一覧から指定したリージョンの no. にキャッシュと接続をウォームアップして、コンテナーを初期化するためのベスト エフォート。
コンテナーに含まれるパーティションの数に応じて、必要な合計時間も変わります。 ただし、一般に、次の式を使用して推定時間を取得できます。接続を確立するのに 200 ミリ秒かかり、コンテナーに 100 個のパーティションがある場合は、(100 * 4 / (10 * CPUCores)) * 200ms * RegionsWithProactiveConnections を使用して、アドレス一覧を取得した後にすべての接続を開きます。
注: この API は、ワークロードの前にアプリケーションの初期化中に 1 回だけ呼び出すのが理想的です。 一時的なエラーが発生した場合、呼び出し元はエラーを使用し、通常のワークロードを続行する必要があります。
キャッシュのウォームアップと接続のオープンに関連する待機時間を最小限に抑えるために、プロアクティブ接続リージョンの no. を 以下 CosmosContainerProactiveInitConfigBuilder#MAX_NO_OF_PROACTIVE_CONNECTION_REGIONSにすることはできません。
Parameters:
Returns:
queryConflicts
public CosmosPagedFlux
現在のコンテナー内のすべての競合を照会します。
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
現在のコンテナー内のすべての競合を照会します。
Parameters:
Returns:
read
public Mono
現在のコンテナーを読み取ります。
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、読み取りコンテナーを含む 1 つの Cosmos コンテナー応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
Returns:
read
public Mono
If-Match などの追加オプションを指定しながら、現在のコンテナーを読み取ります。
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、読み取りコンテナーを含む 1 つの Cosmos コンテナー応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
Parameters:
Returns:
readAllConflicts
public CosmosPagedFlux
現在のコンテナー内のすべての競合を一覧表示します。
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
現在のコンテナーにプロビジョニングされたスループットを読み取ります。
Mono<ThroughputResponse> throughputResponseMono = cosmosAsyncContainer.readThroughput();
throughputResponseMono.subscribe(throughputResponse -> {
System.out.println(throughputResponse);
}, throwable -> {
throwable.printStackTrace();
});
Returns:
replace
public Mono
現在のコンテナーのプロパティを置き換えます。
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、置き換えられたコンテナー プロパティを含む 1 つの Cosmos コンテナー応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
Parameters:
Returns:
replace
public Mono
既定以外の要求オプションを使用しているときに、現在のコンテナーのプロパティを置き換えます。
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、置き換えられたコンテナー プロパティを含む 1 つの Cosmos コンテナー応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
Parameters:
Returns:
replaceThroughput
public Mono
スループットを置き換えます。
ThroughputProperties throughputProperties =
ThroughputProperties.createAutoscaledThroughput(1000);
cosmosAsyncContainer.replaceThroughput(throughputProperties)
.subscribe(throughputResponse -> {
System.out.println(throughputResponse);
},
throwable -> {
throwable.printStackTrace();
});
Parameters:
Returns:
適用対象
Azure SDK for Java
フィードバック
以下は間もなく提供いたします。2024 年を通じて、コンテンツのフィードバック メカニズムとして GitHub の issue を段階的に廃止し、新しいフィードバック システムに置き換えます。 詳細については、「https://aka.ms/ContentUserFeedback」を参照してください。
フィードバックの送信と表示