Fetch Stream Events

Get Assistant Message Events

curl --request GET \
  --url https://api.reportify.cn/v1/agent/conversations/{conversation_id}/messages/{assistant_message_id} \
  --header 'Authorization: Bearer <token>'

import requests

url = "https://api.reportify.cn/v1/agent/conversations/{conversation_id}/messages/{assistant_message_id}"

headers = {"Authorization": "Bearer <token>"}

response = requests.get(url, headers=headers)

print(response.text)

const options = {method: 'GET', headers: {Authorization: 'Bearer <token>'}};

fetch('https://api.reportify.cn/v1/agent/conversations/{conversation_id}/messages/{assistant_message_id}', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api.reportify.cn/v1/agent/conversations/{conversation_id}/messages/{assistant_message_id}",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "GET",
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

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

func main() {

	url := "https://api.reportify.cn/v1/agent/conversations/{conversation_id}/messages/{assistant_message_id}"

	req, _ := http.NewRequest("GET", url, nil)

	req.Header.Add("Authorization", "Bearer <token>")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.get("https://api.reportify.cn/v1/agent/conversations/{conversation_id}/messages/{assistant_message_id}")
  .header("Authorization", "Bearer <token>")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://api.reportify.cn/v1/agent/conversations/{conversation_id}/messages/{assistant_message_id}")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Get.new(url)
request["Authorization"] = 'Bearer <token>'

response = http.request(request)
puts response.read_body

{
  "event_id": "019b24ef23a1f4da18256b402868fae31764",
  "event_type": "init",
  "timestamp": 1765851210657,
  "response_id": "019b24ef238cc97730971a9a0080c99c",
  "workflow_id": "11887655289749510",
  "execution_id": "1dfccd9d-c365-4b7a-adae-aa9123684ec4",
  "run_id": "",
  "node_id": "<string>",
  "node_name": "<string>",
  "node_type": "<string>",
  "agent_id": "<string>",
  "agent_name": "<string>",
  "agent_type": "<string>",
  "tool_id": "<string>",
  "tool_name": "<string>",
  "input": {
    "query": "NVIDIA AMD Intel GPU 半导体 最新动态",
    "symbols": [
      "US:NVDA",
      "US:AMD",
      "US:INTC"
    ],
    "start_datetime": "2025-12-15T00:00:00",
    "end_datetime": "2025-12-16T02:14:15",
    "num": 15,
    "filetype": "json"
  },
  "output": {
    "content": "{\"docs\": [{\"doc_id\": \"1197862772277383168\", \"title\": \"示例文档\"}], \"total_count\": 10}"
  },
  "content": "",
  "error": {},
  "offset": 9195
}

{
  "detail": [
    {
      "loc": [
        "<string>"
      ],
      "msg": "<string>",
      "type": "<string>"
    }
  ]
}

{
  "detail": [
    {
      "loc": [
        "<string>"
      ],
      "msg": "<string>",
      "type": "<string>"
    }
  ]
}

{
  "detail": [
    {
      "loc": [
        "<string>"
      ],
      "msg": "<string>",
      "type": "<string>"
    }
  ]
}

GET

agent

conversations

{conversation_id}

messages

{assistant_message_id}

Get Assistant Message Events

curl --request GET \
  --url https://api.reportify.cn/v1/agent/conversations/{conversation_id}/messages/{assistant_message_id} \
  --header 'Authorization: Bearer <token>'

import requests

url = "https://api.reportify.cn/v1/agent/conversations/{conversation_id}/messages/{assistant_message_id}"

headers = {"Authorization": "Bearer <token>"}

response = requests.get(url, headers=headers)

print(response.text)

const options = {method: 'GET', headers: {Authorization: 'Bearer <token>'}};

fetch('https://api.reportify.cn/v1/agent/conversations/{conversation_id}/messages/{assistant_message_id}', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api.reportify.cn/v1/agent/conversations/{conversation_id}/messages/{assistant_message_id}",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "GET",
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

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

func main() {

	url := "https://api.reportify.cn/v1/agent/conversations/{conversation_id}/messages/{assistant_message_id}"

	req, _ := http.NewRequest("GET", url, nil)

	req.Header.Add("Authorization", "Bearer <token>")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.get("https://api.reportify.cn/v1/agent/conversations/{conversation_id}/messages/{assistant_message_id}")
  .header("Authorization", "Bearer <token>")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://api.reportify.cn/v1/agent/conversations/{conversation_id}/messages/{assistant_message_id}")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Get.new(url)
request["Authorization"] = 'Bearer <token>'

response = http.request(request)
puts response.read_body

{
  "event_id": "019b24ef23a1f4da18256b402868fae31764",
  "event_type": "init",
  "timestamp": 1765851210657,
  "response_id": "019b24ef238cc97730971a9a0080c99c",
  "workflow_id": "11887655289749510",
  "execution_id": "1dfccd9d-c365-4b7a-adae-aa9123684ec4",
  "run_id": "",
  "node_id": "<string>",
  "node_name": "<string>",
  "node_type": "<string>",
  "agent_id": "<string>",
  "agent_name": "<string>",
  "agent_type": "<string>",
  "tool_id": "<string>",
  "tool_name": "<string>",
  "input": {
    "query": "NVIDIA AMD Intel GPU 半导体 最新动态",
    "symbols": [
      "US:NVDA",
      "US:AMD",
      "US:INTC"
    ],
    "start_datetime": "2025-12-15T00:00:00",
    "end_datetime": "2025-12-16T02:14:15",
    "num": 15,
    "filetype": "json"
  },
  "output": {
    "content": "{\"docs\": [{\"doc_id\": \"1197862772277383168\", \"title\": \"示例文档\"}], \"total_count\": 10}"
  },
  "content": "",
  "error": {},
  "offset": 9195
}

{
  "detail": [
    {
      "loc": [
        "<string>"
      ],
      "msg": "<string>",
      "type": "<string>"
    }
  ]
}

{
  "detail": [
    {
      "loc": [
        "<string>"
      ],
      "msg": "<string>",
      "type": "<string>"
    }
  ]
}

{
  "detail": [
    {
      "loc": [
        "<string>"
      ],
      "msg": "<string>",
      "type": "<string>"
    }
  ]
}

获取助手消息事件

URL: /v1/agent/conversations/{conversation_id}/messages/{assistant_message_id} 方法: GET 描述: 获取指定助手消息的所有事件，支持从指定的 offset 开始批量获取，可选择流式（SSE）或非流式（JSON）响应模式。

使用场景

断点续传：当客户端断开连接后，可以从上次接收到的 offset 继续获取事件
历史回放：获取已完成对话的完整事件历史
事件查询：查询特定消息的所有事件，用于调试或分析

路径参数

参数名	类型	必填	描述
conversation_id	integer	是	对话 ID
assistant_message_id	string	是	助手消息 ID（从 chat 接口响应头 X-REPORTIFY-ASSISTANT-MESSAGE-ID 获取）

查询参数

参数名	类型	必填	默认值	描述
stream	boolean	否	true	是否使用流式响应（SSE）
timeout	integer	否	1800	流式模式的超时时间（秒）
from_offset	integer	否	0	从指定偏移量开始获取事件（最小值：0）

响应参数

流式响应（stream=true）

返回 text/event-stream 格式的 SSE 流，每个事件的结构与智能体对话聊天接口相同。

非流式响应（stream=false）

返回 JSON 格式的事件数组：

参数名	类型	描述
assistant_events	array	事件列表，每个元素为 WorkflowStreamEvent

示例代码

cURL 示例（流式响应）

curl -X GET "https://api.reportify.cn/v1/agent/conversations/683242877840089/messages/019b24ef238cc97730971a9a0080c99c?stream=true&from_offset=9200" \
  -H "Authorization: Bearer YOUR_API_KEY"

cURL 示例（非流式响应）

curl -X GET "https://api.reportify.cn/v1/agent/conversations/683242877840089/messages/019b24ef238cc97730971a9a0080c99c?stream=false&from_offset=9200" \
  -H "Authorization: Bearer YOUR_API_KEY"

Python 示例（流式响应）

import requests

url = "https://api.reportify.cn/v1/agent/conversations/683242877840089/messages/019b24ef238cc97730971a9a0080c99c"
headers = {
    "Authorization": "Bearer YOUR_API_KEY"
}
params = {
    "stream": True,
    "from_offset": 9200
}

response = requests.get(url, headers=headers, params=params, stream=True)

for line in response.iter_lines():
    if line:
        line = line.decode('utf-8')
        if line.startswith('data: '):
            event_data = line[6:]  # 去掉 "data: " 前缀
            print(event_data)

Python 示例（非流式响应）

import requests

url = "https://api.reportify.cn/v1/agent/conversations/683242877840089/messages/019b24ef238cc97730971a9a0080c99c"
headers = {
    "Authorization": "Bearer YOUR_API_KEY"
}
params = {
    "stream": False,
    "from_offset": 9200
}

response = requests.get(url, headers=headers, params=params)
data = response.json()

for event in data['assistant_events']:
    print(f"Event: {event['event_type']}, Offset: {event['offset']}")

响应示例

非流式响应示例

{
  "assistant_events": [
    {
      "event_id": "019b24ef3046f157db389ee55a0a670a3797",
      "event_type": "streaming",
      "timestamp": 1765851213894,
      "response_id": "019b24ef238cc97730971a9a0080c99c",
      "workflow_id": "11887655289749510",
      "execution_id": "",
      "run_id": "019b24ef25015b3e6e9b3d2363cfb36c",
      "node_id": "start",
      "agent_id": "workflow_planner",
      "content": "项目的具体信息，并将这些信息整合到一份专业的AI行业每日深度报告中。",
      "offset": 9200
    },
    {
      "event_id": "019b24ef49d95c616af6a7b4953fc70a1129",
      "event_type": "node_start",
      "timestamp": 1765851220441,
      "response_id": "019b24ef238cc97730971a9a0080c99c",
      "workflow_id": "11887655289749510",
      "execution_id": "",
      "run_id": "019b24ef49d8a5997ea7d63b8344bfaa",
      "node_id": "define_report_scope",
      "node_name": "确定报告范围",
      "node_type": "agent",
      "offset": 9216
    }
  ]
}

注意事项

assistant_message_id 可从对话聊天接口（stream=true）的 HTTP 响应头 X-REPORTIFY-ASSISTANT-MESSAGE-ID 中获取
from_offset 参数用于指定从哪个偏移量开始获取事件，可以用于断点续传
流式模式下，事件会实时推送；非流式模式下，会一次性返回所有事件
建议在需要实时更新时使用流式模式，在需要批量处理历史数据时使用非流式模式

Authorizations

Authorization

string

header

required

Enter your Bearer token

Path Parameters

conversation_id

integer

required

对话 ID

assistant_message_id

string

required

助手消息 ID（从 chat 接口响应头 X-REPORTIFY-ASSISTANT-MESSAGE-ID 获取）

Query Parameters

stream

boolean

default:true

是否使用流式响应（SSE） Stream events via SSE when true

timeout

integer

default:1800

流式模式的超时时间（秒） Timeout in seconds for streaming mode

from_offset

integer

default:0

从指定偏移量开始获取事件 Start streaming from specific offset

Required range: x >= 0

Response

Successful Response (Server-Sent Events stream or JSON array)

工作流流式事件对象

event_id

string

required

唯一事件标识符

Example:

"019b24ef23a1f4da18256b402868fae31764"

event_type

enum<string>

required

事件类型

Available options:

init,

workflow_start,

workflow_end,

node_start,

node_end,

agent_start,

agent_end,

tool_start,

tool_end,

stream_start,

streaming,

stream_end,

usage,

cancel,

error

Example:

"init"

timestamp

integer

required

事件时间戳（毫秒）

Example:

1765851210657

response_id

string

required

响应标识符，用于分组事件

Example:

"019b24ef238cc97730971a9a0080c99c"

workflow_id

string

工作流标识符

Example:

"11887655289749510"

execution_id

string

执行标识符

Example:

"1dfccd9d-c365-4b7a-adae-aa9123684ec4"

run_id

string

运行标识符，用于关联一组 start 和 end 事件（如 workflow_start 和 workflow_end、tool_start 和 tool_end），用于分组相关的开始/结束事件对

Example:

""

node_id

string

节点标识符

node_name

string

节点显示名称

node_type

string

节点类型（start, tool, agent, end）

agent_id

string

智能体标识符

agent_name

string

智能体显示名称

agent_type

string

智能体类型（builtin_agent, react_agent 等）

tool_id

string

工具标识符

tool_name

string

工具显示名称

input

Input · object

组件的输入数据

Show child attributes

Example:

{
  "query": "NVIDIA AMD Intel GPU 半导体 最新动态",
  "symbols": ["US:NVDA", "US:AMD", "US:INTC"],
  "start_datetime": "2025-12-15T00:00:00",
  "end_datetime": "2025-12-16T02:14:15",
  "num": 15,
  "filetype": "json"
}

output

Output · object

组件的输出数据。

对于 tool_end 事件：包含 content 字段（JSON 字符串格式）
对于 agent_end 事件：包含 content 字段（Markdown 格式）
对于 node_end 事件：包含 content、filetype、filename、filepath 字段
对于 workflow_end 事件：字典的 key 为最后一个 node 的 node_id，value 包含 title、filetype、content、filename、filepath 字段

Show child attributes

Example:

{
  "content": "{\"docs\": [{\"doc_id\": \"1197862772277383168\", \"title\": \"示例文档\"}], \"total_count\": 10}"
}

content

string

事件内容（用于思考/流式输出）

Example:

""

error

Error · object

错误信息（如果事件类型为 error）

offset

integer

事件偏移量

Example:

9195

Chat Cancel

使用说明

文档接口

股票数据

量化分析

智能体

MCP

SDK

获取助手消息事件

使用场景

路径参数

查询参数

响应参数

流式响应（stream=true）

非流式响应（stream=false）

示例代码

cURL 示例（流式响应）

cURL 示例（非流式响应）

Python 示例（流式响应）

Python 示例（非流式响应）

响应示例

非流式响应示例

注意事项

Authorizations

Path Parameters

Query Parameters

Response

​获取助手消息事件

​使用场景

​路径参数

​查询参数

​响应参数

​流式响应（stream=true）

​非流式响应（stream=false）

​示例代码

​cURL 示例（流式响应）

​cURL 示例（非流式响应）

​Python 示例（流式响应）

​Python 示例（非流式响应）

​响应示例

​非流式响应示例

​注意事项

Authorizations

Path Parameters

Query Parameters

Response

获取助手消息事件

使用场景

路径参数

查询参数

响应参数

流式响应（stream=true）

非流式响应（stream=false）

示例代码

cURL 示例（流式响应）

cURL 示例（非流式响应）

Python 示例（流式响应）

Python 示例（非流式响应）

响应示例

非流式响应示例

注意事项