SeaTunnel MCP Server

by ocean-zhc
Verified

hybrid server

The server is able to function both locally and remotely, depending on the configuration or use case.

Integrations

  • Integrates with SeaTunnel (an Apache project) to provide job management capabilities including submitting, stopping, and monitoring jobs, as well as retrieving system monitoring information and cluster overview.

Servidor MCP de SeaTunnel

Un servidor de Protocolo de Contexto de Modelo (MCP) para interactuar con SeaTunnel a través de interfaces LLM como Claude.

Vídeo de la operación

Para ayudarle a comprender mejor las funciones y el uso de SeaTunnel MCP, le ofrecemos una demostración en video. Consulte el enlace a continuación o consulte el archivo de video directamente en la documentación del proyecto.

https://www.youtube.com/watch?v=JaLA8EkZD7Q

Consejo : si el video no se reproduce directamente, asegúrese de que su dispositivo admita el formato MP4 e intente abrirlo con un navegador o reproductor de video moderno.

Características

  • Gestión de trabajos (enviar, detener, supervisar)
  • Monitoreo de sistemas y recuperación de información
  • Interacción de la API REST con los servicios de SeaTunnel
  • Herramientas de registro y monitoreo integradas
  • Configuración de conexión dinámica
  • Información y estadísticas laborales completas

Instalación

# Clone repository git clone <repository_url> cd seatunnel-mcp # Create virtual environment and install python -m venv .venv source .venv/bin/activate # On Windows: .venv\Scripts\activate pip install -e .

Requisitos

  • Python ≥ 3.9
  • Ejecución de la instancia de SeaTunnel
  • Node.js (para pruebas con MCP Inspector)

Uso

Variables de entorno

SEATUNNEL_API_URL=http://localhost:8090 # Default SeaTunnel REST API URL SEATUNNEL_API_KEY=your_api_key # Optional: Default SeaTunnel API key

Configuración de conexión dinámica

El servidor proporciona herramientas para ver y actualizar la configuración de conexión en tiempo de ejecución:

  • get-connection-settings : Ver la URL de conexión actual y el estado de la clave API
  • update-connection-settings : Actualiza la URL y/o la clave API para conectarse a una instancia diferente de SeaTunnel

Ejemplo de uso a través de MCP:

// Get current settings { "name": "get-connection-settings" } // Update connection settings { "name": "update-connection-settings", "arguments": { "url": "http://new-host:8090", "api_key": "new-api-key" } }

Gestión de trabajos

El servidor proporciona herramientas para enviar y administrar trabajos de SeaTunnel:

  • submit-job : Enviar un nuevo trabajo con configuración de trabajo
  • submit-jobs : Enviar varios trabajos en lote
  • stop-job : Detener un trabajo en ejecución
  • get-job-info : Obtenga información detallada sobre un trabajo específico
  • get-running-jobs : enumera todos los trabajos que se están ejecutando actualmente
  • get-finished-jobs : enumera todos los trabajos terminados por estado (TERMINADO, CANCELADO, FALLIDO, etc.)

Ejecución del servidor

python -m src.seatunnel_mcp

Uso con Claude Desktop

Para usar esto con Claude Desktop, agregue lo siguiente a su claude_desktop_config.json :

{ "mcpServers": { "seatunnel": { "command": "python", "args": ["-m", "src.seatunnel_mcp"], "cwd": "Project root directory" } } }

Pruebas con MCP Inspector

npx @modelcontextprotocol/inspector python -m src.seatunnel_mcp

Herramientas disponibles

Gestión de conexiones

  • get-connection-settings : Ver la URL de conexión actual de SeaTunnel y el estado de la clave API
  • update-connection-settings : Actualiza la URL y/o la clave API para conectarse a una instancia diferente

Gestión de trabajos

  • submit-job : Enviar un nuevo trabajo con configuración en formato HOCON
  • submit-job/upload : enviar archivo de configuración de carga de origen de trabajo
  • submit-jobs : envía varios trabajos en lote, pasando directamente la entrada del usuario como cuerpo de la solicitud
  • stop-job : Detener un trabajo en ejecución con un punto de guardado opcional
  • get-job-info : Obtenga información detallada sobre un trabajo específico
  • get-running-jobs : enumera todos los trabajos que se están ejecutando actualmente
  • get-running-job : obtener detalles sobre un trabajo específico en ejecución
  • get-finished-jobs : enumera todos los trabajos terminados por estado

Monitoreo del sistema

  • get-overview : Obtenga una descripción general del clúster SeaTunnel
  • get-system-monitoring-information : Obtenga información detallada de monitoreo del sistema

Registro de cambios

v1.1.0 (10/04/2025)

  • Nueva función : Se agregaron herramientas submit-jobs y submit-job/upload para el envío de trabajos por lotes y operaciones de envío de documentos.
    • Permite enviar varios trabajos a la vez con una única llamada API
    • La entrada se pasa directamente como cuerpo de la solicitud a la API.
    • Admite el formato JSON para configuraciones de trabajos
    • Permitir el envío de trabajos basados en documentos

v1.0.0 (versión inicial)

  • Versión inicial con capacidades básicas de integración de SeaTunnel
  • Herramientas de gestión de trabajos (enviar, detener, supervisar)
  • Herramientas de monitorización del sistema
  • Utilidades de configuración de conexión

Licencia

Licencia Apache

-
security - not tested
A
license - permissive license
-
quality - not tested

Un servidor de protocolo de contexto de modelo que permite la interacción con Apache SeaTunnel a través de interfaces LLM, permitiendo a los usuarios administrar trabajos, monitorear información del sistema y configurar conexiones a través del lenguaje natural.

  1. Operation Video
    1. Features
      1. Installation
        1. Requirements
          1. Usage
            1. Environment Variables
            2. Dynamic Connection Configuration
            3. Job Management
            4. Running the Server
            5. Usage with Claude Desktop
            6. Testing with MCP Inspector
          2. Available Tools
            1. Connection Management
            2. Job Management
            3. System Monitoring
          3. Changelog
            1. v1.1.0 (2025-04-10)
            2. v1.0.0 (Initial Release)
          4. License
            ID: 5ksdj0wcva