Skip to main content
Glama
deenesjakoruzh
niteshwalia0124

cymbal-kiosk-tools-apm

by niteshwalia0124
OverviewSchemaRelated ServersScoreDiscussions
Python
Remote

⚙️ Cymbal Life — 智能分行自助终端模块化 MCP 工具、精算引擎与 BigQuery APM 分析

Google Cloud ADK Model Context Protocol AlloyDB BigQuery APM Cloud Run License

一个面向 Cymbal Life 智能分行自助终端的企业级、解耦的 模块化 MCP 工具、精算决策引擎与 BigQuery APM 分析平台，构建于 Google Agent Development Kit（ADK）、Model Context Protocol（MCP）、Google AlloyDB for PostgreSQL 和 Google BigQuery 之上。

该服务提供模块化工具执行微服务、对 AlloyDB 的亚 5ms VPC 数据库查询、实时精算贷款与退保对比、分行内 VIP 排队叫号生成，以及全面的 BigQuery 应用性能监控（APM）。

🏛️ 高层级系统架构

Cymbal Life 智能分行终端 MCP 工具与 APM 架构

架构概述

系统划分为四个不同的运行层面：

  1. 客户端与分行内自助终端层：

    • 智能自助终端触摸界面：高分辨率触摸屏终端，实时显示保单详情卡、贷款计算器和排队号码牌。

    • AudioWorklet 处理器：从分行麦克风采集 16kHz 线性 PCM 音频。

    • 实时终端遥测监控器：展示实时函数调用、服务器延迟和工具参数。

  2. 实时流式网关与 ADK Agent 核心（Cloud Run）：

    • FastAPI 异步 WebSocket 桥接（/ws/live）：将双向音视频流代理到 Vertex AI Gemini Live API。

    • ADK 虚拟分行顾问 Agent（“Priya”）：协调客户意图，验证投保人身份并执行领域工具。

    • 实时事件遥测广播器（_notify_ui）：将实时事件查询结果和精算计算卡片推送到终端屏幕。

  3. 模块化 Model Context Protocol（MCP）工具层：

    • policy_tools 微服务：对 AlloyDB 执行实时 SQL 查询，获取客户 KYC、方案信息和已缴保费总额。

    • actuarial_tools 决策引擎：精确计算退保罚金（-₹4.2L）与终端即时保单贷款（₹4.8L，年化 8.5%）之间的财务权衡。

    • branch_tools 运营微服务：生成 VIP 排队升级凭证（#RET-04），分配至 Cabin 2，并通过 WhatsApp 发送数字小票。

  4. 企业数据、APM 分析与全渠道层：

    • Google AlloyDB for PostgreSQL：管理客户 KYC 记录、活跃保单、退保计划和升级凭证的企业数据库集群，支持亚 5ms VPC 查询。

    • Google BigQuery APM 与 Agent 分析套件：记录逐轮转的 Agent 轨迹、工具延迟、Token 消耗和留存转化漏斗。

    • Twilio WhatsApp Business API：向客户手机号码发送数字 VIP 凭证和分行 C城市路线图。

Related MCP server: MCP Business AI Transformation

🧰 模块化 MCP 工具目录

工具微服务位于 backend/tools/ 目录下：

工具模块

函数名

类别

描述

[policy_tools.py](backend/tools/policy_tools.py)

lookup_policyholder_details

核心银行

针对客户 KYC、方案信息、已缴保费总额（₹6.0L）、退保现金价值（₹3.8L）和保证利益（₹18L）的实时 AlloyDB 查询。

[actuarial_tools.py](backend/tools/actuarial_tools.py)

return_surrender_penalty_vs_loan

精算引擎

对比退保损失（-₹4.2L）与即时终端保单贷款（₹4.8L @ 8.5%）及减额缴清状态的财务权衡。

[branch_tools.py](backend/tools/branch_tools.py)

issue_in_branch_vip_token

运营

生成分行内 VIP 升级凭证（#RET-04）、分配给分行负责人 Mr. Vikram Mehta，并触发 WhatsApp 凭证推送。

📊 BigQuery APM 与 Agent 分析套件

该平台包含一套完整的 BigQuery 应用性能监控（APM）套件，详见 docs/ANALYTICS_QUERIES.md：

  • 会话轨迹与工具执行审计：跟踪逐轮调用的工具调用与执行耗时。

  • 感知延迟与 P95 分布：监控语音到工具的往返延迟（目标 <150ms）。

  • 留存转化与保单贷 Use：衡量有多少退保意向客户转化为即时终端的保单贷款。

  • 分行队列与 VIP 升级 APM：跟踪各分行经理室中升级票据的解决时间。

📁 仓库结构

cymbal-kiosk-tools-apm/
├── docs/
│   ├── architecture.jpg        # High-level architecture block diagram
│   ├── ARCHITECTURE.md         # Full enterprise architecture specification
│   └── ANALYTICS_QUERIES.md    # BigQuery APM SQL queries & trajectory audit
├── pyproject.toml              # Dependencies (google-adk, fastapi, psycopg2-binary, uvicorn)
├── requirements.txt            # Python dependencies
├── run.sh                      # Local startup script
├── Dockerfile                  # Production container spec
├── .gitignore
├── .env.example                # Environment configuration template
├── backend/
│   ├── __init__.py
│   ├── agent.py                # ADK Agent definition & retention prompt
│   ├── database.py             # Google AlloyDB PostgreSQL connector (psycopg2)
│   ├── mcp_tools.py            # MCP tools facade & WebSocket telemetry broadcaster
│   ├── analytics.py            # BigQuery agent analytics plugin
│   ├── avatar.png              # Assistant avatar asset
│   ├── server.py               # FastAPI WebSocket /ws/live endpoint
│   └── tools/                  # Modular MCP Tool Microservices
│       ├── __init__.py
│       ├── policy_tools.py     # Policy lookup microservice
│       ├── actuarial_tools.py  # Actuarial decision engine
│       └── branch_tools.py     # VIP escalation & WhatsApp dispatcher
└── frontend/
    ├── index.html              # Kiosk terminal touch interface
    ├── style.css               # Cymbal Life corporate styling
    ├── app.js                  # WebSocket client & telemetry renderer
    └── dashboard.html          # Executive APM Analytics Dashboard

🚀 快速开始指南

前置条件

  • Python：3.11 至 3.13

  • Google Cloud SDK (gcloud)：已配置可用的 GCP 项目。

  • Google AlloyDB for PostgreSQL：可访问的群集，包含客户、KYC 和保单表。

第 1 步：克隆仓库并配置环境

git clone https://github.com/niteshwalia0124/cymbal-kiosk-tools-apm.git
cd cymbal-kiosk-tools-apm

# Create .env from template
cp .env.example .env

配置您的 .env 变量：

GOOGLE_GENAI_USE_VERTEXAI=true
GOOGLE_CLOUD_PROJECT=your-gcp-project-id
GOOGLE_CLOUD_LOCATION=us-central1
PORT=8080
AVATAR_NAME=Priya

# AlloyDB / Cloud SQL PostgreSQL Connection
DB_USER=postgres
DB_PASS=your-database-password
DB_NAME=postgres
DB_HOST=10.48.19.2
DB_PORT=5432

# Twilio WhatsApp (Optional)
TWILIO_ACCOUNT_SID=
TWILIO_AUTH_TOKEN=
TWILIO_WHATSAPP_FROM=whatsapp:+14155238886

# BigQuery Agent Analytics
BIGQUERY_PROJECT_ID=your-gcp-project-id
BIGQUERY_DATASET_ID=cymbal_kiosk_analytics
BIGQUERY_TABLE_ID=agent_trajectory_logs

使用 Google Cloud 进行身份验证：

gcloud auth application-default login
gcloud config set project your-gcp-project-id

第 2 步：本地运行

chmod +x run.sh
./run.sh

打开浏览器访问 http://localhost:8080，与终端工具和遥测看板进行交互。

🐳 Cloud Run 部署

通过 AlloyDB 的 VPC 对等内容，将模块化工具服务部署到 Google Cloud Run：

export PROJECT_ID=$(gcloud config get-value project)
export REGION="us-central1"
export SERVICE_NAME="cymbal-kiosk-tools-apm"

gcloud run deploy $SERVICE_NAME \
  --source . \
  --region $REGION \
  --project $PROJECT_ID \
  --allow-unauthenticated \
  --set-env-vars GOOGLE_CLOUD_PROJECT=$PROJECT_ID,GOOGLE_CLOUD_LOCATION=$REGION,DB_HOST=10.48.19.2 \
  --vpc-connector="projects/$PROJECT_ID/locations/$REGION/connectors/kiosk-vpc-connector" \
  --memory 2Gi \
  --cpu 2 \
  --timeout 3600

📄 许可证

本项目基于 Apache 2.0 License - 详见 LICENSE 文件。

This server cannot be installed

F
license - not found
Not graded
quality - not tested
C
maintenance

How are these scores calculated?

Resources

Unclaimed servers have limited discoverability.

Looking for Admin?

If you are the server author, to access and configure the admin panel.

Related MCP Servers

  • Azure AI MCP Server

    caiotk
    A
    license
    Not graded
    quality
    D
    maintenance
    Enables comprehensive integration with Azure AI services including OpenAI, Cognitive Services, Computer Vision, and Face API through a mission-critical MCP server. Provides enterprise-grade reliability with high availability, observability, chaos engineering, and secure multi-region deployment capabilities.
    MIT

  • MCP Business AI Transformation

    Vovchansky6
    F
    license
    Not graded
    quality
    C
    maintenance
    Enterprise-grade MCP server with multi-agent system for business AI transformation across finance, healthcare, retail, and other domains. Provides specialized AI agents for data analysis, API execution, business validation, and report generation with real-time monitoring and observability.

  • COBOL Bridge MCP Server

    CSOAI-ORG
    A
    license
    Not graded
    quality
    Not graded
    maintenance
    Connects legacy COBOL mainframe systems to modern AI governance via MCP, with tools for parsing copybooks, assessing CICS, scanning JCL, mapping VSAM, and translating EBCDIC.
    1
    MIT

View all related MCP servers

Related MCP Connectors

  • Perspective AI

    An AI concierge that turns static forms into adaptive AI conversations. From any MCP client.

  • DATPAQ

    34 production API tools over one hosted MCP endpoint.

  • a2areplayreceipt-mcp

    Remote MCP for A2A failure replay MCP, structured receipts, audit logs, and reviewer-ready evidence.

View all MCP Connectors

Latest Blog Posts

MCP directory API

We provide all the information about MCP servers via our MCP API.

curl -X GET 'https://glama.ai/api/mcp/v1/servers/niteshwalia0124/cymbal-kiosk-tools-apm'

If you have feedback or need assistance with the MCP directory API, please join our Discord server