本章正在编写中。本页给出整体形态,各步骤的详细指南会陆续补齐。
一条管道长什么样
四个角色:建一条管道要做四步
1
建表
定义目标表的类型和列。表类型的选择取决于你的数据是「状态」还是「事件」。选哪种表类型 →
2
写 Function
用 Python 描述一行数据怎么变成另一行。可以用 Test Case 单独调试,不用跑整条管道。Function 是什么 →
3
写 Notebook 驱动
订阅源表的新块,为每个块提交一个计算任务。Notebook 是什么 →
4
挂上调度
让它常驻运行,或者按固定周期跑。调度:常驻 / 定时 / 手动 →
什么时候不该用它
典型场景
代币转账明细
解析转账事件,把发送方、接收方、金额写进明细表。
NFT 流转记录
捕获铸造和转移事件,按合集和 token ID 组织成完整的流转历史。
余额快照
余额变化时读取当前状态,构建一张任意历史高度都能查的余额表。
流动性追踪
DeFi 协议事件触发时读取池子储备,追踪流动性随时间的变化。