1. 项目缘起当数据查询遇上即时通讯最近在做一个内部数据中台项目时遇到了一个挺典型的痛点业务部门的同事尤其是非技术背景的运营、产品同学经常需要查询一些业务数据。他们要么得在复杂的BI系统里自己拖拽报表要么就得在群里我们描述半天需求我们再手动写SQL、跑脚本、截图发回去。一来一回沟通成本高效率低还容易出错。我们就在想能不能做一个“数据助手”让它能像同事一样在群里直接回答数据问题比如运营同学在钉钉或飞书群里问一句“昨天我们App的日活是多少”这个助手就能自动理解问题去数据库里查然后把结果用清晰的表格或图表发回群里。这就是“DataClaw”这个项目想法的雏形。它本质上是一个自治数据代理核心目标是将数据查询与分析能力无缝集成到日常的即时通讯工具中让数据获取变得像聊天一样自然。这不仅仅是做一个简单的“SQL机器人”而是希望它能理解自然语言意图自主规划查询步骤并利用历史对话记忆来优化回答形成一个真正智能的交互闭环。市面上虽然有一些类似工具但要么集成度不够要么智能化程度有限我们希望能打造一个更贴合实际业务场景、更“懂行”的解决方案。2. 核心架构拆解从接收到响应的智能链路DataClaw的设计不是一蹴而就的我们参考了当前AI Agent领域的一些成熟范式并结合数据查询这个垂直场景做了大量定制。整个系统的核心工作流可以概括为“感知-思考-行动-学习”的循环其架构主要围绕以下几个关键模块构建。2.1 消息接入与意图理解层这是整个系统的“耳朵”和“大脑皮层”。我们首先需要让DataClaw能“听到”群里的消息。2.1.1 即时通讯平台适配器我们选择了飞书和钉钉作为首批集成平台因为它们在国内企业中的普及率最高。这里的关键不是简单地调用官方Webhook而是要处理完整的会话上下文。我们为每个平台开发了一个轻量级的适配器Adapter主要职责是监听消息通过平台提供的机器人API监听指定群组中机器人的消息或私聊消息。标准化消息格式将不同平台格式各异的消息体包括文本、图片、文件等统一转换成系统内部的标准化结构。例如提取发送者ID、消息内容、会话ID、消息类型等。管理会话状态维护一个会话映射表将外部平台的会话如飞书的chat_id与DataClaw内部的会话上下文关联起来。这对于后续的记忆功能至关重要。2.1.2 自然语言理解与意图分类用户的问题可能是模糊的、口语化的。比如“上个月卖得最好的产品是哪个”和“给我看看七月份的销售冠军”表达不同但意图相同。这一步的目标是将自然语言转化为结构化的查询意图。 我们最初尝试了简单的关键词匹配但发现泛化能力太差。后来采用了基于预训练语言模型如BERT或类似轻量级模型的意图分类模型。我们将常见的查询意图分成了几大类指标查询询问具体的数值指标如DAU、GMV、订单量等。通常对应简单的聚合查询SELECT SUM(...) FROM ... WHERE ...。维度分析询问按某个维度如地区、渠道、产品类别的分布或排名。对应GROUP BY查询。趋势查询询问数据随时间的变化如“最近一周的日活趋势”。对应时间序列查询。对比查询如“对比一下A产品和B产品本季度的收入”。明细查询请求查看原始数据或详细列表通常需要分页。澄清与反问当用户问题模糊时Agent需要主动提问澄清例如“您指的是哪个地区的销售额”模型会对输入的问题进行意图分类和实体抽取如时间实体“昨天”、“Q3”指标实体“销售额”维度实体“华东区”输出一个结构化的意图表示Intent作为后续规划的基础。2.2 基于ReAct范式的推理与规划引擎这是DataClaw的“思考中枢”也是其“自治”能力的核心体现。我们采用了经典的ReActReasoning Acting框架来驱动整个决策过程。ReAct的核心思想是让Agent交替进行“推理”和“行动”通过内部“思考”来指导外部“动作”。2.2.1 ReAct循环的具体实现当接收到一个结构化意图后规划引擎会启动一个ReAct循环。我们使用一个强大的大语言模型作为“推理”的核心例如通过API调用GPT-4或部署开源模型如DeepSeek并为其设计了一套清晰的提示词Prompt模板。这个模板会告诉LLM目标用户想查询什么。可用工具系统目前有哪些“手脚”即下一节会讲到的“工具集”比如query_database、get_table_schema、calculate_growth_rate等并详细描述每个工具的用途和输入格式。历史当前会话的记忆由记忆系统提供见2.3节。输出格式要求LLM严格按照“Thought: ... Action: ... Action Input: ...”的格式输出。一个典型循环如下Thought: “用户想查询昨天的DAU。我需要先确认‘昨天’的具体日期然后去‘user_activity’表中查询该日期的去重用户数。”Action:query_databaseAction Input:{“sql”: “SELECT COUNT(DISTINCT user_id) AS dau FROM user_activity WHERE date ‘2023-10-26’”, “db”: “bi_core”}系统执行query_database工具得到结果比如{dau: 1250000}后会将这个观察结果Observation连同之前的记录一起再次喂给LLM。Thought: “查询得到昨天DAU是125万。用户可能还想知道环比变化。我可以计算一下与前天DAU的环比增长率。”Action:calculate_growth_rateAction Input:{“current_value”: 1250000, “previous_value”: 1220000, “metric_name”: “DAU”}如此循环直到LLM认为已经充分回答了用户问题最终输出一个“Final Answer”动作将收集到的所有信息整合成一段面向用户的自然语言回答。2.2.2 为什么选择ReAct相比直接让LLM生成SQLReAct范式有几个显著优势可解释性强每一步的“Thought”都记录了Agent的思考过程这极大方便了调试和追溯。当查询结果出错时我们可以清晰地看到是哪个推理环节出了问题。容错与恢复能力强如果某个工具执行失败比如SQL语法错误或数据库超时观察结果会是错误信息。LLM可以根据这个错误进行反思调整策略例如重写SQL或选择另一个工具而不是直接崩溃。支持复杂多步查询对于“计算上个月销售额最高的三个品类并分别列出它们的同比增速”这类复杂问题ReAct可以自然地将其分解为多个顺序或并行的子任务。2.3 动态工具集Agent的“瑞士军刀”工具Tools是ReAct框架中“Act”的具体执行者。DataClaw的工具集被设计成可插拔、可扩展的。2.3.1 核心数据工具get_table_schema: 根据表名获取字段名、类型和注释。这是安全且高效查询的基础避免Agent对不存在的字段进行操作。query_database: 执行SQL查询。这是最核心的工具。这里有一个关键的安全设计我们并没有给Agent直接的数据库写权限甚至读权限也通过一个中间层进行了管控。所有通过此工具执行的SQL都会先经过一个SQL审核与重写层。该层会做几件事禁止DELETE、UPDATE、DROP等危险操作。自动为查询加上行级限制例如LIMIT 1000防止全表扫描拖垮数据库。根据用户身份动态在WHERE条件中注入数据权限过滤条件例如销售只能看到自己区域的数据。explain_sql: 解释SQL的执行计划当查询较慢时Agent可以调用此工具分析性能瓶颈甚至尝试优化。query_metric_platform: 直接查询预定义的指标平台API。对于一些已经固化、计算复杂的核心指标如“毛利率”直接调用指标平台比实时计算更准确、高效。2.3.2 分析与可视化工具calculate_growth_rate/calculate_percentage: 进行简单的数学计算。generate_chart: 根据查询结果的数据结构自动选择合适的图表类型折线图用于趋势柱状图用于对比饼图用于占比并调用绘图库如Matplotlib或ECharts生成图片。format_to_markdown_table: 将查询结果集格式化为美观的Markdown表格这在IM中展示数据非常清晰。工具的注册和管理通过一个中央注册表完成。开发新功能时我们只需要按照接口规范实现一个新的工具类并注册Agent在下一个推理周期就能自动识别并使用它实现了能力的无缝扩展。2.4 记忆系统让对话拥有“上下文”没有记忆的Agent就像金鱼每次对话都是全新的开始。DataClaw的记忆系统旨在解决这个问题它由几个部分组成2.4.1 短期会话记忆存储在内存或Redis中键为会话ID。它完整记录了当前会话中所有的用户消息、Agent的Thought-Action-Observation链、以及最终的回答。这直接服务于ReAct循环让LLM能知道“刚才我们说到哪了”。例如用户问“DAU是多少”接着问“那MAU呢”Agent需要能理解“那”指的是同一个时间范围。2.4.2 长期实体记忆这是一个向量数据库我们选用ChromaDB。它的作用是记住跨会话的、关于“实体”的知识。例如业务术语映射当新用户第一次问“GMV”时Agent通过查询和澄清得知“GMV”在本公司特指“orders表中statuspaid的amount字段之和”。这个映射关系会被向量化后存入长期记忆。用户偏好某位产品经理总是喜欢看“按渠道细分”的数据这个偏好可以被记录。历史复杂查询一个成功的、多步的复杂查询可以被抽象成“查询模式”存储下来。当新的查询进来时除了短期记忆系统还会从向量数据库中检索相关的长期记忆片段作为上下文提供给LLM。这能让Agent的回答越来越“个性化”和“专业化”。2.4.3 记忆的更新与衰减记忆不是只增不减的。我们设计了简单的衰减机制和手动清理接口。对于长期未使用的记忆片段其重要性权重会降低。业务指标口径发生变更时管理员可以主动更新或删除相关的记忆确保信息的准确性。3. 关键技术选型与实战踩坑构建这样一个系统技术选型直接关系到开发效率和最终效果。下面分享我们的一些决策和遇到的典型问题。3.1 LLM选型效果、成本与可控性的平衡LLM是大脑选型至关重要。我们评估了几个方向闭源大模型API如GPT-4效果最好开发最简单但成本高、数据出境有合规风险、响应速度受网络影响。适合初期快速验证原型。国内大模型API如文心、通义、DeepSeek合规性好成本相对较低。但早期版本在复杂推理和指令跟随上有时不如GPT-4稳定需要更精细的Prompt工程。本地部署开源模型如Llama 3、Qwen系列、DeepSeek Coder数据最安全长期成本可能更低可控性最强。但对硬件有要求且需要一定的模型微调Fine-tuning和优化能力。我们的实践路径为了快速启动我们初期使用了GPT-4 API作为推理核心。在Prompt工程上下足了功夫设计了包含丰富示例Few-shot和严格格式要求的模板效果非常出色。同时我们并行在内部服务器上部署了Qwen-14B-Chat模型通过OpenAI兼容的API服务如vLLM或Ollama进行封装让我们的系统可以无缝切换后端LLM。经过大量测试和Prompt调整后Qwen在大多数常见查询任务上已经能达到接近GPT-4的水平我们便逐步将流量切到了自部署模型上在保证效果的同时控制了成本和安全。踩坑记录Prompt工程的魔鬼细节最初我们的Prompt写得比较简略导致LLM经常“放飞自我”不按格式输出或者使用不存在的工具。后来我们总结出几个关键点系统指令System Prompt要强硬开头必须明确角色、职责和绝对规则例如“你是一个严谨的数据分析师必须使用提供的工具严禁编造信息。”格式示例要极其具体在Few-shot部分不仅要给正确的例子还要给几个典型的错误输出例子并说明为什么错。这比只给正面例子有效得多。工具描述要结构化每个工具的名称、描述、输入参数JSON Schema格式、输出示例都必须清晰无误地提供给LLM。温度Temperature参数要调低对于这种需要严格遵循流程的任务我们将温度设为0.1或0.2以降低输出的随机性提高稳定性。3.2 数据库连接与查询安全这是数据项目的生命线。我们绝不允许Agent直接连接生产数据库。我们的架构专用查询从库为DataClaw单独搭建了一个只读的数据库从库同步延迟在分钟级这既隔离了负载也提供了基础的数据保护。查询网关与审计层所有query_database工具的请求都先发送到一个自研的“查询网关”。这个网关负责SQL解析与重写使用sqlparse等库解析SQL强制添加LIMIT拦截危险操作。权限注入根据当前请求的用户身份从IM上下文获取在SQL的WHERE条件中自动拼接对应的数据范围过滤条件。这部分逻辑与我们公司的统一权限中心对接。查询性能监控与熔断设置查询超时时间如30秒对复杂查询进行资源限制。记录所有查询的日志用于审计和优化。结果集处理与脱敏对查询结果中的敏感字段如手机号、邮箱进行脱敏处理后再返回给Agent。踩过的坑有一次一个同事问了一个看似简单的问题“列出所有用户”。Agent生成的SQL是SELECT * FROM users。尽管有LIMIT 1000但这个查询没有WHERE条件直接全表扫描瞬间导致查询从库的CPU飙升影响了其他业务查询。我们立刻在网关层增加了规则对于没有WHERE条件的SELECT *查询除非目标表是明确的小型配置表否则一律拦截并返回警告要求用户添加过滤条件。同时我们优化了Agent的Prompt鼓励其在查询前先思考数据量级并主动向用户询问过滤维度。3.3 即时通讯集成的稳定性IM机器人对接看似简单但隐藏着稳定性陷阱。消息去重与幂等IM平台可能因为网络问题对同一个事件推送多次。我们的适配器必须根据平台提供的消息ID进行去重处理确保同一条用户指令不会被执行两次。异步与超时处理一个复杂查询可能需要十几秒而IM平台的机器人消息发送接口通常有超时限制如5秒。我们不能同步阻塞。我们的做法是收到消息后立即回复一个“正在思考...”的占位消息。然后将查询任务放入异步队列如Celery或Redis Queue中处理。处理完成后再通过机器人API更新之前的那条“占位消息”为最终结果。这提供了良好的用户体验。限流与配额IM平台对机器人调用API有频率限制。我们需要在系统层面实现全局限流避免因为突发的大量查询导致机器人被平台暂时禁用。4. 效果评估与迭代方向DataClaw上线后我们首先在一个约50人的产品运营团队内部进行了试点。效果评估查询效率简单指标查询的响应时间从平均15分钟人工处理缩短到10秒以内。使用频率试点群内日均主动查询量超过200次说明需求真实存在。准确率我们对前1000条交互进行了人工复核对于明确、常见的业务问题准确率返回结果正确且格式清晰达到92%以上。主要错误集中在模糊问题理解偏差和极复杂的多表关联查询上。用户反馈非技术同学反馈“找数据方便多了”数据分析师则反馈“从重复的取数工作中解放出来可以更专注于深度分析”。持续迭代方向复杂查询能力增强当前对需要多表JOIN、复杂子查询的场景处理还不够好。我们计划引入更强大的“数据图谱”模块将数据库中的表关系、字段业务含义以图谱形式存储辅助LLM进行更准确的查询规划。主动洞察与预警不止于被动问答。我们正在尝试让DataClaw具备“主动说话”的能力。例如定时分析核心指标发现异常波动如DAU突然下跌20%时自动在相关群组发出预警并附上初步的下钻分析线索。多模态输入支持用户上传Excel或截图让Agent能读取文件中的数据或结合截图中的图表进行解读和分析。记忆系统的深度利用基于长期记忆实现“个性化数据简报”。例如每周一早上自动向每位总监推送其负责业务线的核心指标周报。构建DataClaw的过程是一个将前沿的AI Agent理念与传统的企业数据栈深度融合的过程。它不是一个炫技的玩具而是一个切实提升效率、降低数据获取门槛的工具。最大的体会是技术方案的选择必须紧密围绕业务场景在效果、成本、安全和易用性之间找到最佳平衡点。例如用ReAct框架而不是简单的端到端模型虽然增加了复杂度但带来了可解释性和可靠性这在企业级应用中是不可妥协的。未来随着多模态和代码生成能力的进步这类自治数据代理的潜力会更大或许真的能成为每个团队里的那个“最懂数据的同事”。