索引Co MCP服务器
从流式传输实时区块链数据 索引公司 管道直接导入您的Claude Code会话。
这个MCP服务器没有推送到数据库并单独查询,而是通过WebSockets订阅管道事件并将其存储在本地SQLite中,这样Claude就可以实时查询、分析和响应区块链数据。
[Blockchain] → [Indexer Pipeline] → [DIRECT adapter] → [MCP Server (WebSocket)] → [SQLite] → [Claude Code]快速开始
1.安装
git clone https://github.com/indexing-co/indexing-co-mcp.git
cd indexing-co-mcp
npm install && npm run build这也将安装Claude代码 管道技能 到 ~/.claude/skills/。要稍后更新,请执行以下操作: git pull && npm run build.
2.配置
将您的流凭据添加到 ~/.indexing-co/credentials:
API_KEY=3.用克劳德代码注册
claude mcp add indexing-co -- node /path/to/indexing-co-mcp/dist/index.js4.使用
在Claude Code中,现在可以使用以下工具:
| 工具 | 说明 |
|---|---|
subscribe | 订阅DIRECT管道频道。验证通道是否存在。 |
unsubscribe | 停止接收频道的事件。 |
get_subscriptions | 列出活动通道、连接状态、事件计数。 |
get_events | 以JSON格式获取最近的原始事件。 |
describe_data | 从存储的事件中自动发现数据形状。 |
query | 使用以下命令运行只读SQL json_extract() 支持。 |
clear_events | 删除存储的事件(全部或按通道)。 |
chart | 运行SQL并将结果呈现为ASCII图表(火花线、直线、条形图、直方图、表格)。 |
get_status | WebSocket状态、通道、事件计数、数据库路径。 |
list_pipelines | 列出所有管道。显示DIRECT频道名称。 |
get_pipeline | 按名称获取管道。 |
create_pipeline | 创建或更新管道(POSTGRES、HTTP、WEBSOCKET、DIRECT)。 |
delete_pipeline | 删除管道。 |
backfill | 回填管道的历史数据。 |
list_filters | 列出所有过滤器。 |
get_filter | 使用可选前缀搜索获取筛选器值。 |
create_filter | 创建筛选器或向现有筛选器添加值。 |
delete_filter_values | 从筛选器中删除值。 |
list_transformations | 列出所有转换。 |
get_transformation | 按名称获取转换代码。 |
create_transformation | 创建或更新转换。 |
test_transformation | 根据实时区块链数据测试转换代码。 |
运作原理
管道设置
创建索引协同管道时,添加 DIRECT 作为输送适配器:
{
"delivery": {
"adapter": "DIRECT",
"connectionUri": "",
"table": "my-channel-name"
}
}table是您要订阅的频道名称- 空
connectionUri使用env变量 - 可以与任何其他适配器一起运行(例如DIRECT+POSTGRES)
- 只有在至少连接了一个订阅服务器时才发送事件-没有浪费的API调用
查询数据
事件以原始JSON格式存储在SQLite中。使用 describe_data 要发现形状,那么 query 使用SQL:
SELECT json_extract(data, '$.chain') as chain,
json_extract(data, '$.transaction_hash') as tx,
json_extract(data, '$.decoded.value') as amount
FROM events
WHERE channel = 'my-transfers'
AND json_extract(data, '$.chain') = 'ethereum'
ORDER BY received_at DESC
LIMIT 20;建筑
- 没有外部客户端库 --使用内置的Node 22+
WebSocket - 自动重新连接 指数回退
- 带WAL模式的SQLite 用于并发读/写
- 通用架构 --适用于任何管道输出形状
- 事件存储在
~/.indexing-co/mcp-events.db
环境变量
| 变量 | 必填 | 描述 |
|---|---|---|
INDEXING_API_KEY | 是 | 索引公司API密钥(也可从 ~/.indexing-co/credentials 作为 API_KEY) |
STREAM_URL | 否 | 覆盖流WebSocket URL(如果未设置,则从API自动获取) |
需求
- Node.js 22+
- 一 索引公司 账户
许可证
麻省理工学院
