当前位置: 首页 > news >正文

使用 Elasticsearch Agent Builder 构建对话式费用助手,结合 Telegram 、 n8n 和 AWS Bedrock

作者:来自 Elastic _som

你是否希望可以直接和你的费用数据对话?

可以这样问:

“我上周花了多少钱?”
“显示我这个月的餐饮支出。”
“添加我昨天用 信用卡 支付的 350 的晚餐费用。”

这个项目将这些自然语言消息,甚至语音消息,转换为结构化数据和可搜索的洞察,使用了:

  • Telegram 作为聊天 UI
  • n8n 作为工作流编排器
  • AWS Bedrock(本示例中使用 Claude 3.5 Sonnet)用于意图分类、数据写入和对话式查询 agent(你可以替换为任何你选择的 LLM)
  • Sarvam Speech-to-Text 用于语音转写(你也可以接入 Whisper、Deepgram、AssemblyAI,或任何你觉得合适的方案)
  • Elasticsearch Agent Builder + MCP 负责存储、语义搜索,以及自定义 ES|QL 函数调用工具

另外,还准备了一个单独的 Colab notebook,用于自动部署整个 n8n 工作流,这是临时的。对于长期运行的 n8n 服务,建议你将其部署在你自己的服务器上,而不是使用 Colab。

这个系统做了什么

  • 将语音 → 文本
  • 判断消息类型是:
    • INGEST(“我在午餐上花了 250”)
    • QUERY(“我上个月花了多少钱?”)
  • 将结构化 JSON 和语义 embedding 写入 Elasticsearch
  • 使用 Agent Builder 工具运行有上下文的 ES|QL 查询
  • 在 Telegram 中返回友好的回复
  • 在分类置信度较低时,通过交互式澄清步骤来处理

n8n 架构一览

流程

Telegram → n8n( STT → Classifier → Ingest / Query 路由)→ AWS Bedrock LLMs → Elasticsearch(索引 + 使用 MCP 的语义搜索)→ Elastic Agent Builder 工具 → Telegram 响应

关键节点 / 组件

n8n Workflow

  • Telegram Trigger
  • 语音 / 文本 切换
  • STT 请求
  • Classifier agent
  • Ingestion agent
  • 通过 Agent Builder MCP 的 Query agent
  • Elasticsearch indexer
  • 低置信度门控

Elasticsearch

  • 启用带有 Bedrock embeddings 的 semantic_text 字段
  • 干净的索引 mapping( amount 、 merchant 、 category 、 ts / @timestamp 、 raw_transcript )
  • 使用 ES|QL 构建的 Agent Builder 工具

AWS Bedrock

  • Claude 3.5 Sonnet v2 用于:
  • Intent 分类
  • Expense JSON 提取
  • Query agent 推理(通过 MCP 进行函数调用)

自己动手试试( 一键设置 )

我把所有内容都打包在这个 Colab notebook 里:

Colab

https://colab.research.google.com/gist/someshwaranM/b5d21d51a6a9a9cc96e62b05c97ac203/som-expense-tool-colab.ipynb

Colab 为你做了什么:

  • 在 Colab 内启动 n8n,进行临时设置
  • 通过 Cloudflare Tunnel 将其暴露到互联网上
  • 通过 API 在 n8n 中创建 AWS、ES、Telegram 凭证
  • 安装完整的工作流模板
  • 设置 Elasticsearch:
  • Bedrock 推理端点
  • 带 semantic_text 的索引 mapping
  • 提供批量写入工具,用于你的合成费用数据集
  • 让你可以立即从 Telegram 开始与你的 bot 对话

演示截图

  • Telegram 对话

  • Agent Builder(直接对话)

  • Elastic Agent Builder YouTube 视频
https://www.bilibili.com/video/BV1TcBsBVEoB/?spm_id_from=333.1387.homepage.video_card.click

总结

这个技术栈为你提供:

  • 一个对话式个人理财助手
  • 使用 Elastic Agent Builder 的完整语义 + 结构化搜索
  • 来自聊天或语音的实时写入

原文:https://discuss.elastic.co/t/dec-3rd-2025-en-build-a-conversational-expense-assistant-using-elasticsearch-agent-builder-with-telegram-n8n-and-aws-bedrock/383585

http://www.cnnetsun.cn/news/180863.html

相关文章:

  • springboot基于安卓的老年养护与智能服务系统
  • EasyGBS助力智慧医院打造全方位视频监控联网服务体系
  • 【收藏级】全面拆解GraphRAG:从原理到实践,大模型知识库升级必备
  • Java多态——Java的三大特性之一,零基础小白到精通,收藏这篇就够了
  • 【Open-AutoGLM元宇宙适配终极指南】:揭秘三大核心技术突破与落地实践
  • Open-AutoGLM如何实现自主学习?:深度剖析其进化机制与训练闭环设计
  • [驱动之路——GPIO子系统]学习总结,万字长篇,一文彻底搞懂GPIO子系统(含GPIO控制器驱动框架解析)
  • Open-AutoGLM如何重塑城市治理?:3个真实案例揭示AI协同调度的颠覆性力量
  • 智能体式AI实战指南:从零构建IT自动化系统,程序员必学收藏教程
  • 家长用Realme手机,怎样远程管理孩子iPhone的屏幕使用时长?
  • 【Open-AutoGLM智慧城市协同调度】:揭秘未来城市交通智能调度的5大核心技术
  • Java SpringBoot+Vue3+MyBatis 宠物爱心组织管理系统系统源码|前后端分离+MySQL数据库
  • 【Open-AutoGLM自动驾驶交互核心技术】:揭秘AI驱动的车载人机协同新范式
  • 揭秘Open-AutoGLM如何重构电子病历管理:医生工作效率翻倍的底层逻辑
  • NMOS的 G和D并联一个小电容作用和目的
  • 【网络空间安全】P2P网络及限制策略
  • Open-AutoGLM与AppDynamics监控策略剖析(仅限资深架构师掌握的3种模式)
  • 2025年北京大学计算机考研复试机试真题(附 AC 代码 + 解题思路)
  • 【高并发场景下的救星】:Open-AutoGLM智能会话销毁算法详解
  • 为什么你的请假申请总被驳回?,深度剖析Open-AutoGLM流程提交常见陷阱
  • 基于STM32自动售货机控制系统设计
  • Open-AutoGLM会话销毁机制大揭秘:如何实现毫秒级资源释放
  • 【光伏风电功率预测】调度员最需要什么样的 AI 预测?从一条曲线到“可执行方案”
  • 【企业级报销系统深度解读】:Open-AutoGLM单据提交的7个核心要点
  • 揭秘Open-AutoGLM会话超时机制:3步实现稳定可靠的对话控制
  • 别再盲目选型了,Open-AutoGLM与NeoLoad的3个核心差异你必须知道
  • 【Open-AutoGLM多模态理解突破】:揭秘下一代AI视觉语言模型核心技术
  • Open-AutoGLM与NeoLoad压测结果为何大相径庭(独家实测数据披露)
  • 稀缺技术揭秘:Open-AutoGLM分布式任务断点恢复的5个关键设计原则
  • 21世纪全球哲学灯塔:颜廷利——欧美认知度最高的华人思想家