meridian (Meridian Io)

子午线

Kubernetes的开源Trino控制平面和MCP服务器。

getmeridian.dev · v1.1

Trino集群的配置需要30-90秒。Meridian消除了这种等待——热备用池使预配置的集群保持空闲和就绪状态，并在零秒内保留。CI/CD作业、批处理工作负载或多租户平台没有冷启动。

子午线是二合一的： Kubernetes操作员 管理整个集群生命周期(Empty → Pending → Idle → Reserved)和a MCP服务器 借助19个工具，Claude、Cursor或任何MCP客户端都可以通过自然语言配置集群、添加目录、轮换凭据和运行查询。

内部构建的平台大数据团队。现在开源。

______________________________________________________________________

MCP服务器--从这里开始

这 meridian binary是一个独立的MCP服务器，用于 Kubernetes上的任何Trino部署.安装操作员以获得完整的热备用池体验；如果没有它，MCP服务器在第一天就很有用。

安装

二进制（所有平台）：

# macOS arm64
curl -Lo meridian.tar.gz https://github.com/meridian-io/meridian/releases/download/v1.1/trino-mcp-server_v1.1_darwin_arm64.tar.gz
tar xzf meridian.tar.gz && sudo mv meridian /usr/local/bin/

Docker：

docker pull ghcr.io/meridian-io/trino-mcp-server:v1.1

跑

# stdio — for Claude Desktop / local MCP clients
meridian --transport stdio --namespace meridian

# SSE — for remote / team use (Cursor, Claude API)
meridian --transport sse --addr :8080 --namespace meridian

# In-cluster (reads service account token automatically)
meridian --transport sse --addr :8080

连接到克劳德桌面

添加 ~/.config/claude/claude_desktop_config.json:

{
  "mcpServers": {
    "meridian": {
      "command": "meridian",
      "args": ["--transport", "stdio", "--namespace", "meridian"]
    }
  }
}

可用的MCP工具

查询结果缓存

Meridian将Trino查询结果缓存在内存中，以避免在同一会话中重复调用的冗余往返。

它是如何工作的：

1. 第一个电话→ 缓存未命中→ 查询点击Trino→ 结果与到期时间戳一起存储
2. TTL内的同一呼叫→ 缓存命中→ 结果立即返回，标记 [cache hit]
3. TTL到期后→ 下一个调用再次命中Trino并刷新缓存
4. add_catalog / remove_catalog 立即使目录缓存无效，因此 list_catalogs 始终反映当前状态

单程： 如果两个相同的查询同时到达（例如，Claude在一个回合中调用同一个工具两次），只有一个查询会命中Trino。第二个等待，一旦第一个完成，就会从缓存中提供服务。

选择缓存 execute_query: 通过 ttl=N 查询静态或参考数据时：

Run SELECT * FROM mysql_testdb.testdb.orders on trino-local with ttl=60

缓存密钥： SHA-256哈希 (coordinatorURL + sql)不同的SQL或不同的集群=不同的缓存条目，没有冲突。

边缘案例-- add_catalog: 当您通过MCP添加或删除目录时，该协调器的缓存将立即失效。 list_catalogs 稍后调用将始终命中Trino并返回当前状态——没有过时的数据。

查询标记

发送到Trino的每个SQL语句都会自动标记一个唯一的 mcp_query_id:

SELECT * FROM mysql_testdb.testdb.orders
-- mcp_query_id=3f2a1b4c-e8d7-4a9b-b1c2-0f5e6d7a8b9c

标记显示为SQL注释，因此Trino正常执行它。这 query_id 显示在每个结果的顶部：

query_id: 3f2a1b4c-e8d7-4a9b-b1c2-0f5e6d7a8b9c
| name        |
|-------------|
| 55555577    |
| 76y56       |

(2 rows)

使用它在Trino UI中查找确切的执行情况(http://:8080/ui)或查询历史记录——在调试慢速查询或意外结果时非常有用。

注意：标签仅适用于新的Trino调用。缓存点击数([cache hit])跳过标记，因为查询再也不会到达Trino。

CSV文件导出

对于会溢出上下文窗口的大型结果集，请使用 output_file 将结果以CSV格式写入，而不是内联返回：

Run SELECT * FROM mysql_testdb.testdb.orders on trino-local with output_file=/tmp/orders.csv

退货：

Results written to /tmp/orders.csv (1042 rows, 8 columns)
query_id: 3f2a1b4c-...

该文件包含一个标题行，后面是所有数据行。完整的表永远不会发送到LLM，只有摘要。

______________________________________________________________________

建筑

┌──────────────────────────────────────────────────────┐
│                   Project Meridian                    │
│                                                      │
│  ┌────────────┐  ┌─────────────┐  ┌───────────────┐  │
│  │  Web UI    │  │  REST API   │  │  MCP Server   │  │
│  │  Next.js   │  │  Go/mTLS    │  │  Go · 19 tools│  │
│  └────────────┘  └──────┬──────┘  └──────┬────────┘  │
│                         │                │           │
│                ┌────────▼────────────────▼──────┐    │
│                │       Kubernetes API Server     │    │
│                └────────┬────────────────────────┘    │
│       ┌─────────────────┼──────────────┐             │
│       ▼                 ▼              ▼             │
│  ClusterController  ClusterPool   ClusterPool        │
│                     Controller    Autoscaler         │
└──────────────────────────────────────────────────────┘
                          │
           ┌──────────────┼──────────────┐
           ▼              ▼              ▼
      Cluster(Idle)  Cluster(Reserved)  Cluster(Pending)

集群生命周期

Empty → Pending → Idle → Reserved
                    ↓
                  Failed

组件

Kubernetes操作员

操作员在Kubernetes上管理整个Trino集群生命周期。三个控制器在一个二进制文件中运行：

`` connector.name=mysql connection-url=jdbc:mysql://mysql:3306 connection-user=root connection-password=trino_test ``

步骤2--浏览目录：

列出中的架构 mysql_testdb 目录上 trino-local

步骤3——查询数据：

跑 SHOW TABLES FROM mysql_testdb.testdb 上 trino-local

直接在Trino中验证：

docker exec meridian-trino trino --execute "SHOW CATALOGS"
docker exec meridian-trino trino --execute "SHOW SCHEMAS FROM mysql_testdb"

注： 添加MySQL目录时，请使用 mysql:3306 作为连接URL（不是 localhost:3306).Trino在Docker内部运行，并通过内部Docker网络主机名访问MySQL mysql.

______________________________________________________________________

# MCP server
cd mcp && go build -o ../bin/meridian ./cmd/meridian-mcp

# Kubernetes operator
cd operator && go build -o ../bin/meridian-operator .

# Or use Make
make build       # operator
make build-mcp   # MCP server
make test        # all tests

手动测试用例

以下测试用例涵盖了所有端到端的工作工具。在运行本地开发环境的Claude Desktop中运行它们(docker compose up -d + ./hack/setup-local.sh).

测试中使用的参考表：

______________________________________________________________________

注： 测试5、12需要在 相同的克劳德桌面会话 --缓存在内存中，并在MCP进程重新启动时重置。

______________________________________________________________________

第2阶段——操作员手册测试

先决条件：集群正在运行，CRD已应用，操作员正在本地运行。

kubectl apply -f operator/config/crd/bases/
./bin/meridian-operator --namespace meridian --kubeconfig ~/.kube/config

群集生命周期（空→ 待定→ Idle → 预留→ Idle)

热备用池（ClusterPool）

清理

______________________________________________________________________

CRD

# meridian.io/v1alpha1
Cluster              — single Trino cluster lifecycle
ClusterPool          — hot standby pool of N clusters
ClusterPoolAutoscaler — scale pool by reservation utilization

超越AI代理

MCP服务器是一个标准的RPC接口，任何自动化Trino集群生命周期的系统都可以使用它，而不仅仅是LLM。

CI/CD管道

为集成测试保留一个新的集群，运行它们，完成后发布：

# GitHub Actions
- name: Reserve test cluster
  run: |
    RESULT=$(mcp-client call reserve_cluster \
      --profile ci --reservation-id ${{ github.run_id }})
    echo "COORDINATOR_URL=$(echo $RESULT | jq -r .coordinatorUrl)" >> $GITHUB_ENV

- name: Run integration tests
  run: ./test.sh $COORDINATOR_URL

- name: Release cluster
  if: always()
  run: mcp-client call release_cluster --cluster-name ${{ env.CLUSTER_NAME }}

工作流编排器

将集群生命周期作为气流/Dagster/Prefect DAG的一部分进行管理：

@task
def reserve_trino_cluster(dag_run):
    return mcp.call("reserve_cluster", profile="batch", reservation_id=dag_run.run_id)

@task
def run_transformation(cluster):
    run_dbt(target=cluster["coordinatorUrl"])

@task
def release_trino_cluster(cluster):
    mcp.call("release_cluster", cluster_name=cluster["clusterName"])

其他MCP客户端

为什么选择Meridian

• 不存在开源Trino控制平面 — 特立尼达和多巴哥#396 自2019年开放；子午线就是答案
• 不存在官方Trino MCP服务器 — 特立尼达和多巴哥#26239 开放；Meridian提供19种管理工具，而不仅仅是查询执行
• 作为通用操作接口工作 --CI/CD、编排器、内部工具和AI代理都使用相同的二进制文件

路线图

______________________________________________________________________

许可证

Apache 2.0——请参阅 许可证