WebSocket API குறிப்பு
வேல்ஸ் நிலைகள், நிதியளிப்பு விகிதங்கள், லிக்விடேஷன்கள் மற்றும் AI உறுதிப்படுத்தல் மதிப்பெண்களுக்கான நிகழ்நேர தரவு ஸ்ட்ரீமிங். தானியங்கி மீண்டும் இணைப்பு, திறமையான தரவு சுருக்கம் மற்றும் பல ஸ்ட்ரீம் சந்தாக்களுடன் சப்-செகண்ட் லேட்டன்சி.
கண்ணோட்டம்
WebSocket API நிகழ்நேர கிரிப்டோகரன்சி டெரிவேடிவ்ஸ் தரவுக்கான குறைந்த லேட்டன்சி, இருமுனை தகவல்தொடர்பை வழங்குகிறது. REST எண்ட்பாயிண்டுகளை ஒவ்வொரு 5-30 வினாடிகளிலும் பாலிங் செய்வதற்கு பதிலாக, WebSocket இணைப்புகள் சந்தை நிலைமைகள் மாறும்போது உடனடியாக புதுப்பிப்புகளை வழங்குகின்றன. ட்ரேடிங் போட்கள், அலர்ட் சிஸ்டம்கள் மற்றும் நிகழ்நேர டாஷ்போர்டுகளுக்கு சரியானது.
REST ஐ விட WebSocket இன் முக்கிய நன்மைகள்:
சந்தையை நகர்த்தும் நிகழ்வுகளுக்கான சப்-செகண்ட் லேட்டன்சி (லிக்விடேஷன்கள், வேல்ஸ் நகர்வுகள்)
டெல்டா-குறியிடப்பட்ட புதுப்பிப்புகளுடன் திறமையான பேண்ட்வித் பயன்பாடு
ஒற்றை இணைப்பில் பல ஒரே நேரத்தில் சந்தாக்கள்
சர்வர்-சைடு வடிகட்டல் மற்றும் ஒருங்கிணைப்பு
தானியங்கி ஹார்ட்பீட் மற்றும் மீண்டும் இணைப்பு கையாளுதல்
உங்கள் குவோட்டாவுக்கு எதிரான குறைந்த API கோரிக்கை எண்ணிக்கை
WebSocket இணைப்புகள் அனைத்து API டையர்களுக்கும் கிடைக்கின்றன. இலவச டையர் பயனர்கள் நிதியளிப்பு-விகிதங்கள் மற்றும் லிக்விடேஷன்கள் ஸ்ட்ரீம்களுக்கு சந்தா செய்யலாம். ட்ரேடர் மற்றும் ப்ரோ டையர்கள் வேல்ஸ் நிலைகள், திறந்த வட்டி மற்றும் உறுதிப்படுத்தல் மதிப்பெண்களை திறக்கின்றன.
அங்கீகாரம்
WebSocket இணைப்புகள் REST எண்ட்பாயிண்டுகளைப் போலவே அதே அங்கீகாரத்தைப் பயன்படுத்துகின்றன. உங்கள் API விசையை ஒரு குவேரி பாராமீட்டராக அனுப்பவும் அல்லது இணைத்த பிறகு முதல் செய்தியில் அனுப்பவும்.
இணைப்பு URL
அடிப்படை WebSocket URL: wss://ws.smartmoneyapi.com/stream
உங்கள் API விசையை இணைப்பு URL இல் சேர்க்கவும்:
wss://ws.smartmoneyapi.com/stream?token=sk_live_abc123xyz789
இணைப்பு வாழ்க்கைச் சுழற்சி
ஆரம்ப இணைப்பு
நீங்கள் WebSocket எண்ட்பாயிண்டுடன் இணைக்கும்போது, சர்வர் உங்கள் அங்கீகார டோக்கனை சரிபார்த்து இணைப்பு ஒப்புதலை அனுப்புகிறது.
{
"type": "connection_ack",
"connection_id": "conn_1a2b3c4d5e6f7g8h",
"server_version": "1.2.4",
"timestamp": "2026-03-21T14:35:22Z",
"api_tier": "pro",
"max_subscriptions": 50,
"max_symbols_per_sub": 100
}
ஹார்ட்பீட் (பிங்/பாங்)
சர்வர் ஒவ்வொரு 30 வினாடிகளுக்கும் காலமுறை ஹார்ட்பீட் பிங்களை அனுப்புகிறது. உங்கள் கிளையண்ட் இணைப்பை உயிர்ப்புடன் வைத்திருக்க ஒரு பாங் செய்தியுடன் பதிலளிக்க வேண்டும். சர்வர் 10 வினாடிகளுக்குள் பாங் பதிலைப் பெறவில்லை என்றால், இணைப்பு மூடப்படும்.
const ws = new WebSocket("wss://ws.smartmoneyapi.com/stream?token=sk_live_abc123xyz789");
ws.onmessage = (event) => {
const msg = JSON.parse(event.data);
if (msg.type === "ping") {
// Respond to ping with pong
ws.send(JSON.stringify({
type: "pong",
id: msg.id
}));
}
};
ws.onopen = () => {
console.log("Connected to WebSocket");
};
சந்தாக்கள்
இணைத்த பிறகு, சந்தா செய்திகளைப் பயன்படுத்தி தரவு ஸ்ட்ரீம்களுக்கு சந்தா செய்யவும். ஒவ்வொரு சந்தாவும் சந்தை தரவு மாறும்போது புதுப்பிப்புகளை உருவாக்குகிறது.
சந்தா செய்தி வடிவம்
{
"type": "subscribe",
"channel": "whale_positions",
"symbols": ["BTCUSDT", "ETHUSDT"],
"params": {
"min_position_size": 10,
"exchanges": ["bybit", "binance"]
}
}
சந்தா நீக்கம் செய்தி வடிவம்
{
"type": "unsubscribe",
"channel": "whale_positions",
"symbols": ["BTCUSDT"]
}
வேல்ஸ் நிலைகள் ஸ்ட்ரீம்
அனைத்து கண்காணிக்கப்பட்ட சின்னங்கள் மற்றும் எக்ஸ்சேஞ்சுகளில் பெரிய வேல்ஸ் நிலைகளுக்கான நிகழ்நேர புதுப்பிப்புகள். வேல்ஸ்கள் நிலைகளைத் திறக்கும்போது, மூடும்போது அல்லது மாற்றும்போது புதுப்பிப்புகள் அனுப்பப்படுகின்றன. நுழைவு விலை, தற்போதைய விலை, P&L, லெவரேஜ் மற்றும் லிக்விடேஷன் ஆபத்து ஆகியவை அடங்கும்.
{
"type": "subscribe",
"channel": "whale_positions",
"symbols": ["BTCUSDT", "ETHUSDT", "SOLUSDT"]
}
புதுப்பிப்பு செய்தி
{
"type": "data",
"channel": "whale_positions",
"symbol": "BTCUSDT",
"data": {
"wallet_address": "0x1234...",
"exchange": "bybit",
"direction": "long",
"position_size": 25.3,
"entry_price": 41200.0,
"current_price": 43200.5,
"pnl": 50701.50,
"pnl_percent": 4.86,
"leverage": 8,
"liquidation_price": 33760.0,
"timestamp": "2026-03-21T14:35:45Z"
}
}
நிதியளிப்பு விகிதங்கள் ஸ்ட்ரீம்
Bybit, Binance மற்றும் Hyperliquid முழுவதும் நிகழ்நேர நிதியளிப்பு விகித புதுப்பிப்புகள். ஒவ்வொரு 1 நிமிடத்திற்கும் அல்லது விகிதங்கள் கணிசமாக மாறும்போது புதுப்பிக்கப்படுகிறது. தனிப்பட்ட எக்ஸ்சேஞ்ச் விகிதங்கள் மற்றும் ஒருங்கிணைந்த மெட்ரிக்ஸ் ஆகியவை அடங்கும்.
{
"type": "subscribe",
"channel": "funding_rates",
"symbols": ["BTCUSDT", "ETHUSDT"]
}
புதுப்பிப்பு செய்தி
{
"type": "data",
"channel": "funding_rates",
"symbol": "BTCUSDT",
"data": {
"timestamp": "2026-03-21T14:00:00Z",
"bybit": {
"rate": 0.000120,
"next_rate": 0.000145
},
"binance": {
"rate": 0.000098,
"next_rate": 0.000115
},
"hyperliquid": {
"rate": 0.000140,
"next_rate": 0.000160
},
"aggregated": {
"mean": 0.000119,
"median": 0.000120,
"spread": 0.000062
}
}
}
லிக்விடேஷன்கள் ஸ்ட்ரீம்
லெவரேஜ் நிலைகளின் கட்டாய மூடல்களைக் காட்டும் நிகழ்நேர லிக்விடேஷன் ஃபீட். நிலை அளவு, லிக்விடேஷன் விலை, திசை (நீண்ட/குறுகிய) மற்றும் எக்ஸ்சேஞ்ச் ஆகியவை அடங்கும். லிக்விடேஷன் கேஸ்கேட்கள் மற்றும் உயர் தாக்க சந்தை நகர்வுகளை அடையாளம் காண பயனுள்ளது.
{
"type": "subscribe",
"channel": "liquidations",
"params": {
"min_size_usd": 50000
}
}
புதுப்பிப்பு செய்தி
{
"type": "data",
"channel": "liquidations",
"data": {
"exchange": "binance",
"symbol": "BTCUSDT",
"direction": "long",
"position_size": 12.5,
"liquidation_price": 41000.0,
"size_usd": 512500.0,
"timestamp": "2026-03-21T14:35:12Z"
}
}
திறந்த வட்டி ஸ்ட்ரீம்
ஒவ்வொரு சின்னத்திலும் அனைத்து லெவரேஜ் வர்த்தகர்களுக்கான ஒருங்கிணைந்த திறந்த வட்டி. OI அதிகரிப்புகள் (லெவரேஜில் அதிக பணம் நுழைவது) மற்றும் குறைவுகள் (நிலைகள் மூடுவது) ஆகியவற்றைக் கண்காணிக்கவும். விலை இயக்கத்திலிருந்து OI விலகல் மறைந்திருந்த புல்லிஷ்/பேரிஷ் தீர்ந்துபோவதை அடையாளம் காண்கிறது.
{
"type": "subscribe",
"channel": "open_interest",
"symbols": ["BTCUSDT", "ETHUSDT"]
}
உறுதிப்படுத்தல் மதிப்பெண்கள் ஸ்ட்ரீம்
வேல்ஸ் நிலைகள், ஆன்-செயின் சிக்னல்கள், நிதியளிப்பு விகிதங்கள் மற்றும் உணர்வு தரவு ஆகியவற்றை இணைக்கும் நிகழ்நேர AI உறுதிப்படுத்தல் மதிப்பெண்கள். அடிப்படை சிக்னல்கள் மாறும்போது மதிப்பெண்கள் புதுப்பிக்கப்படுகின்றன, ட்ரேடிங் அல்காரிதம்களுக்கு நேரடி நுழைவு/வெளியேறு சிக்னல்களை வழங்குகின்றன.
{
"type": "subscribe",
"channel": "confirmation_scores",
"symbols": ["BTCUSDT", "ETHUSDT", "SOLUSDT"]
}
தானியங்கி மீண்டும் இணைப்பு தர்க்கம்
நெட்வொர்க் பிரச்சினைகள் அல்லது சர்வர் பராமரிப்பு இணைப்புகளை துண்டிக்கக்கூடும். சர்வர் லோடை மதிக்கும் போது தோல்விகளிலிருந்து தானாக மீட்க அதிவேக பேக்அஃப் மீண்டும் இணைப்பு தர்க்கத்தை செயல்படுத்தவும்.
பரிந்துரைக்கப்பட்ட மீண்டும் இணைப்பு உத்தி
class SmartMoneyWebSocket {
constructor(token, options = {}) {
this.token = token;
this.maxReconnectDelay = options.maxReconnectDelay || 30000;
this.reconnectDelay = 1000;
this.subscriptions = new Map();
this.connect();
}
connect() {
this.ws = new WebSocket(
`wss://ws.smartmoneyapi.com/stream?token=${this.token}`
);
this.ws.onopen = () => {
console.log("Connected");
this.reconnectDelay = 1000; // Reset backoff
this.resubscribe(); // Re-subscribe after reconnect
};
this.ws.onmessage = (event) => {
const msg = JSON.parse(event.data);
if (msg.type === "ping") {
this.ws.send(JSON.stringify({ type: "pong", id: msg.id }));
}
this.onMessage(msg);
};
this.ws.onclose = () => this.reconnect();
this.ws.onerror = (err) => console.error("WebSocket error:", err);
}
reconnect() {
console.log(`Reconnecting in ${this.reconnectDelay}ms`);
setTimeout(() => {
this.connect();
this.reconnectDelay = Math.min(
this.reconnectDelay * 1.5,
this.maxReconnectDelay
);
}, this.reconnectDelay);
}
subscribe(channel, symbols, params) {
const key = `${channel}:${symbols.join(",")}`;
this.subscriptions.set(key, { channel, symbols, params });
this.ws.send(JSON.stringify({ type: "subscribe", channel, symbols, params }));
}
resubscribe() {
for (const { channel, symbols, params } of this.subscriptions.values()) {
this.ws.send(JSON.stringify({ type: "subscribe", channel, symbols, params }));
}
}
onMessage(msg) {
if (msg.type === "data") {
console.log(`Update: ${msg.channel}/${msg.symbol}`, msg.data);
}
}
}
const client = new SmartMoneyWebSocket("sk_live_abc123xyz789");
client.subscribe("whale_positions", ["BTCUSDT", "ETHUSDT"]);
client.subscribe("funding_rates", ["BTCUSDT"]);
client.subscribe("liquidations", [], { min_size_usd: 100000 });
குறியீடு எடுத்துக்காட்டுகள்
Python WebSocket கிளையண்ட்
import asyncio
import json
import websockets
async def stream_whale_positions():
uri = "wss://ws.smartmoneyapi.com/stream?token=sk_live_abc123xyz789"
async with websockets.connect(uri) as websocket:
# Wait for connection ack
ack = await websocket.recv()
print(f"Connected: {ack}")
# Subscribe to whale positions
await websocket.send(json.dumps({
"type": "subscribe",
"channel": "whale_positions",
"symbols": ["BTCUSDT", "ETHUSDT"]
}))
# Listen for updates
while True:
try:
msg = await websocket.recv()
data = json.loads(msg)
if data["type"] == "ping":
# Respond to ping
await websocket.send(json.dumps({
"type": "pong",
"id": data["id"]
}))
elif data["type"] == "data":
print(f"New position: {data['data']}")
except websockets.exceptions.ConnectionClosed:
print("Connection closed, reconnecting...")
await asyncio.sleep(1)
asyncio.run(stream_whale_positions())
சந்தா செய்யும் போது வடிகட்டவும்: உங்கள் பயன்பாட்டில் வடிகட்டுவதற்கு பதிலாக சர்வர்-சைடில் தரவை வடிகட்ட params பொருளைப் பயன்படுத்தவும் (min_position_size, min_size_usd).
பேட்ச் சந்தாக்கள்: ஒரு சின்னத்திற்கு ஒரு சந்தாவை விட பல சின்னங்களுக்கு ஒரு செய்தியில் சந்தா செய்யவும்.
பயன்படுத்தப்படாதவற்றை சந்தா நீக்கவும்: ஒரு ஸ்ட்ரீம் தேவையில்லாதபோது, பேண்ட்வித் மற்றும் செய்தி அளவைக் குறைக்க சந்தா நீக்கவும்.
gzip சுருக்கத்தைப் பயன்படுத்தவும்: பேண்ட்வித் சேமிப்புக்காக உங்கள் WebSocket கிளையண்டில் செய்தி சுருக்கத்தை இயக்கவும் (20-40% குறைப்பு).
இணைப்பு ஆரோக்கியத்தைக் கண்காணிக்கவும்: பிங்/பாங் லேட்டன்சி மற்றும் தானியங்கி மீண்டும் இணைப்புகளைக் கண்காணித்து நெட்வொர்க் பிரச்சினைகளைக் கண்டறியவும்.
இணைப்பு துண்டிக்கப்பட்ட போது செய்திகளை பஃப்பர் செய்யவும்: இணைப்பு துண்டிக்கப்பட்ட போது, உத்தி சிக்னல்களை வரிசைப்படுத்தி மீண்டும் இணைக்கப்பட்ட போது அவற்றை செயல்படுத்தவும்.
இப்போதே ஸ்ட்ரீமிங் தொடங்குங்கள்
உங்கள் API விசையைப் பெற்று உண்மையான நேர வர்த்தக அமைப்புகளை உருவாக்கத் தொடங்குங்கள். WebSocket ஸ்ட்ரீமிங் அனைத்து அடுக்குகளிலும் கிடைக்கிறது.
API விசையைப் பெறுக
உண்மையான நேர வர்த்தக அமைப்புகளை உருவாக்குங்கள்
வால் நிலைகள், ஃபண்டிங் விகிதங்கள் மற்றும் AI உறுதிப்படுத்தல் மதிப்பெண்களை வினாடிக்கு குறைவான தாமதத்துடன் ஸ்ட்ரீம் செய்யவும்.
திட்டங்களைப் பார்க்கவும்