Lakexpress Mcp

io.github.arpe-io由 GitHub 账号 arpe-io 发布v0.1.6更新于 Oct 24, 2026

MCP server for LakeXpress — automated database-to-cloud data pipeline as Parquet

已验证STDIO仅桌面数据库云端与基础设施数据与分析

概览

AI 生成的概览

让助手构建、预览并执行 LakeXpress 的数据库到 Parquet 导出与同步命令，并支持认证文件校验和工作流建议。

可以做什么
封装 LakeXpress 命令行工具，让助手先预览其 14 个子命令，再在设置确认后执行已预览的命令。它还能校验认证文件、列出支持的源数据库、日志数据库、存储后端和发布目标、针对使用场景建议命令序列，并报告检测到的二进制版本。支持的源包括 SQL Server、PostgreSQL、Oracle、MySQL 和 MariaDB，存储可选本地、S3、GCS、Azure ADLS Gen2 和 OneLake。
适用场景
当你希望助手协助配置和驱动数据库到 Parquet 的导出、同步配置、日志数据库初始化、状态查询和清理时使用。适合已经使用 LakeXpress、希望由助手完成命令构建、校验和流程引导的数据工程师。
运行要求
以 Python 包形式在本地运行（pip install lakexpress-mcp），通过 stdio 通信，仅限桌面端。需要 LAKEXPRESS_PATH 指向 LakeXpress 二进制文件；未设置时服务器仅能预览。可选配置：FASTBCP_DIR_PATH、LAKEXPRESS_LOG_DIR、LAKEXPRESS_TIMEOUT、LOG_LEVEL。认证文件和数据库凭据由底层命令行工具使用，不交给服务器。
安装前请注意
execute_command 在确认后会执行真实的 LakeXpress 命令，可能写出导出文件、创建或修改同步配置、初始化日志数据库以及清理数据。命令行引用的认证文件包含数据库凭据，应避免放在共享或会被记录的位置。日志写入 LAKEXPRESS_LOG_DIR。确认前请先检查每条预览命令。

安装

在 SourceWeft 中

  1. 打开 控制台中的 Lakexpress Mcp，将其添加到工作区。
  2. 为需要使用其工具的对话启用该服务。

Desktop only，通过 STDIO。 STDIO 服务会启动本地进程，因此需要 SourceWeft 桌面宿主。

其他 MCP 客户端

参照 仓库 中的启动说明。

README

LakeXpress MCP Server

[PyPI] [License: MIT] [MCP Registry]

A Model Context Protocol (MCP) server for LakeXpress — a database to Parquet export tool with sync management and data lake publishing.

Features

  • 14 subcommands supported: logdb management, config management, sync execution, status, and cleanup
  • 5 source databases: SQL Server, PostgreSQL, Oracle, MySQL, MariaDB
  • 6 log databases: SQL Server, PostgreSQL, MySQL, MariaDB, SQLite, DuckDB
  • 6 storage backends: Local, S3, S3-compatible, GCS, Azure ADLS Gen2, OneLake
  • 7 publish targets: Snowflake, Databricks, Fabric, BigQuery, MotherDuck, Glue, DuckLake
  • Command preview before execution with safety confirmation
  • Auth file validation
  • Workflow suggestions based on use case

Installation

bash
pip install -e ".[dev]"

Claude Code Configuration

Add to your Claude Code MCP settings:

json
{  "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/"      }    }  }}

Or using the installed entry point:

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

Tools

preview_command

Build and preview any LakeXpress CLI command without executing it. Supports all 14 subcommands with full parameter validation.

execute_command

Execute a previously previewed command. Requires confirmation: true as a safety mechanism.

validate_auth_file

Validate that an authentication file exists, is valid JSON, and optionally check for specific auth_id entries.

list_capabilities

List all supported source databases, log databases, storage backends, publishing targets, compression types, and available commands.

suggest_workflow

Given a use case (source DB type, storage destination, optional publish target), suggest the full sequence of LakeXpress commands with example parameters.

get_version

Report the detected LakeXpress binary version and capabilities.

Workflow Example

# 1. Initialize the log database (first-time setup)LakeXpress logdb init -a auth.json --log_db_auth_id export_db
# 2. Create a sync configurationLakeXpress 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 syncLakeXpress sync --sync_id <sync_id>
# 4. Check statusLakeXpress status -a auth.json --log_db_auth_id export_db --sync_id <sync_id>

Environment Variables

VariableDefaultDescription
LAKEXPRESS_PATH./LakeXpressPath to the LakeXpress binary
LAKEXPRESS_TIMEOUT3600Command execution timeout in seconds
LAKEXPRESS_LOG_DIR./logsDirectory for execution logs
FASTBCP_DIR_PATH(empty)Path to FastBCP binary directory (auto-fills fastbcp_dir_path parameter)
LOG_LEVELINFOLogging level (DEBUG, INFO, WARNING, ERROR)

Development

bash
# Install dev dependenciespip install -e ".[dev]"
# Run testspython -m pytest tests/ -v
# Run with coveragepython -m pytest tests/ -v --cov=src --cov-report=term-missing

License

MIT

来源：README.md，提交 7e6a085

工具

0
SourceWeft 尚未在沙箱中启动过该软件包，因此其工具未知。

版本历史

1
  1. v0.1.6最新Sep 16, 2026

评分

已满足适用检查项的 50%

该评分衡量此收录条目的完整程度，依据注册中心条目、端点与公开来源计算得出。它不是对服务器本身的评价，也不表示服务器安全或当前可用：可连通性是带日期的检查结果，评分也不包含安装量或用户评价。

  • 近 30 天内可连通25 分

    请保持端点能够响应 MCP 握手；SourceWeft 每 30 天探测一次。

  • 已声明认证方式10 分

    请在注册中心条目中声明凭据请求头，或保持端点能够响应探测，以便判定其认证方式。

  • 已列出工具15 分

    请让服务器在无凭据时响应 tools/list，或发布可在沙箱中无凭据启动的软件包。

  • 描述必需15 分
  • 图标10 分
  • 文档15 分
  • 许可证10 分