how to use InvokeAgent?

[noday]

InvokeAgentRequest req = InvokeAgentRequest.builder()
				.agentId("")
				.agentAliasId("")
				.sessionId("")
				.inputText("who is jack ma")
				.build();
		BedrockAgentRuntimeAsyncClient client = BedrockAgentRuntimeAsyncClient.builder()
				.credentialsProvider(()-> AwsBasicCredentials.create("", ""))
				.region(Region.US_EAST_1)
				.build();

how to get the answer, can not find example code.

[debora-ito]

Check the Bedrock code examples in our Developer Guide here:

https://docs.aws.amazon.com/sdk-for-java/latest/developer-guide/java_bedrock-runtime_code_examples.html

[noday]

thanks

[noday]

        /**
         * Invokes the Anthropic Claude 2 model and processes the response stream.
         *
         * @param prompt The prompt for Claude to complete.
         * @param silent Suppress console output of the individual response stream
         *               chunks.
         * @return The generated response.
         */
        public static String invokeClaude(String prompt, boolean silent) {

                BedrockRuntimeAsyncClient client = BedrockRuntimeAsyncClient.builder()
                                .region(Region.US_EAST_1)
                                .credentialsProvider(ProfileCredentialsProvider.create())
                                .build();

                var finalCompletion = new AtomicReference<>("");

                var payload = new JSONObject()
                                .put("prompt", "Human: " + prompt + " Assistant:")
                                .put("temperature", 0.8)
                                .put("max_tokens_to_sample", 300)
                                .toString();

                var request = InvokeModelWithResponseStreamRequest.builder()
                                .body(SdkBytes.fromUtf8String(payload))
                                .modelId("anthropic.claude-v2")
                                .contentType("application/json")
                                .accept("application/json")
                                .build();

                var visitor = InvokeModelWithResponseStreamResponseHandler.Visitor.builder()
                                .onChunk(chunk -> {
                                        var json = new JSONObject(chunk.bytes().asUtf8String());
                                        var completion = json.getString("completion");
                                        finalCompletion.set(finalCompletion.get() + completion);
                                        if (!silent) {
                                                System.out.print(completion);
                                        }
                                })
                                .build();

                var handler = InvokeModelWithResponseStreamResponseHandler.builder()
                                .onEventStream(stream -> stream.subscribe(event -> event.accept(visitor)))
                                .onComplete(() -> {
                                })
                                .onError(e -> System.out.println("\n\nError: " + e.getMessage()))
                                .build();

                client.invokeModelWithResponseStream(request, handler).join();

                return finalCompletion.get();
        }

[MouQing]

do you have any way to invoke BedrockAgentRuntimeAsyncClient and get output in response