Skip to main content
Indexing 解决的是这件事:链上原始数据不是你想要的形状,你需要把它加工成自己的业务表,并且一直保持更新。
本章正在编写中。本页给出整体形态,各步骤的详细指南会陆续补齐。

一条管道长什么样

四个角色:

建一条管道要做四步

1

建表

定义目标表的类型和列。表类型的选择取决于你的数据是「状态」还是「事件」。选哪种表类型 →
2

写 Function

用 Python 描述一行数据怎么变成另一行。可以用 Test Case 单独调试,不用跑整条管道。Function 是什么 →
3

写 Notebook 驱动

订阅源表的新块,为每个块提交一个计算任务。Notebook 是什么 →
4

挂上调度

让它常驻运行,或者按固定周期跑。调度:常驻 / 定时 / 手动 →

什么时候不该用它

只是想查数据,不要建管道。如果你的需求是「看看某个地址的交易」「统计一下昨天的 gas 消耗」,直接去数据目录 → 数据分析写 SQL 查现成的公共表就行。建管道是为了持续产出一张会一直更新、能被下游依赖的业务表。一次性的分析需求用不上。

典型场景

代币转账明细

解析转账事件,把发送方、接收方、金额写进明细表。

NFT 流转记录

捕获铸造和转移事件,按合集和 token ID 组织成完整的流转历史。

余额快照

余额变化时读取当前状态,构建一张任意历史高度都能查的余额表。

流动性追踪

DeFi 协议事件触发时读取池子储备,追踪流动性随时间的变化。