weather-agent/
├── src/             ---------------------------------- ## 项目根目录
│   └── index.js     ---------------------------------- ## agent 云函数所在目录
├── dist/            ---------------------------------- ## agent 构建产物所在地址（cli 可通过参数自行指定，参考 rcb build -h）
│   └── agent.zip
├── logs/            ---------------------------------- ## 本地服务日志目录
├── node_modules/    ---------------------------------- ## 项目依赖包
├── .gitignore       ---------------------------------- ## .gitignore
├── agent-cloudbase-functions.json  ------------------- ## agent 函数配置目录
├── package.json     ---------------------------------- ## package.json 依赖声明
└── project.config.json ------------------------------- ## 项目配置文件

const { AgentRuntime, AgentDriver } = require("@vectorx/agent-runtime");
 
const test_answer = "hi，我是开放平台智能体，我可以帮你做很多事情！";
 
/**
 * @typedef {import('@vectorx/agent-runtime').IAgent} IAgent
 *
 * @class
 * @implements {IAgent}
 */
class MyAgent extends AgentRuntime {
  async sendMessage() {
    return new Promise((res) => {
      const charArr = test_answer.split("");
      const interval = setInterval(() => {
        const char = charArr.shift();
 
        if (typeof char === "string") {
          // 返回标准的结构定义 
          this.sseSender.send({ 
            data: {
              choices: [
                {
                  message: {
                    role: "assistant",
                    type: "answer",
                    content: char
                  },
                },
              ],
            },
           });
        } else {
          clearInterval(interval);
          this.sseSender.end();
          res();
        }
      }, 50);
    });
  }
}
 
// 基于云函数进行发布
exports.main = function (event, context) {
  return AgentDriver.run(event, context, new MyAgent(context));
};
 

npm i @vectorx/agent-runtime -S // 或指定 latest 
npm i @vectorx/functions-framework -S // 或指定 latest

const { AgentRuntime, AgentDriver } = require("@vectorx/agent-runtime");
 
// 继承 AgentRuntime 基类，获取 开平 AI 核心能力
class MyAgent extends AgentRuntime {
    ...
}
 
// 基于「云函数」的方式注册智能体，agent 服务框架（ @vectorx/functions-framework ）会自动加载函数 
exports.main = function (event, context) {
  return AgentDriver.run(event, context, new MyAgent(context));
};

{
  "version": "1.0.0",
  "description": "智能体模板",
  "scripts": {
    "start": "rcb-ff" // 通过 functions-framework 启动函数式框架
  },
  "dependencies": {
    "@vectorx/agent-runtime": "^0.0.1",
    "@vectorx/functions-framework": "^0.0.1"
  }
}
 

sendMessage() {
  const model = this.createModel('deepseek-r1')
  const modelResponse = await model.streamText({
    messages: [
      {
        role: 'system',
        content: systemPrompt
      },
      {
        role: 'user',
        content: {
          type: 'text',
          content: JSON.stringify(input.msg)
        }
      }
    ]
  })
  
  for await (const chunk of modelResponse) {
    this.sseSender.send({ data: chunk });
  }
 
  this.sseSender.end();
}

sendMessage() {
  const model = this.createModel('deepseek-r1')
  const modelResponse = await model.generateText({
    messages: [
      {
        role: 'system',
        content: systemPrompt
      },
      {
        role: 'user',
        content: {
          type: 'text',
          content: JSON.stringify(input.msg)
        }
      }
    ]
  })
   
   const resp = {
     content: modelResponse.choices[0].message.content || '',
     reasoning_content: '',
     role: 'assistant',
     type: 'text',
   }
 
   this.sseSender.send({ data: resp });
   this.sseSender.end();
}

├── node_modules  # 项目依赖
├── src  # 函数 echo
│   └── index.js  # 默认函数入口文件 
├── package.json
├── cloudbase-functions.json  # 多函数配置文件
├── project.config.json  # 项目配置文件

{
  "functionsRoot": "./src",
  "functions": [
    {
      "triggerPath": "/",
      "name": "main",
      "directory": "./",
      "source": "index.js"
    }
  ]
}