包含什么
| 字段组 | 举例 |
|---|---|
| 身份 | chainId, poolAddress, dex, pairType(v2/v3/v4/CLMM/StableSwap) |
| 代币 | token0, token1, decimals0, decimals1, reserve0, reserve1 |
| 经济 | tvlUsd, volume24hUsd, feeTierBps, apy7d |
| 状态 | priceToken0InToken1, sqrtPriceX96, tick, liquidity |
| 来源 | createdAtBlock, factoryAddress, initCodeHash |
覆盖与新鲜度
- 池子创建按区块检测;状态字段在每次 swap / add / remove 之后更新(通常秒级)。
- 历史 TVL 与成交量按 1h、1d 聚合。
接入方式
REST
pools/{address}、pools/search、pools/{address}/trades。GraphQL
一个查询把 Pools 与 Tokens、Trades JOIN。
WebSocket
dex-pool-balance:{chain}_{poolAddress} 实时池流动性;池创建事件从 Kafka {chain}.dex.pools 消费。SDK:client.stream.subscribeDexPoolBalance。Kafka
各链
*.pool.created、*.pool.sync 主题。常见用例
- 构建按 TVL / 成交量筛选的 all-pools 看板
- 抓新池 / 打新告警
- swap 前检查具体池子深度
- 驱动需要实时储备的路由层
计费
单池查询 1 read unit;搜索与列表按limit 计费。
下一步
Trades 交易
流经这些池子的成交流。
Candles (OHLC) K 线
想要 K 线而不是状态快照时用。

