Labsco
deephaven logo

Deephaven MCP

β˜… 5

from deephaven

MCP servers for Deephaven to orchestrate data workers and power documentation Q&A with LLMs, enabling AI-driven data workflows.

πŸ”₯πŸ”₯πŸ”₯πŸ”₯βœ“ VerifiedFreeQuick setup

deephaven-mcp

PyPI License Build Status

Table of Contents


Overview

Supercharge your AI workflows with real-time data. Deephaven MCP brings the power of live dataframes directly to your favorite AI tools -β€” Claude Desktop, Cursor, VS Code (GitHub Copilot), Windsurf, and more.

Why Deephaven MCP?

Most data tools force you to choose: fast or real-time. With Deephaven's revolutionary live dataframes, you get both. Process streaming data at millisecond speeds while your AI assistant helps you build, query, and analyze -β€” all through natural language.

πŸš€ What makes this different:

  • Live Data, Live Results: Query streaming Kafka, real-time feeds, and batch data as easily as static CSV files
  • AI-Native Integration: Your AI assistant understands your data pipeline and can help optimize, debug, and extend it
  • Enterprise Ready: Battle-tested on Wall Street for over a decade, now available for your team
  • Zero Learning Curve: Write queries as if working with static tables -β€” real-time updates happen automatically

Deephaven MCP implements the Model Context Protocol (MCP) standard using FastMCP to provide seamless integration between Deephaven Community Core and Deephaven Enterprise systems and your AI development workflow. Perfect for data scientists, engineers, analysts, business users, and anyone who wants to harness real-time dataβ€”regardless of programming experience. Let AI generate the code while you focus on insights.


Key Use Cases

  • AI-Assisted Development: Integrate Deephaven with LLM-powered development tools (e.g., Claude Desktop, GitHub Copilot) for AI-assisted data exploration, code generation, and analysis.
  • Multi-Environment Management: Programmatically manage and query multiple Deephaven Community Core and Enterprise deployments from a single interface.
  • Interactive Documentation: Quickly find information and examples from Deephaven documentation using natural language queries.
  • Script Automation: Execute Python or Groovy scripts across multiple Deephaven sessions for data processing workflows.
  • Schema Discovery: Automatically retrieve and analyze table schemas from connected Deephaven instances.
  • Environment Monitoring: Monitor session health, package versions, and system status across your Deephaven infrastructure.

Deephaven MCP Components

Systems Server

Manages and connects to multiple Deephaven Community Core sessions and Deephaven Enterprise systems. This allows for unified control and interaction with your Deephaven instances from various client applications.

Key Capabilities:

  • Session Management: List, monitor, and get detailed status of all configured Deephaven sessions
  • Community Session Creation: Dynamically launch new Community Core sessions via Docker or python with configurable resources
  • Enterprise Systems: Connect to and manage Deephaven Enterprise (Core+) deployments
  • Enterprise Session Creation: Create and delete enterprise sessions with configurable resources and limits
  • Persistent Query Management: Full lifecycle management of enterprise persistent queries (PQs) - create, start, stop, restart, and delete long-running worker sessions
  • Catalog Discovery: Browse enterprise catalog at table and namespace levels to discover available data sources
  • Table Discovery: Lightweight table name listing and comprehensive schema retrieval for both session and catalog tables
  • Table Operations: Retrieve table schemas, metadata, and actual data with flexible formatting options
  • Script Execution: Run Python or Groovy scripts directly on Deephaven sessions
  • Package Management: Query installed Python packages in session environments
  • Configuration Management: Dynamically reload and refresh session configurations

Available MCP Tools

Session Management:

  • sessions_list - List all configured sessions
  • session_details - Get detailed session information
  • mcp_reload - Reload configuration and clear caches

Community Sessions:

  • session_community_create - Dynamically launch Community Core sessions
  • session_community_delete - Delete dynamically created sessions
  • session_community_credentials - Retrieve session credentials

Enterprise Systems & Sessions:

  • enterprise_systems_status - Get enterprise system status
  • session_enterprise_create - Create enterprise sessions
  • session_enterprise_delete - Delete enterprise sessions

Persistent Query (PQ) Management:

  • pq_name_to_id - Convert PQ name to canonical pq_id
  • pq_list - List all persistent queries on a system
  • pq_details - Get detailed PQ information
  • pq_create - Create new persistent queries
  • pq_modify - Modify existing persistent query configuration
  • pq_start - Start persistent queries (supports parallel execution with configurable concurrency)
  • pq_stop - Stop running persistent queries (supports parallel execution with configurable concurrency)
  • pq_restart - Restart persistent queries (supports parallel execution with configurable concurrency)
  • pq_delete - Delete persistent queries (supports parallel execution with configurable concurrency)

Parallel Batch Operations: When operating on multiple PQs, pq_start, pq_stop, pq_restart, and pq_delete execute operations in parallel with a default concurrency limit of 20. This provides near-batch performance (~10x faster for large batches) while maintaining granular per-item error reporting for AI agents. The concurrency limit can be adjusted via the max_concurrent parameter to balance performance and server load.

Table Operations:

  • session_tables_list - List available tables
  • session_tables_schema - Get table schema information
  • session_table_data - Retrieve table data with formatting options

Catalog Discovery (Enterprise):

  • catalog_tables_list - List catalog tables
  • catalog_namespaces_list - Browse catalog namespaces
  • catalog_tables_schema - Get catalog table schemas
  • catalog_table_sample - Sample catalog table data

Execution & Packages:

  • session_script_run - Execute Python/Groovy scripts
  • session_pip_list - Query installed packages

For detailed tool documentation with parameters and examples, see the Developer & Contributor Guide.


Docs Server

Connects to Deephaven's documentation knowledge base via Inkeep AI to answer questions about Deephaven features, APIs, and usage patterns. Ask questions in natural language and get specific answers with code examples and explanations.


Architecture Diagrams

Systems Server Architecture

graph TD
    A["MCP Clients (Claude Desktop, etc.)"] --"stdio (MCP)"--> B("MCP Systems Server")
    B --"Manages"--> C("Deephaven Community Core Worker 1")
    B --"Manages"--> D("Deephaven Community Core Worker N")
    B --"Manages"--> E("Deephaven Enterprise System 1")
    B --"Manages"--> F("Deephaven Enterprise System N")
    E --"Manages"--> G("Enterprise Worker 1.1")
    E --"Manages"--> H("Enterprise Worker 1.N")
    F --"Manages"--> I("Enterprise Worker N.1")
    F --"Manages"--> J("Enterprise Worker N.N")

Clients connect to the MCP Systems Server, which in turn manages and communicates with Deephaven Community Core sessions and Deephaven Enterprise systems.

Docs Server Architecture

graph TD
    A["MCP Clients with streamable-http support"] --"streamable-http (direct)"--> B("MCP Docs Server")
    C["MCP Clients without streamable-http support"] --"stdio"--> D["mcp-proxy"]
    D --"streamable-http"--> B
    B --"Accesses"--> E["Deephaven Documentation Corpus via Inkeep API"]

Modern MCP clients can connect directly via streamable-http for optimal performance. Clients without native streamable-http support can use mcp-proxy to bridge stdio to streamable-http.