MCP Iceberg Service

🚀 MCP アイスバーグカタログ

これは、Apache Iceberg とやり取りするための MCP（モデルコンテキストプロトコル）サーバーの実装です。このサーバーは、Claude デスクトップを通じて SQL インターフェイスを提供し、Iceberg テーブルのクエリと管理を行います。

📦 インストール

Claude デスクトップでの Iceberg データレイクカタログとしての MySQL

Claude デスクトップへのインストール方法

Smithery を通じたインストール

Smithery を通じて、Claude デスクトップ用の MCP Iceberg Catalog を自動インストールするには、以下のコマンドを実行します。

npx -y @smithery/cli install @ahodroj/mcp-iceberg-service --client claude

1. 前提条件

   • Python 3.10 以上
   • UV パッケージインストーラー（推奨）または pip
   • Iceberg REST カタログと S3 互換ストレージへのアクセス

2. Claude デスクトップへのインストール方法 claude_desktop_config.json に以下の設定を追加します。

{
  "mcpServers": {
    "iceberg": {
      "command": "uv",
      "args": [
        "--directory",
        "PATH_TO_/mcp-iceberg-service",
        "run",
        "mcp-server-iceberg"
      ],
      "env": {
        "ICEBERG_CATALOG_URI" : "http://localhost:8181",
        "ICEBERG_WAREHOUSE" : "YOUR ICEBERG WAREHOUSE NAME",
        "S3_ENDPOINT" : "OPTIONAL IF USING S3",
        "AWS_ACCESS_KEY_ID" : "YOUR S3 ACCESS KEY",
        "AWS_SECRET_ACCESS_KEY" : "YOUR S3 SECRET KEY"
      }
    }
  }
}

🔧 技術詳細

アーキテクチャ

この MCP サーバーは、3 つの主要なコンポーネントに基づいて構築されています。

1. MCP プロトコルハンドラ

   • Claude とのモデルコンテキストプロトコルの通信を実装
   • 標準入出力のリクエスト/レスポンスサイクルを処理
   • サーバーのライフサイクルと初期化を管理

2. クエリプロセッサ

   • sqlparse を使用して SQL クエリを解析
   • サポートされる操作：
     • テーブルの一覧表示
     • テーブルの説明
     • 選択
     • 挿入

3. Iceberg 統合

   • pyiceberg を使用してテーブル操作を行う
   • PyArrow を統合して効率的なデータ処理を実現
   • カタログ接続とテーブル操作を管理

PyIceberg 統合

サーバーは、以下の点で PyIceberg を利用しています。

1. カタログ管理

   • REST カタログへの接続
   • メタデータテーブルの管理
   • 名前空間操作の処理

2. データ操作

   • PyIceberg と PyArrow のデータ型間の変換
   • PyArrow テーブルを通じたデータ挿入の処理
   • テーブルスキーマとフィールド型の管理

3. クエリ実行

   • SQL を PyIceberg 操作に変換
   • データスキャンとフィルタリングの処理
   • 結果セットの変換を管理

📈 今後の実装予定

1. クエリ操作

   • [ ] UPDATE 操作の実装
   • [ ] DELETE サポートの追加
   • [ ] スキーマ定義を使用したテーブル作成のサポート
   • [ ] ALTER TABLE 操作の追加
   • [ ] パーティションテーブルサポートの実装

2. データ型

   • [ ] 複雑なデータ型（配列、マップ、構造体）のサポート
   • [ ] タイムゾーン付きタイムスタンプの処理の追加
   • [ ] 小数型のサポート
   • [ ] ネストされたフィールドのサポートの追加

3. パフォーマンス改善

   • [ ] バッチ挿入の実装
   • [ ] クエリ最適化の追加
   • [ ] 並列スキャンのサポート
   • [ ] 頻繁にアクセスされるデータのキャッシュ層の追加

4. セキュリティ機能

   • [ ] 認証メカニズムの追加
   • [ ] ロールベースのアクセス制御の実装
   • [ ] 行レベルのセキュリティの追加
   • [ ] 暗号化接続のサポート

5. 監視と管理

   • [ ] メトリクス収集の追加
   • [ ] クエリ記録の実施
   • [ ] パフォーマンス監視の追加
   • [ ] テーブルメンテナンス操作のサポート

6. エラー処理

   • [ ] エラーメッセージの改善
   • [ ] 一時的な障害を処理するためのリトライメカニズムの追加
   • [ ] トランザクションサポートの実装
   • [ ] データ検証の追加