-
Notifications
You must be signed in to change notification settings - Fork 21
Description
Conversation is deprecated , and QWenConversationParam is removed. Please update your doc as follows
## QuickStart
### Conversation
You can create a conversation client simply by:
```java
// Use http as the network protocol.
Generation generation = new Generation();
This interface also accept a protocol argument:
import com.alibaba.dashscope.common.Protocol;
Generation generation = new Generation(Protocol.HTTP.getValue());
Generation generation = new Generation(Protocol.WEBSOCKET.getValue());The generation interface supports both stream and non-stream queries. These queries all accept GenerationParam as input, and returns GenerationResult as output . Each model has a unique input structure and output structure which derives from the two data classes mentioned above. Please use these sub classes when you are using the coordinating model.
Here shows the usages of each method, with the examples of qwen-turbo model.
Support stream and non-stream mode, accept output from callback
import com.alibaba.dashscope.aigc.generation.Generation;
import com.alibaba.dashscope.aigc.generation.GenerationParam;
import com.alibaba.dashscope.aigc.generation.GenerationResult;
import com.alibaba.dashscope.common.Message;
import com.alibaba.dashscope.common.ResultCallback;
import com.alibaba.dashscope.common.Role;
import com.alibaba.dashscope.exception.ApiException;
import com.alibaba.dashscope.exception.InputRequiredException;
import com.alibaba.dashscope.exception.NoApiKeyException;
import com.alibaba.dashscope.utils.JsonUtils;
import java.util.Arrays;
public class Main {
public static void main(String[] args) {
Generation generation = new Generation();
GenerationParam param = GenerationParam.builder()
.apiKey(System.getenv("DASHSCOPE_API_KEY"))
.model(Generation.Models.QWEN_TURBO)
.messages(Arrays.asList(
Message.builder()
.role(Role.USER.getValue())
.content("Hello, how are you?").build()
)).build();
class ReactCallback extends ResultCallback<GenerationResult> {
@Override
public void onEvent(GenerationResult message) {
System.out.println( JsonUtils.toJson(message));
// TODO deal with result
}
public void onComplete() {
// TODO all messages received
}
public void onError(Exception e) {
ApiException apiException = (ApiException) e;
// TODO deal with exception
}
}
generation.call(param, new ReactCallback());
}
}The Exception instance in the conversation scenario is a ApiException instance. This Exception may contain two parts:
- A
Statusinstance. This instance carries a status_code(The http error code), a code(server error code), a message(server error message), the input message id, and the usage information. - If an exception occurs, the
ApiExceptioninstance may only carry anExceptionstack trace, you can deal with it as you usually do.
Stream only, accept by react io
import com.alibaba.dashscope.aigc.generation.Generation;
import com.alibaba.dashscope.aigc.generation.GenerationParam;
import com.alibaba.dashscope.aigc.generation.GenerationResult;
import com.alibaba.dashscope.common.Message;
import com.alibaba.dashscope.common.Role;
import com.alibaba.dashscope.exception.ApiException;
import com.alibaba.dashscope.exception.InputRequiredException;
import com.alibaba.dashscope.exception.NoApiKeyException;
import com.alibaba.dashscope.utils.JsonUtils;
import io.reactivex.Flowable;
import java.util.Arrays;
public class Main {
public static void main(String[] args) {
Generation generation = new Generation();
Message systemMsg = Message.builder()
.role(Role.SYSTEM.getValue())
.content("You are a helpful assistant.")
.build();
Message userMsg = Message.builder()
.role(Role.USER.getValue())
.content("你是谁?")
.build();
GenerationParam param = GenerationParam.builder()
.apiKey(System.getenv("DASHSCOPE_API_KEY"))
.model(Generation.Models.QWEN_TURBO)
.messages(Arrays.asList(systemMsg, userMsg))
.resultFormat(GenerationParam.ResultFormat.MESSAGE)
.build();
try {
Flowable<GenerationResult> result = generation.streamCall( param);
result.blockingForEach(msg -> System.out.println(JsonUtils.toJson(msg)));
} catch (ApiException | NoApiKeyException | InputRequiredException e) {
System.err.println("An error occurred while calling the generation service: " + e.getMessage());
}
}
}The streamCall method accepts a GenerationParam , and returns a Flowable, which you can get the streaming result by blockingForEach, and catch the exception by the try-catch block.
Non-stream only
import com.alibaba.dashscope.aigc.generation.Generation;
import com.alibaba.dashscope.aigc.generation.GenerationParam;
import com.alibaba.dashscope.aigc.generation.GenerationResult;
import com.alibaba.dashscope.common.Message;
import com.alibaba.dashscope.common.Role;
import com.alibaba.dashscope.exception.ApiException;
import com.alibaba.dashscope.exception.InputRequiredException;
import com.alibaba.dashscope.exception.NoApiKeyException;
import com.alibaba.dashscope.utils.JsonUtils;
import java.util.Arrays;
public class Main {
public static void main(String[] args) {
Generation generation = new Generation();
Message systemMsg = Message.builder()
.role(Role.SYSTEM.getValue())
.content("You are a helpful assistant.")
.build();
Message userMsg = Message.builder()
.role(Role.USER.getValue())
.content("你是谁?")
.build();
GenerationParam param = GenerationParam.builder()
.apiKey(System.getenv("DASHSCOPE_API_KEY"))
.model(Generation.Models.QWEN_TURBO)
.messages(Arrays.asList(systemMsg, userMsg))
.resultFormat(GenerationParam.ResultFormat.MESSAGE)
.build();
try {
GenerationResult result = generation.call( param);
System.out.println(JsonUtils.toJson(result));
} catch (ApiException | NoApiKeyException | InputRequiredException e) {
System.err.println("An error occurred while calling the generation service: " + e.getMessage());
}
}
}The call method accepts a GenerationParam, and returns a GenerationResult, you can also catch the exception with a try-catch block.