MCP-сервер SeaTunnel

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

Видео операции

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

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

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

Related MCP server: Superset MCP Server

Функции

• Управление заданиями (отправка, остановка, мониторинг)

• Системный мониторинг и поиск информации

• Взаимодействие REST API с сервисами SeaTunnel

• Встроенные инструменты регистрации и мониторинга

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

• Подробная информация о вакансиях и статистика

Установка

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

Требования

• Питон ≥ 3.12

• Запуск экземпляра SeaTunnel

• Node.js (для тестирования с помощью MCP Inspector)

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

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

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

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

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

• get-connection-settings : просмотр текущего URL-адреса подключения и статуса ключа API

• update-connection-settings : Обновите URL-адрес и/или ключ API для подключения к другому экземпляру SeaTunnel

Пример использования через 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"
  }
}

Управление работой

Сервер предоставляет инструменты для отправки и управления заданиями SeaTunnel:

• submit-job : Отправить новую работу с конфигурацией работы

• submit-jobs : Отправка нескольких заданий в пакетном режиме

• stop-job : Остановить запущенное задание

• get-job-info : Получить подробную информацию о конкретной работе

• get-running-jobs : Список всех текущих запущенных заданий

• get-finished-jobs : список всех завершенных заданий по состоянию (ЗАВЕРШЕНО, ОТМЕНЕНО, ПРОВАЛЕНО и т. д.)

Запуск сервера

python -m src.seatunnel_mcp

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

Чтобы использовать это с Claude Desktop, добавьте следующее в ваш claude_desktop_config.json :

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

Тестирование с помощью MCP Inspector

npx @modelcontextprotocol/inspector python -m src.seatunnel_mcp

Доступные инструменты

Управление подключением

• get-connection-settings : просмотр текущего URL-адреса подключения SeaTunnel и статуса ключа API

• update-connection-settings : Обновите URL и/или ключ API для подключения к другому экземпляру

Управление работой

• submit-job : Отправить новое задание с конфигурацией в формате HOCON

• submit-job/upload : отправка файла конфигурации загрузки источника задания

• submit-jobs : отправка нескольких заданий в пакетном режиме, прямая передача введенных пользователем данных в качестве тела запроса

• stop-job : Остановка выполняющегося задания с дополнительной точкой сохранения

• get-job-info : Получить подробную информацию о конкретной работе

• get-running-jobs : Список всех текущих запущенных заданий

• get-running-job : Получить сведения о конкретной запущенной работе

• get-finished-jobs : Список всех завершенных работ по штату

Системный мониторинг

• get-overview : Получите обзор кластера SeaTunnel

• get-system-monitoring-information : Получить подробную информацию о мониторинге системы

Журнал изменений

v1.1.0 (2025-04-10)

• Новая функция : добавлены инструменты submit-jobs и submit-job/upload для пакетной отправки заданий и операций отправки документов.

  • Позволяет отправлять несколько заданий одновременно с помощью одного вызова API.

  • Входные данные передаются непосредственно в виде тела запроса в API.

  • Поддерживает формат JSON для конфигураций заданий

  • Разрешить подачу вакансий на основе документов

v1.0.0 (Первоначальный выпуск)

• Первоначальный выпуск с базовыми возможностями интеграции SeaTunnel

• Инструменты управления заданиями (отправка, остановка, мониторинг)

• Инструменты мониторинга системы

• Утилиты настройки подключения

Лицензия

Лицензия Apache