Device Agent

简体中文

English

简体中文

English

Appearance

联系我们
联系我们

API 参考 ​

对外接口按协议分为 MQTT、HTTP 和 WebSocket：MQTT 用于设备接入，HTTP 用于对话、查询和控制，WebSocket 用于实时语音。示例使用本地运行时，其中 productId 是设备智能体 ID，deviceId 是真实设备 ID，HTTP 路径里的 products 按设备智能体理解。

txt
HTTP: http://127.0.0.1:3000
Voice WebSocket: ws://127.0.0.1:3001/ws/voice
Voice HTTP: http://127.0.0.1:3001/api/chat, /api/vision/frames

选择协议 ​

使用场景推荐协议说明
真实设备长期在线、上报状态、接收命令MQTT适合设备端连接、状态同步和命令响应。
业务系统、控制台扩展或自动化脚本调用 Device AgentHTTP适合一次性请求、查询和命令下发。
实时语音交互WebSocket适合连续音频输入、实时识别结果和语音合成输出。
浏览器或设备端通过 WebSocket 连接 MQTT BrokerMQTT over WebSocket这是 MQTT 的传输方式，不是 Device Agent 的语音 WebSocket。

MQTT ​

MQTT 用于设备侧接入。设备通过 MQTT 上线、上报状态、接收命令、返回命令结果和上报事件。MQTT 服务地址、用户名、密码和主题模板以控制台配置为准。

方向主题用途
MQTT 客户端 -> Device Agentdevice-agent/{productId}/in向某个设备智能体发送文本请求。
Device Agent -> MQTT 客户端device-agent/{productId}/out返回设备智能体回复。
MQTT 客户端 -> Device Agentdevice-agent/{productId}/device/{deviceId}/in向某台设备上下文发送文本请求。
Device Agent -> MQTT 客户端device-agent/{productId}/device/{deviceId}/out返回带设备上下文的回复。
Device Agent -> 设备device-agent/{productId}/device/{deviceId}/commands下发设备命令。
设备 -> Device Agentdevice-agent/{productId}/device/{deviceId}/responses返回命令结果。
设备 -> Device Agentv1/{productId}/{deviceId}/telemetry上报在线状态和当前数据。
设备 -> Device Agentv1/{productId}/{deviceId}/event上报设备事件。
设备 -> Device Agentdevice-agent/{productId}/device/{deviceId}/ntp/request发起时间同步。
Device Agent -> 设备device-agent/{productId}/device/{deviceId}/ntp/response返回时间同步结果。

文本请求消息体：

json
{
  "prompt": "查看当前温度",
  "sessionId": "session-default:thermostat:thermostat-001",
  "metadata": {
    "source": "mqtt-client"
  }
}

设备智能体回复消息体：

json
{
  "sessionId": "session-default:thermostat:thermostat-001",
  "text": "当前温度是 28 度。",
  "metadata": {
    "timestamp": "2026-05-11T10:00:00.000Z"
  },
  "timestamp": "2026-05-11T10:00:00.000Z"
}

设备上线状态：

json
{
  "type": "status",
  "data": {
    "status": "online",
    "state": {
      "temperature": 28,
      "humidity": 62,
      "mode": "auto"
    }
  },
  "metadata": {
    "productId": "thermostat",
    "source": "existing-device"
  }
}

设备命令：

json
{
  "cmd": "set_target_temperature",
  "params": {
    "target_temperature": 24
  },
  "requestId": "req-001",
  "ts": 1710000010000
}

命令响应：

json
{
  "code": 0,
  "msg": "ok",
  "requestId": "req-001",
  "data": {
    "target_temperature": 24
  },
  "metadata": {
    "productId": "thermostat",
    "source": "existing-device"
  }
}

设备事件：

json
{
  "type": "event",
  "data": {
    "event": "temperature_alert",
    "temperature": 38.5,
    "level": "warning"
  },
  "metadata": {
    "productId": "thermostat",
    "source": "existing-device"
  }
}

时间同步请求和响应：

json
{
  "deviceSendTime": 1710000010000
}
json
{
  "deviceSendTime": 1710000010000,
  "serverRecvTime": 1710000010100,
  "serverSendTime": 1710000010105
}

更多消息体规则、校验方式和 MQTTX 示例见 MQTT 接入。

HTTP 侧下发的设备命令最终会通过 MQTT 命令主题发送给设备；设备通过 MQTT 响应主题返回结果。设备事件也来自 MQTT 事件主题，上报后可通过 HTTP 事件接口查询。

HTTP ​

HTTP API 路径都以 /api 开头。除 /api/chat 返回 Server-Sent Events 外，其他对外接口通常使用 JSON。

/api/chat 和 /api/vision/frames 同时挂在主 HTTP 端口和语音服务端口上。业务系统通常使用 3000；语音或摄像头客户端如果已经连接 3001，可以直接使用同名接口。

对话和视觉 ​

方法路径用途
GET/api/health检查 HTTP API 是否可用。
POST/api/chat发起文本对话，必须设置 stream: true。
GET/api/sessions/:sessionId/history查询会话历史。
POST/api/sessions/:sessionId/interrupt中断当前会话。
DELETE/api/sessions/:sessionId清空会话。
POST/api/vision/frames上传视觉帧，供后续对话使用。

对话示例：

bash
$ curl -N http://127.0.0.1:3000/api/chat \
  -H 'Content-Type: application/json' \
  -H 'Accept: text/event-stream' \
  -d '{
    "message": "查看当前温度，并把目标温度设置为 24 度",
    "stream": true,
    "sessionId": "demo-session",
    "metadata": {
      "productId": "thermostat",
      "deviceId": "thermostat-001"
    }
  }'

视觉帧先通过 /api/vision/frames 上传，再把返回的 frameId 和 capturedAt 作为 visionRefs 传给 /api/chat。mimeType 支持 image/jpeg、image/png 和 image/webp。

bash
$ curl http://127.0.0.1:3000/api/vision/frames \
  -H 'Content-Type: application/json' \
  -d '{
    "sessionId": "demo-session",
    "deviceId": "thermostat-001",
    "mimeType": "image/png",
    "imageBase64": "<base64>",
    "source": "camera"
  }'

上传成功后，响应会返回：

json
{
  "frameId": "frame-001",
  "capturedAt": "2026-05-11T10:00:00.000Z",
  "source": "camera",
  "mimeType": "image/png"
}

带视觉帧发起对话：

json
{
  "message": "根据这张图判断设备屏幕是否异常",
  "stream": true,
  "sessionId": "demo-session",
  "visionRefs": [
    {
      "frameId": "frame-001",
      "capturedAt": "2026-05-11T10:00:00.000Z",
      "source": "camera"
    }
  ]
}

设备、命令和事件 ​

方法路径用途
GET/api/products/:productId/devices查询某个设备智能体下的设备列表。
GET/api/products/:productId/devices/:deviceId查询设备详情。
POST/api/products/:productId/devices/:deviceId/commands向在线设备下发命令。
GET/api/products/:productId/devices/:deviceId/events查询设备事件。
POST/api/products/:productId/devices/:deviceId/simulator-report让浏览器模拟设备上报一次状态或事件。

先查真实 ID，再执行请求。HTTP API 不会帮你猜要操作哪台设备，所以先拿到 productId 和 deviceId。

bash
$ export BASE=http://127.0.0.1:3000
$ curl "$BASE/api/products"
$ export PRODUCT_ID=your_product_id
$ curl "$BASE/api/products/$PRODUCT_ID/devices"
$ export DEVICE_ID=your_device_id

把 your_product_id 和 your_device_id 替换为前两个响应里的真实值。

查询设备详情：

bash
$ curl "$BASE/api/products/$PRODUCT_ID/devices/$DEVICE_ID"

下面的命令来自 Smart Cockpit Range 示例。它会把模拟车机的驾驶模式切到 eco；如果使用别的设备智能体，请换成该 DeviceSpec 中已有的命令和参数。

bash
$ curl "$BASE/api/products/$PRODUCT_ID/devices/$DEVICE_ID/commands" \
  -H 'Content-Type: application/json' \
  -d '{
    "command": "set_drive_mode",
    "params": {
      "mode": "eco"
    },
    "timeoutMs": 30000
  }'

查询设备事件：

bash
$ curl "$BASE/api/products/$PRODUCT_ID/devices/$DEVICE_ID/events?limit=50"

浏览器模拟设备上报事件时，把 sim_your_device_id 换成 sim- 开头或由控制台浏览器模拟器创建的设备 ID。下面的事件表示电量偏低；如果使用别的设备智能体，请换成该 DeviceSpec 中已有的事件名和字段。

bash
$ export DEVICE_ID=sim_your_device_id
$ curl "$BASE/api/products/$PRODUCT_ID/devices/$DEVICE_ID/simulator-report" \
  -H 'Content-Type: application/json' \
  -d '{
    "namespace": "default",
    "reportType": "event",
    "eventName": "battery_low_warning",
    "payload": {
      "soc": 15,
      "estimated_range_km": 42
    }
  }'

该接口只接受浏览器模拟设备。真实设备应通过 MQTT 或 SDK 上报状态和事件。

工作流 ​

工作流可以通过 HTTP 查询、启停和删除。创建和完整更新由设备智能体的工作流工具完成，通常在对话中说明触发条件和处理动作。使用方式见 工作流。

方法路径用途
GET/api/workflows查询已保存工作流。
PATCH/api/workflows/:workflowId启用或停用工作流。请求体为 { "enabled": true } 或 { "enabled": false }。
DELETE/api/workflows/:workflowId删除工作流。

工作流 ID 来自 GET /api/workflows 返回结果，或创建工作流时指定的 ID：

bash
$ curl "$BASE/api/workflows"
$ export WORKFLOW_ID=battery-low-alert
$ curl "$BASE/api/workflows/$WORKFLOW_ID" \
  -X PATCH \
  -H 'Content-Type: application/json' \
  -d '{ "enabled": false }'
$ curl "$BASE/api/workflows/$WORKFLOW_ID" -X DELETE

控制台创建、更新、发布设备智能体，生成 SDK，修改配置，查看日志，管理技能和工具等能力属于产品界面内部接口，不在对外 API 参考中展开。

WebSocket ​

WebSocket 目前主要用于语音通道。默认地址：

txt
ws://127.0.0.1:3001/ws/voice

语音服务端口还会处理 POST /api/chat 和 POST /api/vision/frames，用于语音和摄像头客户端在同一个服务地址下提交文本请求和视觉帧。

连接时可带 Header：

Header说明
Protocol-Version协议版本，当前为 3。
Device-Id当前设备 ID。
Client-Id客户端 ID，不传时默认使用设备 ID。

语音连接建立后，先发送 hello：

json
{
  "type": "hello",
  "version": 3,
  "audio_params": {
    "format": "pcm",
    "sample_rate": 16000,
    "channels": 1
  },
  "sessionId": "demo-session",
  "productId": "thermostat",
  "deviceId": "thermostat-001",
  "provider": "aliyun"
}

一次语音交互的消息顺序通常是：

方向消息说明
客户端 -> Device Agenthello建立语音会话，提交音频参数、设备上下文和语音服务商。
Device Agent -> 客户端hello返回会话 ID 和服务端语音输出参数。
客户端 -> Device Agentlisten开始收音。
客户端 -> Device Agent音频二进制帧发送语音数据。
Device Agent -> 客户端asr返回实时或最终识别文本。
客户端 -> Device Agentstop结束收音，可携带 visionRefs。
Device Agent -> 客户端agent_reply返回设备智能体文本回复。
Device Agent -> 客户端tts返回待合成文本。
Device Agent -> 客户端语音合成音频二进制帧播放语音回复。
Device Agent -> 客户端tts_complete本轮语音完成。
客户端 -> Device Agentabort中断当前轮次。
客户端 -> Device Agentgoodbye关闭语音会话。

语音配置见 语音配置，使用方式见 语音交互。

注意，mqtt.wsUrl 是 MQTT Broker 的 WebSocket 地址，用来通过 WebSocket 传输 MQTT 协议；/ws/voice 是 Device Agent 的语音通道，两者不是同一个接口。