使用 Agent 记忆服务

POST / HTTP/1.1
Host: postgres.tencentcloudapi.com
Content-Type: application/json
X-TC-Action: CloseMem0Service
<公共请求参数>

{
  "DBInstanceId": "postgres-pax**z0n"
}

POST / HTTP/1.1
Host: postgres.tencentcloudapi.com
Content-Type: application/json
X-TC-Action: DescribeMem0Service
<公共请求参数>

{
  "DBInstanceId": "postgres-pax**z0n"
}

const BASE_URL = "http://<服务地址>";
const headers = { "Content-Type": "application/json" };

// 写入记忆
async function addMemory(messages, userId) {
  const res = await fetch(`${BASE_URL}/memories`, {
    method: "POST",
    headers,
    body: JSON.stringify({ messages, user_id: userId }),
  });
  return res.json();
}

// 检索记忆（注意使用 filters + top_k）
async function searchMemory(query, userId) {
  const res = await fetch(`${BASE_URL}/search`, {
    method: "POST",
    headers,
    body: JSON.stringify({ query, filters: { user_id: userId }, top_k: 5 }),
  });
  return (await res.json()).results;
}

import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;

public class MemoryDemo {
    static final String BASE_URL = "http://<服务地址>";

    public static void main(String[] args) throws Exception {
        HttpClient client = HttpClient.newHttpClient();

        // 写入记忆
        String addBody = """
            {"messages":[{"role":"user","content":"我叫张三，是一名后端工程师。"}],"user_id":"zhangsan"}""";
        HttpRequest addReq = HttpRequest.newBuilder()
            .uri(URI.create(BASE_URL + "/memories"))
            .header("Content-Type", "application/json")
            .POST(HttpRequest.BodyPublishers.ofString(addBody))
            .build();
        System.out.println(client.send(addReq, HttpResponse.BodyHandlers.ofString()).body());

        // 检索记忆（注意使用 filters + top_k）
        String searchBody = """
            {"query":"张三的职业","filters":{"user_id":"zhangsan"},"top_k":3}""";
        HttpRequest searchReq = HttpRequest.newBuilder()
            .uri(URI.create(BASE_URL + "/search"))
            .header("Content-Type", "application/json")
            .POST(HttpRequest.BodyPublishers.ofString(searchBody))
            .build();
        System.out.println(client.send(searchReq, HttpResponse.BodyHandlers.ofString()).body());
    }
}

package main

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

const baseURL = "http://<服务地址>"

func post(path, body string) string {
	resp, err := http.Post(baseURL+path, "application/json", bytes.NewBufferString(body))
	if err != nil {
		panic(err)
	}
	defer resp.Body.Close()
	data, _ := io.ReadAll(resp.Body)
	return string(data)
}

func main() {
	// 写入记忆
	fmt.Println(post("/memories",
		`{"messages":[{"role":"user","content":"我叫张三，是一名后端工程师。"}],"user_id":"zhangsan"}`))

	// 检索记忆（注意使用 filters + top_k）
	fmt.Println(post("/search",
		`{"query":"张三的职业","filters":{"user_id":"zhangsan"},"top_k":3}`))
}

<?php
$baseUrl = "http://<服务地址>";

function post($url, $payload) {
    $ch = curl_init($url);
    curl_setopt_array($ch, [
        CURLOPT_RETURNTRANSFER => true,
        CURLOPT_POST => true,
        CURLOPT_HTTPHEADER => ["Content-Type: application/json"],
        CURLOPT_POSTFIELDS => json_encode($payload, JSON_UNESCAPED_UNICODE),
    ]);
    $result = curl_exec($ch);
    curl_close($ch);
    return $result;
}

// 写入记忆
echo post("$baseUrl/memories", [
    "messages" => [["role" => "user", "content" => "我叫张三，是一名后端工程师。"]],
    "user_id" => "zhangsan",
]);

// 检索记忆（注意使用 filters + top_k）
echo post("$baseUrl/search", [
    "query" => "张三的职业",
    "filters" => ["user_id" => "zhangsan"],
    "top_k" => 3,
]);