SeaTunnel MCP-Server

Ein Model Context Protocol (MCP)-Server für die Interaktion mit SeaTunnel über LLM-Schnittstellen wie Claude.

Bedienungsvideo

Um Ihnen die Funktionen und die Nutzung von SeaTunnel MCP besser zu verstehen, stellen wir Ihnen eine Videodemonstration zur Verfügung. Bitte folgen Sie dem unten stehenden Link oder sehen Sie sich die Videodatei direkt im Projektdokumentationsverzeichnis an.

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

Tipp : Wenn das Video nicht direkt abgespielt wird, stellen Sie sicher, dass Ihr Gerät das MP4-Format unterstützt, und versuchen Sie, es mit einem modernen Browser oder Videoplayer zu öffnen.

Related MCP server: Superset MCP Server

Merkmale

• Auftragsverwaltung (Senden, Stoppen, Überwachen)

• Systemüberwachung und Informationsabruf

• REST-API-Interaktion mit SeaTunnel-Diensten

• Integrierte Protokollierungs- und Überwachungstools

• Dynamische Verbindungskonfiguration

• Umfassende Jobinformationen und Statistiken

Installation

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

Anforderungen

• Python ≥ 3.12

• Ausführen einer SeaTunnel-Instanz

• Node.js (zum Testen mit MCP Inspector)

Verwendung

Umgebungsvariablen

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

Dynamische Verbindungskonfiguration

Der Server bietet Tools zum Anzeigen und Aktualisieren der Verbindungseinstellungen zur Laufzeit:

• get-connection-settings : Aktuelle Verbindungs-URL und API-Schlüsselstatus anzeigen

• update-connection-settings : Aktualisieren Sie die URL und/oder den API-Schlüssel, um eine Verbindung zu einer anderen SeaTunnel-Instanz herzustellen

Beispielverwendung durch 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"
  }
}

Auftragsverwaltung

Der Server bietet Tools zum Senden und Verwalten von SeaTunnel-Jobs:

• submit-job : Senden Sie einen neuen Job mit Jobkonfiguration

• submit-jobs : Mehrere Jobs im Stapel übermitteln

• stop-job : Stoppen Sie einen laufenden Job

• get-job-info : Erhalten Sie detaillierte Informationen zu einem bestimmten Job

• get-running-jobs : Listet alle aktuell laufenden Jobs auf

• get-finished-jobs : Listet alle abgeschlossenen Jobs nach Status auf (ABGESCHLOSSEN, ABGEBROCHEN, FEHLGESCHLAGEN usw.)

Ausführen des Servers

python -m src.seatunnel_mcp

Verwendung mit Claude Desktop

Um dies mit Claude Desktop zu verwenden, fügen Sie Folgendes zu Ihrer claude_desktop_config.json hinzu:

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

Testen mit MCP Inspector

npx @modelcontextprotocol/inspector python -m src.seatunnel_mcp

Verfügbare Tools

Verbindungsverwaltung

• get-connection-settings : Aktuelle SeaTunnel-Verbindungs-URL und API-Schlüsselstatus anzeigen

• update-connection-settings : Aktualisieren Sie die URL und/oder den API-Schlüssel, um eine Verbindung zu einer anderen Instanz herzustellen

Auftragsverwaltung

• submit-job : Senden Sie einen neuen Job mit Konfiguration im HOCON-Format

• submit-job/upload : Sendejob-Quellen-Upload-Konfigurationsdatei

• submit-jobs : Senden Sie mehrere Jobs im Stapel und übergeben Sie die Benutzereingabe direkt als Anforderungstext.

• stop-job : Stoppen Sie einen laufenden Job mit optionalem Sicherungspunkt

• get-job-info : Erhalten Sie detaillierte Informationen zu einem bestimmten Job

• get-running-jobs : Listet alle aktuell laufenden Jobs auf

• get-running-job : Details zu einem bestimmten laufenden Job abrufen

• get-finished-jobs : Listet alle abgeschlossenen Jobs nach Status auf

Systemüberwachung

• get-overview : Erhalten Sie einen Überblick über den SeaTunnel-Cluster

• get-system-monitoring-information : Erhalten Sie detaillierte Informationen zur Systemüberwachung

Änderungsprotokoll

Version 1.1.0 (10.04.2025)

• Neue Funktion : Hinzugefügtes submit-jobs und submit-job/upload Tool für Batch-Job-Übermittlung und Dokumentübermittlungsvorgänge

  • Ermöglicht die gleichzeitige Übermittlung mehrerer Jobs mit einem einzigen API-Aufruf

  • Die Eingabe wird direkt als Anforderungstext an die API übergeben

  • Unterstützt das JSON-Format für Jobkonfigurationen

  • Ermöglichen Sie die Übermittlung von Aufträgen auf Grundlage von Dokumenten

v1.0.0 (Erstveröffentlichung)

• Erstveröffentlichung mit grundlegenden SeaTunnel-Integrationsfunktionen

• Tools zur Auftragsverwaltung (Senden, Stoppen, Überwachen)

• Tools zur Systemüberwachung

• Dienstprogramme zur Verbindungskonfiguration

Lizenz

Apache-Lizenz