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

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

URL: wss://datastream.solanatracker.io/{apiKey}
Available on Premium, Business, and Enterprise plans.

Connect

All Datastream channels use the same WebSocket connection. Send JSON messages to join and leave rooms. See the Datastream protocol for heartbeat (ping/pong), auth failures, and leave semantics.

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

Subscribe to price-by-token:{tokenAddress} for the primary pool’s price. The primary pool is usually the one with the most liquidity.

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
  }
}

Aggregated Price

Subscribe to price:aggregated:{tokenAddress} for a cross-pool price summary. The payload includes median, average, minimum, maximum, and pool count.

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 by Pool

Subscribe to price:{poolId} for price updates from one specific pool. Use this when you care about a particular DEX or liquidity source.

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

All Pool Prices

Subscribe to price:{tokenAddress} (without aggregated) to receive individual price updates from every pool a token trades on.

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

Token Changes (Full Updates)

Subscribe to token:{tokenAddress} when you need pool state beyond price, including liquidity, market cap, supply, and security fields.

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}%`);
  }
};

For primary pool only (less noise on multi-pool tokens):

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

Live Transactions

Subscribe to transaction:{tokenAddress} to see every swap as it happens.

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}`);
    });
  }
};

Filter by pool:

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

Build a Live Chart

Load historical candles from the OHLCV endpoint, then use price ticks to update the current candle’s open, high, low, and close. Price ticks alone do not provide traded volume.

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
};

Open-Source Chart Examples

These example repositories show how to connect the history and live feeds:

Liveline Chart

Minimal real-time line chart using the Datastream WebSocket. Good starting point for custom UIs.

TradingView Advanced Chart

Full TradingView Advanced Charts integration with real-time candle updates from the Datastream.

Volume & Statistics

Token Volume

Subscribe to volume:token:{tokenAddress} for aggregated volume updates:

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

Token Statistics

Subscribe to stats:token:{tokenAddress} for multi-timeframe stats (1m, 5m, 1h, 6h, 24h buy/sell counts, volume, unique traders):

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

For a single total snapshot:

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

Room Reference

Room pattern	What you get
`price-by-token:{token}`	Price from primary pool
`price:aggregated:{token}`	Cross-pool median/avg/min/max
`price:{pool}`	Price from one pool
`price:{token}`	Price from all pools
`token:{token}`	Full pool state (price, liquidity, mcap)
`token:{token}:primary`	Primary pool state only
`transaction:{token}`	All swaps on a token
`transaction:{token}:{pool}`	Swaps in a specific pool
`volume:token:{token}`	Aggregated volume
`stats:token:{token}`	Multi-timeframe statistics

价格与图表

REST endpoints for historical OHLCV, price snapshots, and ATH data.

代币发行

Stream new tokens, graduating tokens, and market events.

开始使用

代币数据

钱包与盈亏

实时数据

Pump.fun

预测市场

兑换与 RPC

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

Connect

Price by Token

Aggregated Price

Price by Pool

All Pool Prices

Token Changes (Full Updates)

Live Transactions

Build a Live Chart

Open-Source Chart Examples

Liveline Chart

TradingView Advanced Chart

Volume & Statistics

Token Volume

Token Statistics

Room Reference

价格与图表

代币发行

​Connect

​Price by Token

​Aggregated Price

​Price by Pool

​All Pool Prices

​Token Changes (Full Updates)

​Live Transactions

​Build a Live Chart

​Open-Source Chart Examples

Liveline Chart

TradingView Advanced Chart

​Volume & Statistics

​Token Volume

​Token Statistics

​Room Reference

价格与图表

代币发行

Connect

Price by Token

Aggregated Price

Price by Pool

All Pool Prices

Token Changes (Full Updates)

Live Transactions

Build a Live Chart

Open-Source Chart Examples

Volume & Statistics

Token Volume

Token Statistics

Room Reference