Lakexpress MCP

LakeXpress MCP服务器

  

特性

• 14个子命令 支持：logdb管理、配置管理、同步执行、状态和清理
• 5个源数据库：SQL Server、PostgreSQL、Oracle、MySQL、MariaDB
• 6个日志数据库：SQL Server、PostgreSQL、MySQL、MariaDB、SQLite、DuckDB
• 6个存储后端：本地、S3、S3兼容、GCS、Azure ADLS Gen2、OneLake
• 7个发布目标：雪花、Databricks、布料、BigQuery、母鸭、胶水、DuckLake
• 执行前进行命令预览，并确认安全
• 身份验证文件
• 基于用例的工作流建议

安装

pip install -e ".[dev]"

Claude代码配置

添加到您的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 

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

环境变量

发展

# 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

许可证

麻省理工学院