技术文档摘要

SSB MCP Server

显示可用流和作业的主页仪表板，突出展示了SSB MCP Server集成的品牌标识。

提供对SQL Stream Builder（SSB）全面访问的模型上下文协议服务器，支持直接访问SSB和与Apache Knox的集成。

适用于独立部署的SSB和Cloudera Data Platform（CDP）SSB部署 - 通过Claude Desktop提供对SSB功能的完全访问。

功能

• 多种身份验证方法：
  • 直接SSB身份验证：针对独立部署的基本认证
  • Knox集成：针对CDP部署的Bearer令牌、Cookie和通行码令牌
• 默认只读模式 - 安全地探索SSB流和配置
• 全面覆盖SSB API，包含80+ MCP工具，用于完整的SSB管理：
  • 高级作业管理：事件历史记录、状态管理、作业复制、数据源克隆
  • 监控与诊断：系统健康状况、性能计数器、SQL分析
  • 增强表管理：详细表信息、层次结构、验证、创建
  • 连接器及格式管理：数据格式、连接器详情、JAR信息
  • 用户及项目管理：设置、项目、用户信息、项目创建
  • API密钥管理：密钥生命周期管理、创建、删除、详情
  • 环境管理：环境切换、配置、创建
  • 同步与配置：项目导出/导入、同步管理、验证
  • UDF管理：UDF生命周期、执行、工件、自定义函数
  • 流管理：列出、创建、更新、删除、启动、停止SQL流
  • 查询执行：执行SQL查询并获取实时结果及采样
  • 样本数据访问：从运行中的作业中检索流数据样本
  • 作业管理：监控作业状态、获取作业详情、管理作业生命周期
  • 模式发现：探索表模式和可用表
  • 函数管理：列出并检查用户定义的函数
  • 连接器管理：探索可用的连接器
  • Kafka集成：列出并检查Kafka主题
  • 集群监控：获取集群信息和健康状态
  • 性能指标：监控流性能和指标

快速开始

对于独立部署的SSB（Docker Compose）

1. 启动SSB服务：

   git clone https://github.com/your-org/ssb-mcp-server.git
   cd ssb-mcp-server
   docker-compose up -d
   

2. 配置Claude Desktop - 编辑 ~/Library/Application Support/Claude/claude_desktop_config.json：

   {
     "mcpServers": {
       "ssb-mcp-server": {
         "command": "/FULL/PATH/TO/SSB-MCP-Server/run_mcp_server.sh",
         "args": [],
         "cwd": "/FULL/PATH/TO/SSB-MCP-Server"
       }
     }
   }
   

3. 重启Claude Desktop 并开始与您的SSB流互动！

对于CDP SSB部署

您的SSB API基础URL通常是：

https://<your-ssb-host>/ssb/api/v1

从CDP UI获取您的Knox JWT令牌，并使用以下配置。

设置

选项1：Claude Desktop（本地）

1. 克隆并安装：

   git clone https://github.com/your-org/ssb-mcp-server.git
   cd ssb-mcp-server
   python3 -m venv .venv
   source .venv/bin/activate
   pip install -e .
   

2. 配置Claude Desktop - 编辑 ~/Library/Application Support/Claude/claude_desktop_config.json：

    {
      "mcpServers": {
        "ssb-mcp-server": {
          "command": "/FULL/PATH/TO/SSB-MCP-Server/.venv/bin/python",
          "args": [
            "-m",
            "ssb_mcp_server.server"
          ],
          "env": {
            "MCP_TRANSPORT": "stdio",
            "SSB_API_BASE": "https://ssb-gateway.yourshere.cloudera.site/ssb/api/v1",
            "KNOX_TOKEN": "<your_knox_bearer_token>",
            "SSB_READONLY": "true"
          }
        }
      }
    }
   

3. 重启Claude Desktop 并开始询问有关您的SSB流的问题！

选项2：Cloudera AI Agent Studio

对于Cloudera AI Agent Studio的使用，通过环境变量进行配置：

{
  "mcpServers": {
    "ssb-mcp-server": {
      "command": "uvx",
      "args": [
        "--from",
        "git+https://github.com/your-org/ssb-mcp-server@main",
        "run-server"
      ],
      "env": {
        "MCP_TRANSPORT": "stdio",
        "SSB_BASE_URL": "https://your-ssb-host:443",
        "SSB_TENANT": "your-tenant-name",
        "KNOX_TOKEN": "your_jwt_token_here",
        "MVE_USERNAME": "your_mve_username",
        "MVE_PASSWORD": "your_mve_password",
        "SSB_READONLY": "false"
      }
    }
  }
}

配置模板：使用 config/cloudera_ai_agent_studio_template.json 作为起点。

Cloudera AI Agent Studio的环境变量：

export SSB_BASE_URL="https://your-ssb-host:443"
export SSB_TENANT="your-tenant-name"
export KNOX_TOKEN="your_jwt_token_here"
export MVE_USERNAME="your_mve_username"
export MVE_PASSWORD="your_mve_password"
export SSB_READONLY="false"

配置选项

可以通过环境变量或JSON配置文件进行配置。环境变量优先于JSON配置文件。

JSON配置文件

MCP服务器可以从 config/cloud_ssb_config.json 加载配置：

{
  "cloud_ssb": {
    "base_url": "https://your-ssb-host:443",
    "tenant": "your-tenant-name",
    "jwt_token": "your_jwt_token_here",
    "ssb_readonly": false,
    "knox_verify_ssl": true,
    "http_timeout_seconds": 60,
    "http_max_retries": [...]
}