语音助手编排服务

Blink MCP Orchestrator是Blink语音助手的核心服务,负责连接用户语音输入、OpenAI LLM意图识别、n8n工作流处理、POS系统对接及数据分析,实现全流程自动化交互。

  • by balbonis
  • Python
  • 本地部署
  • 更新于
在 GitHub 查看 balbonis/blinksbuy_mcp_orchestrator

使用说明

闪烁MCP编排器

这项服务是 大脑 在您的Blink语音助手后面。

它连接:

  • 用户语音(来自listen_channel小部件)
  • OpenAI LLM(用于意图+实体提取)
  • n8n工作流程(菜单、电话验证、订单处理)
  • POS MCP编排器(占位符切换)
  • 分析(记录到n8n)

🧠 高水位流量

  1. 用户对着 listen_client小部件
  2. 小部件发送STT文本→ /orchestrate 在此服务器上
  3. 编排者:
    • 从加载会话上下文 MemoryStore
    • 用途 LLMBasedIntentRouter 分类:
      • get_menu
      • provide_phone
      • provide_address
      • place_order
      • chitchat / unknown
    • 通过拨打n8n N8NGateway (菜单、电话、订单)
    • 通过以下方式验证项目与菜单 MenuValidator
    • 通过向POS MCP发送订单摘要 POSGateway (占位符)
    • 通过向n8n发送分析 AnalyticsGateway
  4. 返回自然语言回复→ 小部件
  5. Widget向ElevenLabs TTS发送回复并播放音频

📁 项目结构

mcp_orchestrator/
├─ app.py                      # FastAPI entrypoint
├─ orchestration/
│  ├─ agent_core.py            # Main orchestrator brain
│  ├─ llm_router.py            # LLM-based intent + entity extraction
│  ├─ menu_validator.py        # Fuzzy menu item validation
│  ├─ n8n_gateway.py           # All calls to n8n webhooks
│  ├─ pos_gateway.py           # Handoff to POS MCP (placeholder)
│  ├─ analytics_gateway.py     # Analytics logs to n8n
│  ├─ session_context.py       # SessionContext, state, short-term memory
│  ├─ memory_store.py          # In-memory session store
│  ├─ models.py                # Pydantic models
│  └─ config.py                # Environment-based settings
├─ requirements.txt
├─ Procfile
└─ .env.example