订阅 Solana 实时价格并更新图表

按范围选择价格房间：主池、指定池、全部池或跨池聚合。图表历史来自 Data API，实时价格用于更新当前 K 线。

URL: wss://datastream.solanatracker.io/{apiKey}
适用于 Premium、Business 和 Enterprise 套餐。

连接

所有 Datastream 频道使用同一个 WebSocket 连接。发送 JSON 消息即可加入和离开房间。心跳（ping/pong）、认证失败和离开语义见 Datastream 协议。

const ws = new WebSocket("wss://datastream.solanatracker.io/YOUR_API_KEY");

ws.onopen = () => {
  console.log("Connected");
};

ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);
  if (msg.type === "ping") {
    ws.send(JSON.stringify({ type: "pong" }));
    return;
  }
  if (msg.type === "message") {
    // Handle data
  }
};

按代币订阅价格

订阅 price-by-token:{tokenAddress} 可获取主池价格。主池通常是流动性最高的交易池。

const token = "9BB6NFEcjBCtnNLFko2FqVQBq8HHM13kCyYcdQbgpump";

// Join
ws.send(JSON.stringify({ type: "join", room: `price-by-token:${token}` }));

// Receive
ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);
  if (msg.type === "joined") {
    console.log(`Subscribed to ${msg.room}`);
  }
  if (msg.type === "message") {
    const { price, price_quote, pool, time } = msg.data;
    console.log(`$${price} (${price_quote} SOL) at ${new Date(time).toISOString()}`);
  }
};

// Leave when done
ws.send(JSON.stringify({ type: "leave", room: `price-by-token:${token}` }));

Payload:

{
  "type": "message",
  "room": "price-by-token:9BB6NFEcjBCtnNLFko2FqVQBq8HHM13kCyYcdQbgpump",
  "data": {
    "price": 0.008006,
    "price_quote": 0.00010064,
    "pool": "EWiYmq3nWQpoTkcU4UfGYEoYvDHduDsXhpPvqmoqpump",
    "token": "9BB6NFEcjBCtnNLFko2FqVQBq8HHM13kCyYcdQbgpump",
    "time": 1723728065246
  }
}

聚合价格

订阅 price:aggregated:{tokenAddress} 可获取跨池价格汇总。Payload 包含中位数、平均值、最小值、最大值和交易池数量。

const sol = "So11111111111111111111111111111111111111112";

ws.send(JSON.stringify({ type: "join", room: `price:aggregated:${sol}` }));

ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);
  if (msg.type === "message") {
    const { price, aggregated } = msg.data;
    console.log(`Price: $${price}`);
    console.log(`Median: $${aggregated.median} (${aggregated.poolCount} pools)`);
    console.log(`Range: $${aggregated.min} — $${aggregated.max}`);
  }
};

Payload:

{
  "price": 153.70,
  "aggregated": {
    "median": 153.68,
    "average": 153.67,
    "min": 153.36,
    "max": 153.71,
    "poolCount": 10
  },
  "topPools": [...]
}

按交易池订阅价格

订阅 price:{poolId} 可获取单个交易池的价格更新。适合只关注某个 DEX 或流动性来源的场景。

ws.send(JSON.stringify({ type: "join", room: "price:EWiYmq3nWQpoTkcU4UfGYEoYvDHduDsXhpPvqmoqpump" }));

全部交易池价格

订阅 price:{tokenAddress}（不带 aggregated）可接收代币所在每个交易池各自的价格更新。

ws.send(JSON.stringify({ type: "join", room: `price:${token}` }));

代币变化（完整更新）

需要价格以外的交易池状态（包括流动性、市值、供应量和安全字段）时，订阅 token:{tokenAddress}。

ws.send(JSON.stringify({ type: "join", room: `token:${token}` }));

ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);
  if (msg.type === "message") {
    const d = msg.data;
    console.log(`Price: $${d.price.usd}`);
    console.log(`Liquidity: $${d.liquidity.usd}`);
    console.log(`Market Cap: $${d.marketCap.usd}`);
    console.log(`LP Burn: ${d.lpBurn}%`);
  }
};

只看主池（多池代币的干扰更少）：

ws.send(JSON.stringify({ type: "join", room: `token:${token}:primary` }));

实时交易

订阅 transaction:{tokenAddress} 可实时查看每笔兑换。

ws.send(JSON.stringify({ type: "join", room: `transaction:${token}` }));

ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);
  if (msg.type === "message") {
    const trades = Array.isArray(msg.data) ? msg.data : [msg.data];
    trades.forEach(t => {
      const side = t.type === "buy" ? "BUY " : "SELL";
      console.log(`${side} $${t.volume.toFixed(2)} by ${t.wallet}`);
    });
  }
};

按交易池筛选：

ws.send(JSON.stringify({
  type: "join",
  room: `transaction:${token}:${poolId}`
}));

构建实时图表

从 OHLCV 端点加载历史 K 线，再用价格 tick 更新当前 K 线的开盘价、最高价、最低价和收盘价。仅靠价格 tick 无法得到成交量。

const token = "9BB6NFEcjBCtnNLFko2FqVQBq8HHM13kCyYcdQbgpump";
const headers = { "x-api-key": "YOUR_API_KEY" };

// 1. Load historical candles via REST
const now = Math.floor(Date.now() / 1000);
const candles = await fetch(
  `https://data.solanatracker.io/chart/${token}?type=1m&time_from=${now - 3600}&time_to=${now}`,
  { headers }
).then(r => r.json());

let currentCandle = candles[candles.length - 1];

// 2. Stream live price updates
const ws = new WebSocket("wss://datastream.solanatracker.io/YOUR_API_KEY");

ws.onopen = () => {
  ws.send(JSON.stringify({ type: "join", room: `price-by-token:${token}` }));
};

ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);
  if (msg.type !== "message") return;

  const { price, time } = msg.data;
  const candleStart = Math.floor(time / 60000) * 60;

  if (candleStart > currentCandle.time) {
    // New candle
    candles.push(currentCandle);
    currentCandle = { time: candleStart, open: price, high: price, low: price, close: price, volume: 0 };
  } else {
    // Update current candle
    currentCandle.close = price;
    currentCandle.high = Math.max(currentCandle.high, price);
    currentCandle.low = Math.min(currentCandle.low, price);
  }

  // Render candles + currentCandle to your chart library
};

开源图表示例

以下示例仓库展示了如何连接历史数据和实时推送：

Liveline Chart

使用 Datastream WebSocket 的极简实时折线图，适合作为自定义界面的起点。

TradingView Advanced Chart

完整集成 TradingView Advanced Charts，通过 Datastream 实时更新 K 线。

成交量和统计

代币成交量

订阅 volume:token:{tokenAddress} 可获取聚合成交量更新：

ws.send(JSON.stringify({ type: "join", room: `volume:token:${token}` }));

代币统计

订阅 stats:token:{tokenAddress} 可获取多时间窗口统计（1m、5m、1h、6h、24h 的买卖笔数、成交量和独立交易者数）：

ws.send(JSON.stringify({ type: "join", room: `stats:token:${token}` }));

只需要一份总量快照时：

ws.send(JSON.stringify({ type: "join", room: `stats:token:${token}:total` }));

房间参考

房间格式	返回内容
`price-by-token:{token}`	主池价格
`price:aggregated:{token}`	跨池中位数、平均值、最小值、最大值
`price:{pool}`	单个交易池的价格
`price:{token}`	全部交易池的价格
`token:{token}`	完整交易池状态（价格、流动性、市值）
`token:{token}:primary`	仅主池状态
`transaction:{token}`	某代币的全部兑换
`transaction:{token}:{pool}`	指定交易池中的兑换
`volume:token:{token}`	聚合成交量
`stats:token:{token}`	多时间窗口统计

价格与图表

用于查询历史 OHLCV、价格快照和 ATH 数据的 REST 端点。

代币发行

订阅新代币、即将毕业的代币和市场事件。

开始使用

代币数据

钱包与盈亏

实时数据

Pump.fun

预测市场

兑换与 RPC

订阅 Solana 实时价格并更新图表

连接

按代币订阅价格

聚合价格

按交易池订阅价格

全部交易池价格

代币变化（完整更新）

实时交易

构建实时图表

开源图表示例

Liveline Chart

TradingView Advanced Chart

成交量和统计

代币成交量

代币统计

房间参考

价格与图表

代币发行

​连接

​按代币订阅价格

​聚合价格

​按交易池订阅价格

​全部交易池价格

​代币变化（完整更新）

​实时交易

​构建实时图表

​开源图表示例

Liveline Chart

TradingView Advanced Chart

​成交量和统计

​代币成交量

​代币统计

​房间参考

价格与图表

代币发行

连接

按代币订阅价格

聚合价格

按交易池订阅价格

全部交易池价格

代币变化（完整更新）

实时交易

构建实时图表

开源图表示例

成交量和统计

代币成交量

代币统计

房间参考