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.

Related MCP server: Superset MCP Server

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.12

• 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