AI导哈

数据流连接服务

Conduit MCP服务器是一个连接AI代理与数据流的服务，支持多种协议和实时转发功能，适用于AI代理数据处理和集成场景。

  • by useconduit
  • JavaScript
  • 本地部署
  • 更新于
在 GitHub 查看 useconduit/mcp

使用说明

@useconduct/MCP

MCP服务器 导管 --将任何AI代理连接到您的数据流。

📖 API文件 · 🌐 网站 · 📦 npm · 💻 GitHub

快速开始

从获取API密钥 platform.usecondu.it/代币，然后添加到您的AI编辑器配置中：

克劳德代码/克劳德桌面

添加 ~/.claude/settings.json:

{
  "mcpServers": {
    "conduit": {
      "command": "npx",
      "args": ["-y", "@useconduit/mcp"],
      "env": {
        "CONDUIT_API_KEY": "conduit_sk_..."
      }
    }
  }
}

光标

添加 .cursor/mcp.json 在您的项目中：

{
  "mcpServers": {
    "conduit": {
      "command": "npx",
      "args": ["-y", "@useconduit/mcp"],
      "env": {
        "CONDUIT_API_KEY": "conduit_sk_..."
      }
    }
  }
}

帆板运动

添加 ~/.codeium/windsurf/mcp_config.json:

{
  "mcpServers": {
    "conduit": {
      "command": "npx",
      "args": ["-y", "@useconduit/mcp"],
      "env": {
        "CONDUIT_API_KEY": "conduit_sk_..."
      }
    }
  }
}

环境变量

变量 必填 默认 描述
CONDUIT_API_KEY ✅ — 您的导管API密钥
CONDUIT_API_URL — https://api.usecondu.it 自定义API终结点

工具

工具 说明
conduit_list_streams 列出所有数据流
conduit_get_schema 获取流的架构（列、类型、编解码器）
conduit_create_stream 创建新流
conduit_ingest 将事件发送到流
conduit_list_events 使用分页和时间范围过滤器查询事件
conduit_add_forward 添加带有身份验证选项的转发目标（HTTP、MQTT或WebSocket）
conduit_stream_stats 获取摄取统计数据（事件计数、速率、延迟）
conduit_analyze_schema 分析JSON有效负载以获得最佳模式
conduit_feedback 向Conduit团队提交反馈
conduit_backfill 将历史事件回放到转发目的地
conduit_backfill_status 检查回填作业进度或列出所有作业
conduit_time_range 获取流的最早/最新事件时间戳

资源

URI 描述
conduit://streams 所有流
conduit://streams/{name} 流详细信息+架构
conduit://stats 全平台统计

API 文档

完整的交互式API文档可在 api.usecondu.it/docs （由Scalar提供动力）。

关键端点：

方法 端点 描述
POST /v1/{tenant}/{stream} 摄入事件（任何协议：HTTP、WebSocket、MQTT）
GET /api/v1/streams 列出流
GET /api/v1/streams/{name} 流详细信息+架构
GET /api/v1/streams/{name}/events?from=&to=&limit= 查询具有时间范围的事件
GET /api/v1/streams/{name}/stats 摄入统计
GET /api/v1/streams/{name}/schema-history 模式演化历史
POST /api/v1/streams/{name}/forwards 添加转发目的地
POST /api/v1/streams/{name}/backfill 开始回填作业
GET /api/v1/streams/{name}/backfill 列出回填作业
GET /api/v1/streams/{name}/time-range 事件时间范围
POST /api/v1/tokens 创建API令牌
GET /api/v1/account 账户信息+使用情况

可机调API规格：

什么是Conduit？

Conduit是服务之间的轻量级数据层。发送任何JSON——模式没有定义，它们会出现。它们会随着你的源代码而演变。

  • 一个端点，任何协议 --同一路径上的HTTP、WebSocket、MQTT/S
  • 基于AI的模式检测 --零配置，在本地运行（您的数据永远不会离开）
  • 实时转发 --HTTP webhooks、MQTT代理、具有完整身份验证选项的WebSocket端点
  • 回填 --将历史事件回放到新目的地
  • 专为代理商打造 --MCP从第一天开始就是原生的，包括反馈回路
  • 欧洲基础设施 🇪🇺 — 所有数据在欧盟托管和处理，设计符合GDPR

代理如何使用Conduit

Agent: "I see live sensor data flowing in. I'll pipe it to our datawarehouse and add hot storage."

▸ conduit_list_events(stream: "sensors", limit: 1000)
  ↳ 1,000 events · 18.4 MB raw → 1.1 MB stored (94% compressed)

▸ conduit_add_forward(stream: "sensors", type: "http", url: "https://dwh.acme.io/ingest")
  ↳ Destination added · forwarding to datawarehouse

▸ conduit_add_forward(stream: "sensors", type: "mqtt", broker: "mqtt://redis.acme.io", topic: "hot/sensors")
  ↳ Destination added · 2 destinations active

▸ conduit_backfill(stream: "sensors", from: "2026-02-24", to: "2026-03-02")
  ↳ Backfilling 89,929 events from last 7 days

了解更多 usecondom.it

许可证

麻省理工学院

相关 MCP