跳转到主要内容
DEX Pools 数据产品给你 ChainStream 索引的每个流动性池的状态——经典 Uniswap v2 恒积池、v3/v4 集中流动性池、Solana AMM 等——字段已规整。

包含什么

字段组举例
身份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/searchpools/{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 线而不是状态快照时用。