Messages
{
"type": "join",
"room": "price:EWiYmq3nWQpoTkcU4UfGYEoYvDHduDsXhpPvqmoqpump"
}{
"type": "leave",
"room": "price:EWiYmq3nWQpoTkcU4UfGYEoYvDHduDsXhpPvqmoqpump"
}{
"type": "joined",
"room": "price:EWiYmq3nWQpoTkcU4UfGYEoYvDHduDsXhpPvqmoqpump"
}{
"type": "message",
"room": "price:EWiYmq3nWQpoTkcU4UfGYEoYvDHduDsXhpPvqmoqpump",
"data": {
"price": 0.000008006,
"price_quote": 0.0000010064,
"pool": "EWiYmq3nWQpoTkcU4UfGYEoYvDHduDsXhpPvqmoqpump",
"token": "EWiYmq3nWQpoTkcU4UfGYEoYvDHduDsXhpPvqmoqpump",
"time": 1723728065246
}
}Websockets
Price by pool
通过 Datastream WebSocket 实时流式传输指定 Solana DEX 交易池的价格更新，驱动按池图表与池级交易告警。
WSS
SDK Example
import { Datastream } from '@solana-tracker/data-api';
const dataStream = new Datastream({
wsUrl: 'wss://datastream.solanatracker.io/YOUR_API_KEY',
});
await dataStream.connect();
const sub = dataStream.subscribe.price.pool('9d9mb8kooFfaD3SctgZtkxQypkshx6ezhbKio89ixyy2').on((data) => {
console.log(data);
});
// sub.unsubscribe();
Messages
{
"type": "join",
"room": "price:EWiYmq3nWQpoTkcU4UfGYEoYvDHduDsXhpPvqmoqpump"
}{
"type": "leave",
"room": "price:EWiYmq3nWQpoTkcU4UfGYEoYvDHduDsXhpPvqmoqpump"
}{
"type": "joined",
"room": "price:EWiYmq3nWQpoTkcU4UfGYEoYvDHduDsXhpPvqmoqpump"
}{
"type": "message",
"room": "price:EWiYmq3nWQpoTkcU4UfGYEoYvDHduDsXhpPvqmoqpump",
"data": {
"price": 0.000008006,
"price_quote": 0.0000010064,
"pool": "EWiYmq3nWQpoTkcU4UfGYEoYvDHduDsXhpPvqmoqpump",
"token": "EWiYmq3nWQpoTkcU4UfGYEoYvDHduDsXhpPvqmoqpump",
"time": 1723728065246
}
}apiKey
type:httpApiKey
API key for authentication. Include your Datastream key in the connection URL: wss://datastream.solanatracker.io/{DATASTREAM_KEY}
joinPricePool
type:object
Subscribe to pool price updates
leavePricePool
type:object
Unsubscribe from pool price
pricePoolJoined
type:object
Pool price subscription confirmed
pricePoolMessage
type:object
Pool price update
此页面对您有帮助吗？
⌘I