追踪流动性池储备变化

本教程使用以太坊主网的 Uniswap V2 USDC–ETH 池 0xb4e16d0168e52d35cacd2c6185b44281ec28c9dc。合约内的两种代币是 USDC 和 WETH。

chain.event.eth → 筛选池子的 Sync 事件 → 读取区块末储备 → 储备状态表

开始前

进入新建或已有的 Space。本文使用 demo，操作时替换为你的 Space ID。

1. 创建储备状态表

在 Tables 中创建表，名称填 pool_reserves，类型选择 Block State，链选择 Ethereum。创建后的表 ID 为 demo.pool_reserves.eth。

在表的 Schema 中，将 id 的类型改为 ADDRESS，用于存放池地址，并添加以下字段。保留系统预置的区块字段和其他默认配置：

字段名	类型	内容
`reserve_usdc`	`UINT256`	USDC 原始储备量
`reserve_weth`	`UINT256`	WETH 原始储备量

2. 创建 Function

在 Functions 中创建 read_pool_reserves，输入以下代码：

def _(event):
    from leafage import ChainState

    pool = '0xb4e16d0168e52d35cacd2c6185b44281ec28c9dc'
    chain = ChainState('eth', event['block_id'])
    reserve_usdc, reserve_weth, _ = chain.call(
        pool, 'getReserves()(uint112,uint112,uint32)', []
    )
    return {
        'id': pool,
        'reserve_usdc': reserve_usdc,
        'reserve_weth': reserve_weth,
        'block_id': event['block_id'],
        'block_height': event['block_height'],
        'block_timestamp': event['block_timestamp'],
    }

在编辑器下方添加参数 event，类型选择 JSON，然后保存 Function。具体操作见创建 Function。 Function 使用事件的 block_id 读取区块执行完成后的储备。同一区块中的多条 Sync 事件会得到相同的区块末状态。返回记录同时带上事件的区块字段，回填范围较大时需要它们，见结果处理器。

配置接收 event 参数的 read_pool_reserves Function

3. 运行 Pipeline

配置 Pipeline

在 Notebooks 中创建 backfill_pool_reserves，输入以下代码，将 SPACE 改为你的 Space ID：

from blockdb import Column
from blockdb.operator import filter
from blockx import Pipeline, ROW

SPACE = 'demo'

pipeline = Pipeline(
    sources=[{
        'table_id': 'chain.event.eth',
        'func_id': f'{SPACE}.read_pool_reserves',
        'args_tmpl': [ROW],
        'operator': filter(
            (Column('contract_id') == '0xb4e16d0168e52d35cacd2c6185b44281ec28c9dc')
            & (Column('name') == 'Sync')
        ),
    }],
    target=f'{SPACE}.pool_reserves.eth',
)

pipeline.backfill(start=25939925, end=25939934)

sources 指定源表和已保存的 Function；operator 筛选事件，ROW 将每条源记录作为参数传入。Function 返回的记录由 Pipeline 写入 target 指定的表。

运行回填

保存并点击 Run，在 Output 或 Instance detail 中查看回填进度和处理结果。 backfill() 处理指定的 10 个区块，包含起止高度，完成后自动结束。

4. 查看当前状态和历史变化

回到 pool_reserves.eth，在 Overview 查看已处理区块。本次只回填了一个局部区间，更早的历史尚未补齐。

打开 Subtables 下的 latest，查看当前储备。本例按池地址写入，两次状态更新最终保留一条当前记录。

打开 archive，查看不同区块的历史状态。original_id 是池地址，id 是该历史记录的 ID。

archive 子表保存区块 25939928 和 25939930 的两次储备变化

图中在高度 25939928 和 25939930 各有一条状态记录。储备字段保留原始整数值：

USDC 原始值除以 10^6，得到 USDC 数量。
WETH 原始值除以 10^18，得到 WETH 数量。

可选：持续更新

新建 Notebook update_pool_reserves，复制前面的代码，将最后一行 pipeline.backfill(...) 替换为以下调用，保存并运行：

pipeline.update()

update() 默认从最小未完成区块开始补齐历史，追上最新区块后持续更新。只需要某个高度之后的数据时，可先设置起始高度。历史区块较多时，也可以在另一个 Notebook 中同时运行 backfill()，加快回填。

update_pool_reserves Notebook 的持续更新调用和历史区块处理日志

选择 Switch to Background 可转为后台运行。在账户的 Instances 中取消实例即可停止，已写入的数据会保留。

概览

快速开始

使用指南

参考