lakexpress-mcp

LakeXpress MCP 服务

适用于 LakeXpress 的 Model Context Protocol (MCP) 服务。LakeXpress 是一款数据库导出为 Parquet 的工具，支持同步管理和数据湖发布。

功能

• 支持 14 个子命令：日志数据库管理、配置管理、同步执行、状态查询和清理
• 5 种源数据库：SQL Server、PostgreSQL、Oracle、MySQL、MariaDB
• 6 种日志数据库：SQL Server、PostgreSQL、MySQL、MariaDB、SQLite、DuckDB
• 6 种存储后端：本地、S3、兼容 S3 的存储、GCS、Azure ADLS Gen2、OneLake
• 7 种发布目标：Snowflake、Databricks、Fabric、BigQuery、MotherDuck、Glue、DuckLake
• 执行前可预览命令，并进行安全确认
• 验证身份验证文件
• 根据使用场景提供工作流建议

安装

pip install -e ".[dev]"

Claude Code 配置

将以下内容添加到 Claude Code MCP 设置中：

{
  "mcpServers": {
    "lakexpress": {
      "command": "python",
      "args": ["-m", "src.server"],
      "cwd": "/path/to/lakexpress-mcp",
      "env": {
        "LAKEXPRESS_PATH": "/path/to/LakeXpress",
        "LAKEXPRESS_TIMEOUT": "3600",
        "LAKEXPRESS_LOG_DIR": "./logs",
        "FASTBCP_DIR_PATH": "/path/to/FastBCP/"
      }
    }
  }
}

也可以使用已安装的入口点：

{
  "mcpServers": {
    "lakexpress": {
      "command": "lakexpress-mcp",
      "env": {
        "LAKEXPRESS_PATH": "/path/to/LakeXpress",
        "FASTBCP_DIR_PATH": "/path/to/FastBCP/"
      }
    }
  }
}

工具

preview_command

构建并预览任意 LakeXpress CLI 命令，但不执行。支持全部 14 个子命令，并进行完整的参数验证。

execute_command

执行先前预览的命令。出于安全考虑，必须设置 confirmation: true。

validate_auth_file

验证身份验证文件是否存在且为有效的 JSON，并可选择检查是否包含特定的 auth_id 条目。

list_capabilities

列出所有支持的源数据库、日志数据库、存储后端、发布目标、压缩类型和可用命令。

suggest_workflow

根据使用场景（源数据库类型、存储目标、可选的发布目标），提供完整的 LakeXpress 命令序列及示例参数。

get_version

报告检测到的 LakeXpress 二进制文件版本和功能。

工作流示例

# 1. Initialize the log database (first-time setup)
LakeXpress logdb init -a auth.json --log_db_auth_id export_db

# 2. Create a sync configuration
LakeXpress config create -a auth.json --log_db_auth_id export_db \
  --source_db_auth_id prod_db --source_schema_name sales \
  --output_dir ./exports --compression_type Zstd

# 3. Execute the sync
LakeXpress sync --sync_id <sync_id>

# 4. Check status
LakeXpress status -a auth.json --log_db_auth_id export_db --sync_id <sync_id>

环境变量

变量	默认值	描述
LAKEXPRESS_PATH	./LakeXpress	LakeXpress 二进制文件的路径
LAKEXPRESS_TIMEOUT	3600	命令执行超时时间（秒）
LAKEXPRESS_LOG_DIR	./logs	执行日志目录
FASTBCP_DIR_PATH	(empty)	FastBCP 二进制文件目录路径（自动填充 fastbcp_dir_path 参数）
LOG_LEVEL	INFO	日志级别（DEBUG、INFO、WARNING、ERROR）

开发

# Install dev dependencies
pip install -e ".[dev]"

# Run tests
python -m pytest tests/ -v

# Run with coverage
python -m pytest tests/ -v --cov=src --cov-report=term-missing

许可证

MIT