跳转到主要内容
Trades 数据产品是 ChainStream 索引的每一笔 DEX swap 的规整版本——你可以按代币、钱包、池子、路由器查询,不用关心事件来自哪个 AMM。

包含什么

覆盖与新鲜度

  • 链:支持的链 里全部。
  • DEX:Uniswap v2/v3/v4、Raydium、Meteora、PancakeSwap、Aerodrome、Jupiter 路由等——详见 分链支持表。
  • 延迟:区块级——Kafka 在确认后 1–2s 投递,REST 5–10s。

接入方式

REST

tokens/{address}/trades、wallets/{address}/trades、pools/{address}/trades。

GraphQL

灵活过滤器;Trades 可与 Tokens、Wallets JOIN。

WebSocket

dex-trade:{chain}_{tokenAddress}(按 token)和 dex-wallet-trade:{chain}_{walletAddress}(按钱包)。SDK:client.stream.subscribeTokenTrade / subscribeWalletTrade。

Kafka

各链 *.dex.trade 主题,Protobuf 编码。

SDK / CLI

client.trade.stream()、chainstream trade tail。

MCP

Agent 用 trades_list、trades_stream 工具。

常见用例

  • 渲染某代币的实时成交 tape
  • 计算钱包的已实现 PnL
  • 在首笔买入 / 大单上触发告警
  • 为交易机器人提供 maker/taker 上下文
  • 自定义周期聚合成 OHLC(或直接用 Candles)

计费

REST / GraphQL 按 limit 分页计费;WebSocket 与 Kafka 按投递条数,流量越大阶梯折扣越多。

下一步

Candles (OHLC) K 线

不需要 tick 级粒度时用预聚合好的 K 线。

Smart Money 聪明钱

筛选到高胜率钱包的那部分交易。