吉鑫升andClaude Opus 4.7
4940e0d8ed
- 任务1: 用户管理/定时任务管理移入左下角菜单, 从侧边栏删除原入口
- 任务2: 管理员查看用户问答(读 LangGraph checkpoint)与记忆, 新增 admin_users 路由与审计页
- 任务3: 标签筛选改为顶部多选标签栏(OR), agents/skills/scheduled_tasks 三端
- 任务4: 新增 tool_call_metrics 表 + ToolMetricsMiddleware + tool-metrics 路由,
工具/技能调用统计并入大模型统计页, 含错误分类
- 技能识别: lead agent 经 read_file 加载 /mnt/skills/<cat>/<name>/SKILL.md 调用技能,
中间件扫描工具参数里的 skills/{public,custom}/{name}/ 路径还原 skill_name
- 单元测试 tests/test_tool_metrics_middleware.py (18 项全过)
- 附: SQLite->MySQL 切换后清理脚本
Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
60 lines
2.4 KiB
Python
60 lines
2.4 KiB
Python
"""ORM model for per-tool-call (skill-call) metrics."""
|
|
|
|
from __future__ import annotations
|
|
|
|
from datetime import UTC, datetime
|
|
|
|
from sqlalchemy import Integer, String, Text
|
|
from sqlalchemy.orm import Mapped, mapped_column
|
|
|
|
from deerflow.persistence.base import Base
|
|
from deerflow.persistence.types import BeijingDateTime
|
|
|
|
|
|
class ToolCallMetricRow(Base):
|
|
"""One row per completed (or failed) tool / skill invocation.
|
|
|
|
Unlike :class:`LlmCallMetricRow` this also captures *self-handled*
|
|
failures — search tools that swallow an HTTP 429/403 and return an error
|
|
payload instead of raising — so an admin can see "retrieval failed" /
|
|
"IP blocked" events that never surfaced as exceptions.
|
|
"""
|
|
|
|
__tablename__ = "tool_call_metrics"
|
|
|
|
id: Mapped[str] = mapped_column(String(64), primary_key=True)
|
|
created_at: Mapped[datetime] = mapped_column(BeijingDateTime(), default=lambda: datetime.now(UTC), index=True)
|
|
|
|
user_id: Mapped[str | None] = mapped_column(String(64), index=True)
|
|
thread_id: Mapped[str | None] = mapped_column(String(64), index=True)
|
|
run_id: Mapped[str | None] = mapped_column(String(64), index=True)
|
|
agent_name: Mapped[str | None] = mapped_column(String(128), index=True)
|
|
tool_name: Mapped[str | None] = mapped_column(String(128), index=True)
|
|
# The specific Agent Skill targeted by a skill tool call (from the call's
|
|
# ``name`` argument); null for non-skill tool calls.
|
|
skill_name: Mapped[str | None] = mapped_column(String(128), index=True)
|
|
|
|
duration_ms: Mapped[int] = mapped_column(Integer, default=0)
|
|
|
|
# "success" or "error".
|
|
status: Mapped[str] = mapped_column(String(16), default="success", index=True)
|
|
# Coarse failure bucket; null on success.
|
|
error_category: Mapped[str | None] = mapped_column(String(32), index=True)
|
|
error_message: Mapped[str | None] = mapped_column(Text)
|
|
|
|
def to_dict(self) -> dict:
|
|
return {
|
|
"id": self.id,
|
|
"created_at": self.created_at.isoformat() if isinstance(self.created_at, datetime) else self.created_at,
|
|
"user_id": self.user_id,
|
|
"thread_id": self.thread_id,
|
|
"run_id": self.run_id,
|
|
"agent_name": self.agent_name,
|
|
"tool_name": self.tool_name,
|
|
"skill_name": self.skill_name,
|
|
"duration_ms": self.duration_ms,
|
|
"status": self.status,
|
|
"error_category": self.error_category,
|
|
"error_message": self.error_message,
|
|
}
|