DynamoDB 拡張クライアント API を非同期的に使用する

DynamoDbEnhancedAsyncClient を構築するときは、次のスニペットに示すように、標準クライアントの非同期バージョン、DynamoDbAsyncClient を指定する必要があります。

 DynamoDbEnhancedAsyncClient enhancedClient = 
     DynamoDbEnhancedAsyncClient.builder()
                                .dynamoDbClient(dynamoDbAsyncClient)
                                .build();

1 つのデータオブジェクトを返すメソッドは、結果だけではなく結果の CompletableFuture を返します。そうすることで、アプリケーションは結果をブロックせずに他の処理を行うことができます。次のスニペットは、非同期 getItem() メソッドを示しています。

CompletableFuture<Customer> result = customerDynamoDbTable.getItem(customer);
// Perform other work here.
return result.join();   // Now block and wait for the result.

ページ分割された結果リストを返すメソッドは、同期 DynamoDbEnhanceClient が同じメソッドで返す SdkIterable の代わりに、SdkPublisher を返します。その後、アプリケーションはハンドラーをそのパブリッシャーにサブスクライブして、結果をブロックせずに非同期的に処理できます。

PagePublisher<Customer> results = customerDynamoDbTable.query(r -> r.queryConditional(keyEqualTo(k -> k.partitionValue("Smith"))));
results.subscribe(myCustomerResultsProcessor);
// Perform other work and let the processor handle the results asynchronously.

SdkPublisher API のより詳細な使用例については、このガイドの非同期 scan() メソッドについて説明しているセクションの例を参照してください。