Skip to main content
Glama

@useconduit/mcp

MCP server for Conduit โ€” connect any AI agent to your data streams.

๐Ÿ“– API Docs ยท ๐ŸŒ Website ยท ๐Ÿ“ฆ npm ยท ๐Ÿ’ป GitHub

Quick Start

Get an API key from platform.usecondu.it/tokens, then add to your AI editor config:

Claude Code / Claude Desktop

Add to ~/.claude/settings.json:

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

Cursor

Add to .cursor/mcp.json in your project:

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

Windsurf

Add to ~/.codeium/windsurf/mcp_config.json:

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

Related MCP server: AgentData MCP Server

Environment Variables

Variable

Required

Default

Description

CONDUIT_API_KEY

โœ…

โ€”

Your Conduit API key

CONDUIT_API_URL

โ€”

https://api.usecondu.it

Custom API endpoint

Tools

Tool

Description

conduit_list_streams

List all data streams

conduit_get_schema

Get schema for a stream (columns, types, codecs)

conduit_create_stream

Create a new stream

conduit_ingest

Send events to a stream

conduit_list_events

Query events with pagination & time range filters

conduit_add_forward

Add a forwarding destination (HTTP, MQTT, or WebSocket) with auth options

conduit_stream_stats

Get ingestion statistics (event count, rate, latency)

conduit_analyze_schema

Analyze a JSON payload for optimal schema

conduit_feedback

Submit feedback to the Conduit team

conduit_backfill

Replay historical events to forwarding destinations

conduit_backfill_status

Check backfill job progress or list all jobs

conduit_time_range

Get earliest/latest event timestamps for a stream

Resources

URI

Description

conduit://streams

All streams

conduit://streams/{name}

Stream details + schema

conduit://stats

Platform-wide statistics

API Documentation

Full interactive API docs are available at api.usecondu.it/docs (powered by Scalar).

Key endpoints:

Method

Endpoint

Description

POST

/v1/{tenant}/{stream}

Ingest events (any protocol: HTTP, WebSocket, MQTT)

GET

/api/v1/streams

List streams

GET

/api/v1/streams/{name}

Stream details + schema

GET

/api/v1/streams/{name}/events?from=&to=&limit=

Query events with time range

GET

/api/v1/streams/{name}/stats

Ingestion statistics

GET

/api/v1/streams/{name}/schema-history

Schema evolution history

POST

/api/v1/streams/{name}/forwards

Add forwarding destination

POST

/api/v1/streams/{name}/backfill

Start backfill job

GET

/api/v1/streams/{name}/backfill

List backfill jobs

GET

/api/v1/streams/{name}/time-range

Event time range

POST

/api/v1/tokens

Create API token

GET

/api/v1/account

Account info + usage

Machine-readable API specs:

What is Conduit?

Conduit is the lightweight data layer between your services. Send any JSON โ€” schemas aren't defined, they emerge. And they evolve as your sources do.

  • One endpoint, any protocol โ€” HTTP, WebSocket, MQTT/S on the same path

  • AI-powered schema detection โ€” zero configuration, runs locally (your data never leaves)

  • Real-time forwarding โ€” HTTP webhooks, MQTT brokers, WebSocket endpoints with full auth options

  • Backfill โ€” replay historical events to new destinations

  • Built for agents โ€” MCP-native from day one, feedback loop included

  • European infrastructure ๐Ÿ‡ช๐Ÿ‡บ โ€” all data hosted and processed in the EU, GDPR-compliant by design

How agents use 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

Learn more at usecondu.it

License

MIT

Install Server
A
license - permissive license
A
quality
D
maintenance

Maintenance

โ€“Maintainers
โ€“Response time
โ€“Release cycle
โ€“Releases (12mo)
Commit activity

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

  • A
    license
    Not graded
    quality
    D
    maintenance
    Connects AI agents and MCP clients to Keboola, enabling storage queries, SQL transformations, job triggers, and more through natural language.
    MIT
  • A
    license
    A
    quality
    D
    maintenance
    Connects AI agents to AgentData's company intelligence platform, enabling natural language queries for structured company data like tech stacks, emails, people, and signals.
    6
    13
    MIT
  • A
    license
    Not graded
    quality
    C
    maintenance
    Enables AI agents to query live schema, lineage, and query-context across data warehouses, dbt projects, orchestration systems, and BI tools via MCP tools.
    Apache 2.0
  • A
    license
    Not graded
    quality
    A
    maintenance
    Enables AI agents to connect to any API by loading OpenAPI, GraphQL, gRPC, or SOAP specs, with a built-in catalog of 2500+ public APIs, supporting secure execution, response filtering, chaining, and parallel calls.
    4
    MIT

View all related MCP servers

Related MCP Connectors

  • Give your agent live data from Twitter, Reddit, the web and GitHub. No API keys, no scraping stack.

  • Connect your AI assistants to Keboola and expose your data, transformations, SQL queries, ...

  • Connect your team's living knowledge base โ€” docs, data, issues, CRM โ€” to Claude and ChatGPT.

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/useconduit/mcp'

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