Сервер Model Context Protocol (MCP) для взаимодействия с SeaTunnel через интерфейсы LLM, такие как Claude.

Операционное видео

Чтобы помочь вам лучше понять функции и использование SeaTunnel MCP, мы предоставляем видео-демонстрацию. Пожалуйста, обратитесь к ссылке ниже или непосредственно проверьте видеофайл в каталоге проектной документации.

[[Т0]]

** Совет**: Если видео не воспроизводится напрямую, убедитесь, что ваше устройство поддерживает формат MP4 и попробуйте открыть его с помощью современного браузера или видеоплеера.

Особенности

• Управление работой (представление, остановка, мониторинг)
• Системный мониторинг и поиск информации Взаимодействие REST API с сервисами SeaTunnel
• Встроенные инструменты регистрации и мониторинга
• Динамическая конфигурация соединения
• Всеобъемлющая информация о работе и статистика

##Установка

Требования

Python ≥ 3,12

• Случай запуска SeaTunnel Node.js (для тестирования с MCP Inspector)

Использование

Переменные среды

Динамическая конфигурация соединения

Сервер предоставляет инструменты для просмотра и обновления настроек подключения во время выполнения:

[[Т1]]: Просмотр текущего состояния соединения URL и API

SeaTunnel MCP Server

A Model Context Protocol (MCP) server for interacting with SeaTunnel through LLM interfaces like Claude.

Operation Video

To help you better understand the features and usage of SeaTunnel MCP, we provide a video demonstration. Please refer to the link below or directly check the video file in the project documentation directory.

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

Tip: If the video does not play directly, make sure your device supports MP4 format and try opening it with a modern browser or video player.

Features

• Job management (submit, stop, monitor)
• System monitoring and information retrieval
• REST API interaction with SeaTunnel services
• Built-in logging and monitoring tools
• Dynamic connection configuration
• Comprehensive job information and statistics

Installation

# Clone repository
git clone 
cd seatunnel-mcp

# Create virtual environment and install
python -m venv .venv
source .venv/bin/activate  # On Windows: .venv\Scripts\activate
pip install -e .

Requirements

• Python ≥ 3.12
• Running SeaTunnel instance
• Node.js (for testing with MCP Inspector)

Usage

Environment Variables

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

Dynamic Connection Configuration

The server provides tools to view and update connection settings at runtime:

• get-connection-settings: View current connection URL and API key status
• update-connection-settings: Update URL and/or API key to connect to a different SeaTunnel instance

Example usage through 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"
  }
}

Job Management

The server provides tools to submit and manage SeaTunnel jobs:

• submit-job: Submit a new job with job configuration
• submit-jobs: Submit multiple jobs in batch
• stop-job: Stop a running job
• get-job-info: Get detailed information about a specific job
• get-running-jobs: List all currently running jobs
• get-finished-jobs: List all finished jobs by state (FINISHED, CANCELED, FAILED, etc.)

Running the Server

python -m src.seatunnel_mcp

Usage with Claude Desktop

To use this with Claude Desktop, add the following to your claude_desktop_config.json:

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

Testing with MCP Inspector