Java V2 Add the Bedrock Converse Java example

.doc_gen/metadata/bedrock-runtime_metadata.yaml

@@ -181,6 +181,22 @@ bedrock-runtime_Scenario_ToolUse:
   synopsis: "build a typical interaction between an application, a generative AI model, and connected tools or APIs to mediate interactions between the AI and the outside world. It uses the example of connecting an external weather API to the AI model so it can provide real-time weather information based on user input."
   category: Scenarios
   languages:
+    Java:
+      versions:
+        - sdk_version: 2
+          github: javav2/example_code/bedrock-runtime
+          excerpts:
+            - description: "The primary execution of the scenario flow. This scenario orchestrates the conversation between the user, the &BR; Converse API, and a weather tool."
+              snippet_tags:
+                - bedrock.converseTool.javav2.scenario
+            - description: "The weather tool used by the demo. This file defines the tool specification and implements the logic to retrieve weather data using from the Open-Meteo API."
+              genai: some
+              snippet_tags:
+                - bedrock.converseTool.javav2.weathertool
+            - description: "The Converse API action with a tool configuration."
+              genai: some
+              snippet_tags:
+                - bedrockruntime.java2.converse.main   
     .NET:
       versions:
         - sdk_version: 3
@@ -1468,6 +1484,22 @@ bedrock-runtime_Scenario_ToolUseDemo_AmazonNova:
   synopsis: "build a typical interaction between an application, a generative AI model, and connected tools or APIs to mediate interactions between the AI and the outside world. It uses the example of connecting an external weather API to the AI model so it can provide real-time weather information based on user input."
   category: Amazon Nova
   languages:
+    Java:
+      versions:
+        - sdk_version: 2
+          github: javav2/example_code/bedrock-runtime
+          excerpts:
+            - description: "The primary execution of the scenario flow. This scenario orchestrates the conversation between the user, the &BR; Converse API, and a weather tool."
+              snippet_tags:
+                - bedrock.converseTool.javav2.scenario
+            - description: "The weather tool used by the demo. This file defines the tool specification and implements the logic to retrieve weather data using from the Open-Meteo API."
+              genai: some
+              snippet_tags:
+                - bedrock.converseTool.javav2.weathertool
+            - description: "The Converse API action with a tool configuration."
+              genai: some
+              snippet_tags:
+                - bedrockruntime.java2.converse.main  
     .NET:
       versions:
         - sdk_version: 3

javav2/example_code/bedrock-runtime/pom.xml

@@ -41,6 +41,10 @@
             <groupId>software.amazon.awssdk</groupId>
             <artifactId>bedrockruntime</artifactId>
         </dependency>
+        <dependency>
+            <groupId>software.amazon.awssdk</groupId>
+            <artifactId>netty-nio-client</artifactId>
+        </dependency>
         <dependency>
             <groupId>software.amazon.awssdk</groupId>
             <artifactId>sts</artifactId>
@@ -65,6 +69,11 @@
             <artifactId>icu4j</artifactId>
             <version>75.1</version>
         </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-databind</artifactId>
+            <version>2.17.0</version> <!-- Replace with the latest stable version if needed -->
+        </dependency>
         <dependency>
             <groupId>org.junit.jupiter</groupId>
             <artifactId>junit-jupiter-api</artifactId>

javav2/example_code/bedrock-runtime/src/main/java/com/example/bedrockruntime/scenario/BedrockActions.java

@@ -0,0 +1,99 @@
+// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+// SPDX-License-Identifier: Apache-2.0
+
+package com.example.bedrockruntime.scenario;
+
+import software.amazon.awssdk.core.client.config.ClientOverrideConfiguration;
+import software.amazon.awssdk.core.retry.RetryMode;
+import software.amazon.awssdk.http.async.SdkAsyncHttpClient;
+import software.amazon.awssdk.http.nio.netty.NettyNioAsyncHttpClient;
+import software.amazon.awssdk.regions.Region;
+import software.amazon.awssdk.services.bedrockruntime.BedrockRuntimeAsyncClient;
+import software.amazon.awssdk.services.bedrockruntime.model.*;
+
+import java.time.Duration;
+import java.util.ArrayList;
+import java.util.List;
+
+public class BedrockActions {
+
+    private static volatile BedrockRuntimeAsyncClient bedrockRuntimeClient;
+
+    private BedrockRuntimeAsyncClient getClient() {
+        if (bedrockRuntimeClient == null) {
+         /*
+            The `NettyNioAsyncHttpClient` class is part of the AWS SDK for Java, version 2,
+            and it is designed to provide a high-performance, asynchronous HTTP client for interacting with AWS services.
+             It uses the Netty framework to handle the underlying network communication and the Java NIO API to
+             provide a non-blocking, event-driven approach to HTTP requests and responses.
+             */
+
+            SdkAsyncHttpClient httpClient = NettyNioAsyncHttpClient.builder()
+                .maxConcurrency(50)  // Adjust as needed.
+                .connectionTimeout(Duration.ofSeconds(60))  // Set the connection timeout.
+                .readTimeout(Duration.ofSeconds(60))  // Set the read timeout.
+                .writeTimeout(Duration.ofSeconds(60))  // Set the write timeout.
+                .build();
+
+            ClientOverrideConfiguration overrideConfig = ClientOverrideConfiguration.builder()
+                .apiCallTimeout(Duration.ofMinutes(2))  // Set the overall API call timeout.
+                .apiCallAttemptTimeout(Duration.ofSeconds(90))  // Set the individual call attempt timeout.
+                .retryStrategy(RetryMode.STANDARD)
+                .build();
+
+            bedrockRuntimeClient = BedrockRuntimeAsyncClient.builder()
+                .region(Region.US_EAST_1)
+                .httpClient(httpClient)
+                .overrideConfiguration(overrideConfig)
+                .build();
+        }
+        return bedrockRuntimeClient;
+    }
+
+    // snippet-start:[bedrockruntime.java2.converse.main]
+    /**
+     * Sends an asynchronous converse request to the AI model.
+     *
+     * @param modelId      the unique identifier of the AI model to be used for the converse request
+     * @param systemPrompt the system prompt to be included in the converse request
+     * @param conversation a list of messages representing the conversation history
+     * @param toolSpec     the specification of the tool to be used in the converse request
+     * @return the converse response received from the AI model
+     */
+    public ConverseResponse sendConverseRequestAsync(String modelId, String systemPrompt, List<Message> conversation, ToolSpecification toolSpec) {
+        List<Tool> toolList = new ArrayList<>();
+        Tool tool = Tool.builder()
+            .toolSpec(toolSpec)
+            .build();
+
+        toolList.add(tool);
+
+        ToolConfiguration configuration = ToolConfiguration.builder()
+            .tools(toolList)
+            .build();
+
+        SystemContentBlock block = SystemContentBlock.builder()
+            .text(systemPrompt)
+            .build();
+
+        ConverseRequest request = ConverseRequest.builder()
+            .modelId(modelId)
+            .system(block)
+            .messages(conversation)
+            .toolConfig(configuration)
+            .build();
+
+        try {
+            ConverseResponse response = getClient().converse(request).join();
+            return response;
+
+        } catch (ModelNotReadyException ex) {
+            throw new RuntimeException("Model is not ready: " + ex.getMessage(), ex);
+        } catch (BedrockRuntimeException ex) {
+            throw new RuntimeException("Failed to converse with Bedrock model: " + ex.getMessage(), ex);
+        }
+    }
+    // snippet-end:[bedrockruntime.java2.converse.main]
+}
+
+