KurrentDB MCP 服务器

KurrentDB MCP 服务器

通过直接访问 KurrentDB 的事件流和投影,提升 AI 工作流,增强 FlowHunt 中的快速开发、调试与分析能力。

“KurrentDB” MCP 服务器的作用是什么?

KurrentDB MCP 服务器是一款帮助 AI 助手和开发者无缝对接 KurrentDB(流式数据库)的工具。通过提供一系列工具和标准化操作,该服务器使客户端能够查询、读取、写入流数据,并可直接在 AI 开发环境中构建和管理投影。这种集成提升了工作流效率,例如可编程或通过自然语言检索事件流、记录新事件、创建数据投影。KurrentDB MCP 服务器简化了事件驱动数据的原型开发、调试与探索,尤其适用于利用 KurrentDB 的应用中的快速开发和分析。

提示模版列表

  • read_stream:用于从指定流检索事件的模版,支持方向和数量限制。
  • write_events_to_stream:用于向流中添加事件的模版,可指定事件类型、数据和元数据。
  • list_streams:用于列出现有流的模版,支持分页和方向。
  • build_projection:用于 AI 辅助描述和生成新投影的模版。
  • create_projection:用于根据规格创建投影的模版。
  • update_projection:用于更新现有投影的模版。
  • test_projection:用于使用示例数据测试投影的模版。
  • get_projections_status:用于检索所有投影状态的模版。

资源列表

  • 流数据:可访问 KurrentDB 中的流事件数据,实现读取和分析。
  • 流列表:数据库中可用流的列表及其元数据。
  • 投影:基于流数据定义和计算出来的视图(投影)。
  • 投影状态:现有投影的实时状态信息。

工具列表

  • read_stream:从指定流读取事件,可选择正序/倒序及数量。
  • write_events_to_stream:向流中添加新事件,可自定义数据、事件类型和元数据。
  • list_streams:返回 KurrentDB 实例中所有可用流的列表。
  • build_projection:利用 AI 按用户需求生成投影。
  • create_projection:在 KurrentDB 中创建新投影。
  • update_projection:用新规格更新现有投影。
  • test_projection:使用示例数据或场景测试投影。
  • get_projections_status:获取所有投影的状态和健康信息。

此 MCP 服务器的应用场景

  • 数据库事件探索:开发者可快速查看、筛选和分析任意 KurrentDB 流中的历史或实时事件数据,提升排障和审计效率。
  • 事件写入与日志记录:以编程方式直接将新事件(如用户操作、系统变更)写入数据库,实现健壮的事件溯源和可追溯性。
  • 投影开发与调试:快速构建、测试和优化投影,用于分析或衍生数据模型,加快数据驱动功能的反馈周期。
  • 流元数据发现:列出所有流并检查其结构或元数据,辅助架构设计或数据导航。
  • 运维监控:通过工具检查投影的健康和状态,确保关键数据转换过程正常运行。

如何配置

Windsurf

  1. 前置条件:确保已安装 Python,并且 KurrentDB 以开启投影的方式运行(--run-projections=all --start-standard-projections)。
  2. 找到配置文件:打开 .codeium/windsurf/mcp_config.json
  3. 添加 KurrentDB MCP 服务器
    {
      "mcpServers": {
        "kurrentdb": {
          "command": "python",
          "args": ["path to mcp-server folder\\server.py"],
          "env": {
            "KURRENTDB_CONNECTION_STRING": "insert kurrentdb connection here"
          }
        }
      }
    }
    
  4. 保存并重启:保存配置并重启 Windsurf。
  5. 验证配置:确认 MCP 服务器已激活并连接。

Claude

  1. 前置条件:已安装 Python,KurrentDB 按要求投影参数运行。
  2. 找到配置文件:编辑你的 Claude Desktop 配置文件。
  3. 添加 KurrentDB MCP 服务器
    {
      "servers": {
        "KurrentDB": {
          "type": "stdio",
          "command": "uv",
          "args": [
            "--directory",
            "path to mcp-server folder",
            "run",
            "server.py"
          ],
          "env": {
            "KURRENTDB_CONNECTION_STRING": "insert kurrentdb connection here"
          }
        }
      }
    }
    
  4. 保存并重启:保存并重启 Claude Desktop。
  5. 验证:确保 KurrentDB MCP 在 Claude 界面中显示。

Cursor

  1. 前置条件:如上已配置好 Python 和 KurrentDB。
  2. 找到配置文件:编辑 .cursor/mcp.json
  3. 添加 KurrentDB MCP 服务器
    {
      "mcpServers": {
        "kurrentdb": {
          "command": "python",
          "args": ["path to mcp-server folder\\server.py"],
          "env": {
            "KURRENTDB_CONNECTION_STRING": "insert kurrentdb connection here"
          }
        }
      }
    }
    
  4. 保存并重启:应用更改并重启 Cursor。
  5. 验证:确认 MCP 服务器已运行且可访问。

Cline

仓库中未提供 Cline 配置的明确说明。

API 密钥安全

请在配置中使用环境变量:

"env": {
  "KURRENTDB_CONNECTION_STRING": "insert kurrentdb connection here"
}

这样可保障凭证安全,防止泄露到版本控制。

如何在流程中使用此 MCP

在 FlowHunt 中使用 MCP

要将 MCP 服务器集成到 FlowHunt 工作流中,首先添加 MCP 组件并将其连接到你的 AI 代理:

FlowHunt MCP flow

点击 MCP 组件以打开配置面板。在系统 MCP 配置部分,使用如下 JSON 格式添加你的 MCP 服务器信息:

{
  "kurrentdb": {
    "transport": "streamable_http",
    "url": "https://yourmcpserver.example/pathtothemcp/url"
  }
}

配置完成后,AI 代理即可将此 MCP 作为工具,获得其全部功能和能力。请记得将 “kurrentdb” 替换为你的 MCP 服务器实际名称,并将 URL 替换为你的 MCP 服务器地址。


概览

部分可用性说明/备注
概览明确阐述了服务器用途和能力
提示模版列表提供了全部工具和工作流的提示模版
资源列表暴露流、投影及其状态
工具列表提供八种流和投影操作工具
API 密钥安全配置中采用环境变量进行安全凭证管理
采样支持(评估时不重要)仓库中未提及

我们的看法

KurrentDB MCP 服务器文档详尽,提供了与 KurrentDB 流和投影交互的丰富工具和资源。主流平台的配置说明清晰,但部分高级 MCP 功能如 Roots 和采样未提及。总体而言,该 MCP 对于其数据库应用场景非常稳健。

评分: 8/10

MCP 评分

有 LICENSE✅ (MIT)
至少有一个工具
Fork 数量1
Star 数量9

常见问题

什么是 KurrentDB MCP 服务器?

KurrentDB MCP 服务器是一个中间件组件,使 AI 助手和开发者能够以编程方式与 KurrentDB(一款流式数据库)交互。它提供了查询、写入和投影事件数据的工具,优化了分析、调试和快速原型开发的工作流程。

该服务器提供哪些工具和操作?

它提供用于读取和写入流数据、列出流、构建和测试投影以及监控投影状态的工具。这些操作可实现全面的事件流管理和高级分析,直接在你的开发环境中完成。

该 MCP 服务器的主要应用场景有哪些?

常见应用场景包括事件数据探索、事件写入和日志记录、投影的快速开发、流元数据发现,以及对 KurrentDB 中数据转换操作的运维监控。

如何安全地提供我的 KurrentDB 连接字符串?

请始终使用配置文件中的环境变量来存储诸如 KURRENTDB_CONNECTION_STRING 之类的敏感凭证。这可以确保你的密钥安全并避免泄露到版本控制中。

如何将 KurrentDB MCP 服务器集成到 FlowHunt 流程中?

将 MCP 组件添加到你的 FlowHunt 流程中,并配置你的 KurrentDB MCP 服务器信息。使用提供的 JSON 格式进行连接,你的 AI 代理即可访问所有 KurrentDB 工具和资源。

将 KurrentDB 集成到 FlowHunt

将 KurrentDB 连接到 FlowHunt,为你的 AI 和数据项目注入强大动力。即时访问事件流数据、投影及先进工具,助力分析和快速开发。

了解更多

Teradata MCP 服务器
Teradata MCP 服务器

Teradata MCP 服务器

Teradata MCP 服务器将 AI 助手与 Teradata 数据库集成,实现高级分析、无缝 SQL 查询执行以及在 FlowHunt 内直接进行实时商业智能工作流。...

2 分钟阅读
AI Database +5
Quarkus MCP 服务器
Quarkus MCP 服务器

Quarkus MCP 服务器

Quarkus MCP 服务器让 FlowHunt 用户能够通过基于 Java 的 MCP 服务器,将由 LLM 驱动的智能体连接到外部数据库和服务,从而简化自动化、集成,以及为 AI 工作流实现真实世界数据访问。...

2 分钟阅读
MCP Database +5
Databricks MCP 服务器
Databricks MCP 服务器

Databricks MCP 服务器

Databricks MCP 服务器将 AI 助手连接到 Databricks 环境,实现对 Unity Catalog 元数据和数据资产的自主探索、理解和交互。它使智能体能够发现数据、构建 SQL 查询,并自动化复杂的分析工作流,无需人工干预。...

2 分钟阅读
AI MCP Server +5