索引 ERC-20 转账

本教程将以太坊主网的 USDC 转账整理成事件表，记录发送方、接收方、金额和交易哈希。

chain.event.eth → 筛选 USDC Transfer 事件 → 提取转账字段 → 转账事件表

开始前

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

1. 创建转账事件表

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

在表的 Schema 中添加以下字段，保留系统预置字段和其他默认配置：

字段名	类型	内容
`tx_id`	`TXID`	交易哈希
`from_address`	`ADDRESS`	发送方地址
`to_address`	`ADDRESS`	接收方地址
`amount`	`UINT256`	转账金额的原始整数值

2. 创建 Function

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

def _(event):
    sender, recipient, amount = event['params']
    return {
        'id': event['id'],
        'tx_id': event['tx_id'],
        'from_address': sender,
        'to_address': recipient,
        'amount': amount,
        'block_id': event['block_id'],
        'block_height': event['block_height'],
        'block_timestamp': event['block_timestamp'],
    }

在编辑器下方添加参数 event，类型选择 JSON，然后保存 Function。具体操作见创建 Function。 Function 从事件的 params 提取发送方、接收方和金额，返回要写入转账表的记录。返回记录同时带上事件的区块字段，回填范围较大时需要它们，见结果处理器。

配置接收 event 参数的 parse_usdc_transfer Function

3. 运行 Pipeline

配置 Pipeline

在 Notebooks 中创建 backfill_usdc_transfers，输入以下代码，将 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}.parse_usdc_transfer',
        'args_tmpl': [ROW],
        'operator': filter(
            (Column('contract_id') == '0xa0b86991c6218b36c1d19d4a2e9eb0ce3606eb48')
            & (Column('name') == 'Transfer')
        ),
    }],
    target=f'{SPACE}.usdc_transfers.eth',
)

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

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

运行回填

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

4. 查看转账数据

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

打开 Subtables 下的 event，查看转账记录。

每条记录使用源事件的 id，区块字段由 Pipeline 自动补齐。 amount 保留原始整数值，除以 10^6 即为 USDC 数量。

可选：持续更新

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

pipeline.update()

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

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

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

概览

快速开始

使用指南

参考