Flow Monitor

功能特性

🔍 实时监控

📊 流量分析

🔬 调试工具

🚦 流量拦截

📤 导出功能

📁 会话管理

快速开始

作为 ProxyCast 插件使用

独立使用(开发中)

# 克隆仓库
git clone https://github.com/aiclientproxy/flow-monitor.git
cd flow-monitor
# 安装依赖
npm install
# 开发模式运行
npm run tauri:dev
# 构建
npm run tauri:build

架构设计

┌─────────────────────────────────────────────────────────┐
│ Frontend (React) │
│ ┌─────────────┐ ┌─────────────┐ ┌─────────────────┐ │
│ │ FlowList │ │ FlowDetail │ │ FilterPanel │ │
│ └─────────────┘ └─────────────┘ └─────────────────┘ │
│ ┌─────────────┐ ┌─────────────┐ ┌─────────────────┐ │
│ │ DiffView │ │ Sessions │ │ Statistics │ │
│ └─────────────┘ └─────────────┘ └─────────────────┘ │
├─────────────────────────────────────────────────────────┤
│ API Layer (Tauri) │
│ ┌─────────────────────────────────────────────────┐ │
│ │ Tauri Commands │ │
│ └─────────────────────────────────────────────────┘ │
├─────────────────────────────────────────────────────────┤
│ Backend (Rust) │
│ ┌──────────────┐ ┌──────────────┐ ┌──────────────┐ │
│ │ Monitor │ │ Interceptor │ │ Exporter │ │
│ └──────────────┘ └──────────────┘ └──────────────┘ │
│ ┌──────────────┐ ┌──────────────┐ ┌──────────────┐ │
│ │ MemoryStore │ │ FileStore │ │ QueryService │ │
│ └──────────────┘ └──────────────┘ └──────────────┘ │
└─────────────────────────────────────────────────────────┘

核心模块

过滤表达式

# 按模型过滤
model:gpt-4
# 按状态过滤
state:completed
state:error
# 按 Provider 过滤
provider:openai
provider:claude
# 按 Token 数量过滤
tokens:>1000
tokens:<500
# 按延迟过滤
latency:>2000 # 大于 2 秒
# 组合过滤
model:gpt-4 AND state:completed
provider:openai OR provider:claude
NOT state:error
# 内容搜索
content:"hello world"
request:"system prompt"
response:"error"

数据模型

LLMFlow

interface LLMFlow {
 id: string; // 唯一标识
 flow_type: FlowType; // 流类型
 state: FlowState; // 状态
 request: LLMRequest; // 请求
 response?: LLMResponse; // 响应
 error?: FlowError; // 错误信息
 metadata: FlowMetadata; // 元数据
 timestamps: FlowTimestamps; // 时间戳
 annotations: FlowAnnotations; // 注解
}

FlowState

enum FlowState {
 Pending, // 等待中
 Streaming, // 流式传输中
 Completed, // 已完成
 Error, // 错误
 Cancelled, // 已取消
 Intercepted, // 已拦截
}

配置

默认配置

{
 "default_settings": {
 "max_flows_in_memory": 1000,
 "retention_days": 7,
 "auto_cleanup": true,
 "notification_enabled": true,
 "intercept_enabled": false
 }
}

环境变量

API 参考

获取 Flow 列表

const flows = await flowMonitorApi.getFlows({
 filter: "state:completed",
 sort_by: "timestamp",
 sort_order: "desc",
 page: 1,
 page_size: 50,
});

获取 Flow 详情

const flow = await flowMonitorApi.getFlow(flowId);

导出 Flow

const result = await flowMonitorApi.exportFlows({
 flow_ids: ["flow-1", "flow-2"],
 format: "har",
 options: {
 include_request_body: true,
 include_response_body: true,
 redact_sensitive: true,
 },
});

生成代码

const code = await flowMonitorApi.generateCode(flowId, {
 format: "python",
 include_comments: true,
});

开发

技术栈

目录结构

flow-monitor/
├── src/ # 前端源码
│ ├── components/ # React 组件
│ ├── hooks/ # React Hooks
│ ├── lib/ # 工具库和 API
│ └── pages/ # 页面组件
├── src-tauri/ # Rust 后端
│ └── src/
│ ├── flow_monitor/ # 核心模块
│ └── commands/ # Tauri 命令
├── plugin/ # 插件配置
└── .github/workflows/ # CI/CD

构建

# 开发模式
npm run tauri:dev
# 生产构建
npm run tauri:build
# 仅构建 CLI
cd src-tauri && cargo build --release --bin flow-monitor-cli

测试

# Rust 测试
cd src-tauri && cargo test
# 前端测试
npm test

路线图

贡献

许可证

相关项目

致谢