平台角色对话

curl --location \
 'https://nlp.aliyuncs.com/v2/api/chat/send' \
 --header 'Expect: '  \
 --header 'Content-Type: application/json' \
 --header 'X-AcA-DataInspection: enable' \
 --header 'x-fag-servicename: aca-chat-send' \
 --header 'x-fag-appcode: aca' \
 --header 'Authorization: Bearer {YOUR_API_KEY}' \
 --data '{
            "input": {
                "messages": [
                    {
                        "name":"小明",
                        "role":"user",
                        "content":"你有几个闺蜜？"
                    }
                ],
                "aca": {
                    "botProfile": {
                        "characterId": "c39797a35ad243f1a85baaa6e1ec37e0"
                    },
                    "userProfile": {
                        "userId": "123456789"
                        "basicInfo": ""
                    },
                    "context": {
                        "useChatHistory": true,
                    }
                }
            }
              
        }'

import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.util.concurrent.CompletableFuture;

/**
 * API名称：平台角色对话
 * 环境要求：Java 17及以上
 */
public class Example {
    private static final String URL = "https://nlp.aliyuncs.com/v2/api/chat/send";
    private static final String API_KEY = "Bearer {YOUR_API_KEY}";

    private static final String jsonBody = """
        {
            "input": {
                "messages": [
                    {
                        "name":"小明",
                        "role":"user",
                        "content":"你有几个闺蜜？"
                    }
                ],
                "aca": {
                    "botProfile": {
                        "characterId": "c39797a35ad243f1a85baaa6e1ec37e0"
                    },
                    "userProfile": {
                        "userId": "123456789"
                    },
                    "context": {
                        "useChatHistory": true,
                    }
                }
            }
        }
        """;

    public static void main(String[] args) throws Exception {
        // 非流式调用
        nonStreamingCall();

        // 流式调用
        streamingCall();
    }

    private static void nonStreamingCall() throws Exception {
        System.out.println("=== 非流式调用示例 ===");

        HttpClient client = HttpClient.newHttpClient();

        HttpRequest request = HttpRequest.newBuilder()
                .uri(URI.create(URL))
                .headers(
                        "Authorization", API_KEY,
                        "X-AcA-DataInspection", "enable",
                        "x-fag-servicename", "aca-chat-send",
                        "x-fag-appcode", "aca",
                        "Content-Type", "application/json")
                .POST(HttpRequest.BodyPublishers.ofString(jsonBody))
                .build();

        // 同步调用
        HttpResponse<String> response = client.send(
                request,
                HttpResponse.BodyHandlers.ofString()
        );

        String responseBody = response.body();
        System.out.println("响应数据: " + responseBody);
    }

    private static void streamingCall() {
        System.out.println("\n=== 流式调用示例 ===");

        HttpClient client = HttpClient.newHttpClient();

        HttpRequest request = HttpRequest.newBuilder()
                .uri(URI.create(URL))
                .headers(
                        "Authorization", API_KEY,
                        "X-AcA-DataInspection", "enable",
                        "X-AcA-SSE", "enable",
                        "x-fag-servicename", "aca-chat-send-sse",
                        "x-fag-appcode", "aca",
                        "Content-Type", "application/json")
                .POST(HttpRequest.BodyPublishers.ofString(jsonBody))
                .build();

        // 异步处理 SSE 流
        CompletableFuture<Void> future = client.sendAsync(request, HttpResponse.BodyHandlers.ofLines())
                .thenApply(HttpResponse::body)
                .thenAccept(stream -> {
                    stream.forEach(line -> {
                        System.out.println("流式响应数据: " + line);
                    });
                });

        // 保持主线程等待
        future.join();
    }
}

import requests

URL = "https://nlp.aliyuncs.com/v2/api/chat/send"

# API名称：平台角色对话
# 环境要求：python3.10及以上
def call(api_key):
    headers = {
        "Content-Type": "application/json",
        "x-fag-servicename": "aca-chat-send",
        # "X-AcA-SSE": "enable", # 流式调用开启此配置
        "x-fag-appcode": "aca",
        "Authorization": f"Bearer {api_key}",
        "X-AcA-DataInspection": "enable"
    }

    payload = {
        "input": {
            "messages": messages,
            "aca": {
                "botProfile": {
                    "characterId": "c39797a35ad243f1a85baaa6e1ec37e0"
                },
                "userProfile": {
                    "userId": "123456789"
                },
                "context": {
                    "useChatHistory": True,
                }
            }
        }
    }

    response = requests.post(URL, json=payload, headers=headers)
    # 逐行打印原始响应内容
    for line in response.iter_lines():
        if line:
            print(line.decode('utf-8'))
    # 检查响应状态，如有错误则抛出异常
    response.raise_for_status()
    return response


if __name__ == "__main__":
    api_key = "{YOUR_API_KEY}"
    messages = [
        {
            "name": "小明",
            "role": "user",
            "content": "你有几个闺蜜？"
        }
    ]

    try:
        response = call(api_key)
    except requests.HTTPError as e:
        print(f"请求出错: {e}")

package main

import (
    "bytes"
    "encoding/json"
    "fmt"
    "io"
    "net/http"
)

// API名称：平台角色对话
// 环境要求：go 1.20及以上

const URL = "https://nlp.aliyuncs.com/v2/api/chat/send"

func call(messages []map[string]interface{}, apiKey string) (*http.Response, error) {
    payload := map[string]interface{}{
        "input": map[string]interface{}{
            "messages": messages,
            "aca": map[string]interface{}{
                "botProfile": map[string]interface{}{
                    "characterId": "c39797a35ad243f1a85baaa6e1ec37e0",
                },
                "userProfile": map[string]interface{}{
                    "userId":    "123456789",
                },
                "context": map[string]interface{}{
                    "useChatHistory": true,
                },
            },
        },
    }

    payloadBytes, err := json.Marshal(payload)
    if err != nil {
        return nil, err
    }

    req, err := http.NewRequest("POST", URL, bytes.NewBuffer(payloadBytes))
    if err != nil {
        return nil, err
    }

    req.Header.Set("Content-Type", "application/json")
    //req.Header.Set("X-AcA-SSE", "enable") // 流式调用开启此配置
    req.Header.Set("x-fag-servicename", "aca-chat-send")
    req.Header.Set("x-fag-appcode", "aca")
    req.Header.Set("Authorization", "Bearer "+apiKey)
    req.Header.Set("X-AcA-DataInspection", "enable")
    client := &http.Client{}
    resp, err := client.Do(req)
    if err != nil {
        return nil, err
    }

    // 逐行打印原始响应内容
    defer resp.Body.Close()
    body, _ := io.ReadAll(resp.Body)
    fmt.Println(string(body))

    if resp.StatusCode != http.StatusOK {
        return nil, fmt.Errorf("请求出错，状态码：%d", resp.StatusCode)
    }

    return resp, nil
}

func main() {
    messages := []map[string]interface{}{
        {
            "name":    "小明",
            "role":    "user",
            "content": "你有几个闺蜜？",
        },
    }

    apiKey := "{YOUR_API_KEY}"

    _, err := call(messages, apiKey)
    if err != nil {
        fmt.Printf("请求出错: %v\n", err)
    }
}

curl --location \
 'https://nlp.aliyuncs.com/v2/api/chat/send' \
 --header 'Expect: '  \
 --header 'Content-Type: application/json' \
 --header 'X-AcA-DataInspection: enable' \
 --header 'x-fag-servicename: aca-chat-send' \
 --header 'x-fag-appcode: aca' \
 --header 'Authorization: Bearer {YOUR_API_KEY}' \
 --data '{
            "input": {
                "messages": [
                    {
                        "name":"小明",
                        "role":"user",
                        "content":"你叫什么名字"
                    },
                    {
                        "name":"小婉",
                        "role":"assistant",
                        "content":"我叫小婉啊。"
                    },
                    {
                        "name":"小明",
                        "role":"user",
                        "content":"你今年多大"
                    },
                    {
                        "name":"小婉",
                        "role":"assistant",
                        "content":"我今年17岁了。"
                    },
                    {
                        "name":"小明",
                        "role":"user",
                        "content":"你有几个闺蜜？"
                    }
                ],
                "aca": {
                    "botProfile": {
                        "characterId": "c39797a35ad243f1a85baaa6e1ec37e0"
                    },
                    "userProfile": {
                        "userId": "123456789"
                    },
                    "context": {
                      "useChatHistory": false
                    }
                }
            }
        }'

import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.util.concurrent.CompletableFuture;

/**
 * API名称：平台角色对话-自定义历史记录
 * 环境要求：Java 17及以上
 */
public class Example {
    private static final String URL = "https://nlp.aliyuncs.com/v2/api/groupchat/send";
    private static final String API_KEY = "Bearer {YOUR_API_KEY}";

    private static final String jsonBody = """
        {
            "input": {
                "messages": [
                    {
                      "name":"小明",
                      "role":"user",
                      "content":"你叫什么名字"
                    },
                    {
                      "name":"小婉",
                      "role":"assistant",
                      "content":"我叫小婉啊。"
                    },
                    {
                      "name":"小明",
                      "role":"user",
                      "content":"你今年多大"
                    },
                    {
                      "name":"小婉",
                      "role":"assistant",
                      "content":"我今年17岁了。"
                    },
                    {
                      "name":"小明",
                      "role":"user",
                      "content":"你有几个闺蜜？"
                    }
                ],
                "aca": {
                    "botProfile": {
                        "characterId": "c39797a35ad243f1a85baaa6e1ec37e0"
                    },
                    "userProfile": {
                        "userId": "123456789"
                    },
                    "context": {
                        "useChatHistory": false,
                    }
                }
            }
        }
        """;

    public static void main(String[] args) throws Exception {
        // 非流式调用
        nonStreamingCall();

        // 流式调用
        streamingCall();
    }

    private static void nonStreamingCall() throws Exception {
        System.out.println("=== 非流式调用示例 ===");

        HttpClient client = HttpClient.newHttpClient();

        HttpRequest request = HttpRequest.newBuilder()
                .uri(URI.create(URL))
                .headers(
                        "Authorization", API_KEY,
                        "X-AcA-DataInspection", "enable",
                        "x-fag-servicename", "aca-chat-send",
                        "x-fag-appcode", "aca",
                        "Content-Type", "application/json")
                .POST(HttpRequest.BodyPublishers.ofString(jsonBody))
                .build();

        // 同步调用
        HttpResponse<String> response = client.send(
                request,
                HttpResponse.BodyHandlers.ofString()
        );

        String responseBody = response.body();
        System.out.println("响应数据: " + responseBody);
    }

    private static void streamingCall() {
        System.out.println("\n=== 流式调用示例 ===");

        HttpClient client = HttpClient.newHttpClient();

        HttpRequest request = HttpRequest.newBuilder()
                .uri(URI.create(URL))
                .headers(
                        "Authorization", API_KEY,
                        "X-AcA-DataInspection", "enable",
                        "X-AcA-SSE", "enable",
                        "x-fag-servicename", "aca-chat-send-sse",
                        "x-fag-appcode", "aca",
                        "Content-Type", "application/json")
                .POST(HttpRequest.BodyPublishers.ofString(jsonBody))
                .build();

        // 异步处理 SSE 流
        CompletableFuture<Void> future = client.sendAsync(request, HttpResponse.BodyHandlers.ofLines())
                .thenApply(HttpResponse::body)
                .thenAccept(stream -> {
                    stream.forEach(line -> {
                        System.out.println("流式响应数据: " + line);
                    });
                });

        // 保持主线程等待
        future.join();
    }
}

import requests

URL = "https://nlp.aliyuncs.com/v2/api/chat/send"

# API名称：平台角色对话-自定义历史记录
# 环境要求：python3.10及以上
def call(api_key):
    headers = {
        "Content-Type": "application/json",
        "x-fag-servicename": "aca-chat-send",
        # "X-AcA-SSE": "enable", # 流式调用开启此配置
        "x-fag-appcode": "aca",
        "Authorization": f"Bearer {api_key}",
        "X-AcA-DataInspection": "enable"
    }

    payload = {
        "input": {
            "messages": messages,
            "aca": {
                "botProfile": {
                    "characterId": "c39797a35ad243f1a85baaa6e1ec37e0"
                },
                "userProfile": {
                    "userId": "123456789"
                },
                "context": {
                    "useChatHistory": False,
                }
            }
        }
    }

    response = requests.post(URL, json=payload, headers=headers)
    # 逐行打印原始响应内容
    for line in response.iter_lines():
        if line:
            print(line.decode('utf-8'))
    # 检查响应状态，如有错误则抛出异常
    response.raise_for_status()
    return response


if __name__ == "__main__":
    api_key = "{YOUR_API_KEY}"
    messages = [
        {
            "name":"小明",
            "role":"user",
            "content":"你叫什么名字"
        },
        {
            "name":"小婉",
            "role":"assistant",
            "content":"我叫小婉啊。"
        },
        {
            "name":"小明",
            "role":"user",
            "content":"你今年多大"
        },
        {
            "name":"小婉",
            "role":"assistant",
            "content":"我今年17岁了。"
        },
        {
            "name":"小明",
            "role":"user",
            "content":"你有几个闺蜜？"
        }
    ]

    try:
        response = call(api_key)
    except requests.HTTPError as e:
        print(f"请求出错: {e}")

package main

import (
    "bytes"
    "encoding/json"
    "fmt"
    "io"
    "net/http"
)

// API名称：平台角色对话
// 环境要求：go 1.20及以上

const URL = "https://nlp.aliyuncs.com/v2/api/chat/send"

func call(messages []map[string]interface{}, apiKey string) (*http.Response, error) {
    payload := map[string]interface{}{
        "input": map[string]interface{}{
            "messages": messages,
            "aca": map[string]interface{}{
                "botProfile": map[string]interface{}{
                    "characterId": "c39797a35ad243f1a85baaa6e1ec37e0",
                },
                "userProfile": map[string]interface{}{
                    "userId":    "123456789",
                },
                "context": map[string]interface{}{
                    "useChatHistory": false,
                },
            },
        },
    }

    payloadBytes, err := json.Marshal(payload)
    if err != nil {
        return nil, err
    }

    req, err := http.NewRequest("POST", URL, bytes.NewBuffer(payloadBytes))
    if err != nil {
        return nil, err
    }

    req.Header.Set("Content-Type", "application/json")
    //req.Header.Set("X-AcA-SSE", "enable") // 流式调用开启此配置
    req.Header.Set("x-fag-servicename", "aca-chat-send")
    req.Header.Set("x-fag-appcode", "aca")
    req.Header.Set("Authorization", "Bearer "+apiKey)
    req.Header.Set("X-AcA-DataInspection", "enable")
    client := &http.Client{}
    resp, err := client.Do(req)
    if err != nil {
        return nil, err
    }

    // 逐行打印原始响应内容
    defer resp.Body.Close()
    body, _ := io.ReadAll(resp.Body)
    fmt.Println(string(body))

    if resp.StatusCode != http.StatusOK {
        return nil, fmt.Errorf("请求出错，状态码：%d", resp.StatusCode)
    }

    return resp, nil
}

func main() {
    messages := []map[string]interface{}{
        {
            "name":    "小明",
            "role":    "user",
            "content": "你叫什么名字",
        },
        {
            "name":    "小婉",
            "role":    "assistant",
            "content": "我叫小婉啊。",
        },
        {
            "name":    "小明",
            "role":    "user",
            "content": "你今年多大",
        },
        {
            "name":    "小婉",
            "role":    "assistant",
            "content": "我今年17岁了。",
        },
        {
            "name":    "小明",
            "role":    "user",
            "content": "你有几个闺蜜？",
        },
    }

    apiKey := "YOUR_API_KEY"

    _, err := call(messages, apiKey)
    if err != nil {
        fmt.Printf("请求出错: %v\n", err)
    }
}