Skip to main content

RocketRide MCP stdio server that streams local files to RocketRide EaaS

Project description

RocketRide MCP Server

Let AI assistants run your RocketRide pipelines via the Model Context Protocol.

Glama MCP Score

PyPI GitHub Discord MIT License

Quick Start

pip install rocketride-mcp

Configure your MCP client to use the server (see examples below), then ask your AI assistant to process files through your running RocketRide pipelines.

How It Works

The MCP server connects to a running RocketRide engine and dynamically exposes your pipelines as MCP tools. When an AI assistant calls a tool, the server sends the file to the corresponding pipeline and returns the result.

AI Assistant (Claude, Cursor, ...)
        |
   MCP Protocol
        |
  rocketride-mcp server
        |
   WebSocket (DAP)
        |
  RocketRide Engine
        |
   Your Pipelines

Running pipelines are discovered automatically - start a pipeline in VS Code or via the SDK, and it appears as a callable tool in your AI assistant.

What is RocketRide?

RocketRide is an open-source, developer-native AI pipeline platform. It lets you build, debug, and deploy production AI workflows without leaving your IDE -- using a visual drag-and-drop canvas or code-first with TypeScript and Python SDKs.

  • 50+ ready-to-use nodes - 13 LLM providers, 8 vector databases, OCR, NER, PII anonymization, and more
  • High-performance C++ engine - production-grade speed and reliability
  • Deploy anywhere - locally, on-premises, or self-hosted with Docker
  • MIT licensed - fully open-source, OSI-compliant

Installation

pip install rocketride-mcp

Requires Python 3.10+ and rocketride-client-python >= 1.1.0.

Client Configuration

Claude Desktop

Add to your Claude Desktop config file:

macOS: ~/Library/Application Support/Claude/claude_desktop_config.json Windows: %APPDATA%\Claude\claude_desktop_config.json

{
	"mcpServers": {
		"rocketride": {
			"command": "rocketride-mcp",
			"env": {
				"ROCKETRIDE_URI": "ws://localhost:5565",
				"ROCKETRIDE_AUTH": "your-api-key"
			}
		}
	}
}

Cursor

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

{
	"mcpServers": {
		"rocketride": {
			"command": "rocketride-mcp",
			"env": {
				"ROCKETRIDE_URI": "ws://localhost:5565",
				"ROCKETRIDE_AUTH": "your-api-key"
			}
		}
	}
}

Claude Code

claude mcp add rocketride -- rocketride-mcp

Set ROCKETRIDE_URI and ROCKETRIDE_AUTH in your environment before running.

Command line

# Using the installed entry point
rocketride-mcp

# Or using Python module
python -m rocketride_mcp

Available Tools

Tools are discovered from the RocketRide server (pipelines/tasks available to your account) plus a built-in convenience tool:

  • Server tasks - Any pipelines or tasks returned by the server for your API key are exposed as MCP tools. Each tool accepts a filepath argument and sends that file's contents to the corresponding pipeline.
  • RocketRide_Document_Processor - A convenience tool that runs the bundled document-parsing pipeline (simpleparser.json) without requiring a pre-started task. Supports multi-modal parsing (text, images, video, tables, audio).

All tools accept a single filepath parameter (path to the file to process). File paths support:

  • Absolute and relative paths
  • file:// URIs (automatically decoded)
  • ~ home directory expansion

Response format

Tool results include both human-readable text and structured data:

  • Text content: Confirmation message plus extracted text from the pipeline result
  • Structured content: Raw pipeline result in structuredContent.result for programmatic access

MCP Resources

The server exposes three read-only MCP Resources that provide live information about the connected RocketRide engine. Resources use the rocketride:// URI scheme and return JSON payloads.

URI Name Description
rocketride://pipelines Pipeline List JSON array of all available pipelines (name and description) on the connected server
rocketride://status Server Status Connection status, pipeline count, and list of loaded pipeline names
rocketride://nodes Node Registry Available pipeline node types and their schemas (via rrext_get_nodes)

Reading resources

In Claude Desktop or any MCP-compatible client, resources are listed automatically. You can also access them programmatically:

# Example: read the pipeline list resource
result = await session.read_resource("rocketride://pipelines")
# Returns: {"pipelines": [{"name": "my-pipeline", "description": "..."}, ...]}

# Example: check server status
result = await session.read_resource("rocketride://status")
# Returns: {"connected": true, "pipeline_count": 3, "pipelines": ["pipe-a", "pipe-b", "pipe-c"]}

# Example: list available node types
result = await session.read_resource("rocketride://nodes")
# Returns: {"nodes": [{"name": "llm-openai", "type": "processor"}, ...]}

When the RocketRide client is not connected, resources return a JSON error payload (e.g. {"pipelines": [], "error": "Client is not connected"}) instead of raising an exception. Unknown URIs raise a ValueError.

MCP Prompt Templates

The server provides three reusable MCP Prompt Templates for common RocketRide operations. These templates generate pre-formatted user messages that can be sent to an LLM.

analyze-document

Analyze a document through a RocketRide pipeline.

Argument Required Description
pipeline Yes Pipeline name to use for analysis
query Yes Analysis question or instruction

Example usage in Claude Desktop:

Select the "analyze-document" prompt, then fill in:

  • pipeline: invoice-parser
  • query: Extract all line items and totals

This generates the message: "Please analyze the document using the RocketRide pipeline "invoice-parser". Focus on the following: Extract all line items and totals"

chat-with-data

Start a conversation about data processed by RocketRide.

Argument Required Description
pipeline Yes Pipeline name
question Yes Your question about the data

Example usage:

  • pipeline: quarterly-reports
  • question: What was the revenue growth in Q3?

This generates the message: "I would like to discuss data processed by the RocketRide pipeline "quarterly-reports". My question is: What was the revenue growth in Q3?"

evaluate-pipeline

Evaluate a pipeline's output quality using test data.

Argument Required Description
pipeline Yes Pipeline to evaluate
test_input Yes Test input data
expected_output No Expected output for comparison

Example usage:

  • pipeline: sentiment-classifier
  • test_input: This product is fantastic!
  • expected_output: positive

This generates the message: "Evaluate the output quality of the RocketRide pipeline "sentiment-classifier" using the following test input: This product is fantastic! Expected output: positive"

Using prompts programmatically

# List available prompts
prompts = await session.list_prompts()

# Get a rendered prompt
result = await session.get_prompt("analyze-document", arguments={
    "pipeline": "my-pipeline",
    "query": "Summarize the key findings"
})
# result.messages[0].content.text contains the rendered message

SSE Mode

For remote or Docker deployments, the server can run as an HTTP/SSE server instead of stdio:

pip install rocketride-mcp[sse]
rocketride-mcp-sse --host 0.0.0.0 --port 8080

SSE mode supports optional Bearer token authentication via the MCP_API_KEY environment variable. The /health endpoint is always accessible for monitoring.

Configuration

Set these environment variables (required; no config file is used):

Variable Required Description
ROCKETRIDE_URI Yes WebSocket URI of the RocketRide engine (e.g. ws://localhost:5565)
ROCKETRIDE_AUTH Yes* API authentication token
ROCKETRIDE_APIKEY Yes* Alternative to ROCKETRIDE_AUTH
MCP_API_KEY No Bearer token for SSE server authentication

*Either ROCKETRIDE_AUTH or ROCKETRIDE_APIKEY must be set.

Links

License

MIT - see LICENSE.

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

rocketride_mcp-1.1.1.tar.gz (18.4 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

rocketride_mcp-1.1.1-py3-none-any.whl (20.9 kB view details)

Uploaded Python 3

File details

Details for the file rocketride_mcp-1.1.1.tar.gz.

File metadata

  • Download URL: rocketride_mcp-1.1.1.tar.gz
  • Upload date:
  • Size: 18.4 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.1.0 CPython/3.12.13

File hashes

Hashes for rocketride_mcp-1.1.1.tar.gz
Algorithm Hash digest
SHA256 6c4d61614b9f0530163e76f45e20ca2750ad5c36089374e2a0c88e159f895dfd
MD5 4f1faaabaddc0a235639ef7c0f1079f3
BLAKE2b-256 949c4f5586bf01713cf35a18df4c3b333f103084fa965666dd0d5dcc5eda9261

See more details on using hashes here.

File details

Details for the file rocketride_mcp-1.1.1-py3-none-any.whl.

File metadata

  • Download URL: rocketride_mcp-1.1.1-py3-none-any.whl
  • Upload date:
  • Size: 20.9 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.1.0 CPython/3.12.13

File hashes

Hashes for rocketride_mcp-1.1.1-py3-none-any.whl
Algorithm Hash digest
SHA256 6d6f80de6933be9167e90dbe28ed18452dd2423b227538b625ed1a1523a2a53e
MD5 ea0ad35b3f5349648450815c9ef5bc23
BLAKE2b-256 13d580b99c094a80d5ad8cfa2a25250bede835100009d5b03f53cdce7ef243f4

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page