Binance Square WebSocket API quick start

# pip install "websockets>=13"   (Python 3.9+)
import asyncio, json, os
from websockets.asyncio.client import connect

# ws_path and WS key: the API access page in your dashboard
WS_PATH = os.environ["BINANCE_WS_PATH"].strip("/")
WS_URL = "wss://binance.1322.io/" + WS_PATH + "?key=" + os.environ["BINANCE_WS_KEY"]

def handle(frame):
    kind = frame.get("type")
    data = frame.get("data") or {}
    if kind == "binance.post":
        print(data.get("username"), data.get("tendency") or "-", (data.get("text") or "")[:80])
    elif kind == "binance.pin.update":
        print("pins changed:", data.get("username"),
              len(data.get("added") or []), "added,", len(data.get("removed") or []), "removed")

async def main():
    backoff = 1
    while True:
        try:
            async with connect(WS_URL) as ws:
                backoff = 1
                async for raw in ws:
                    try:
                        event = json.loads(raw)
                    except ValueError:
                        continue
                    if isinstance(event, dict):
                        handle(event)
        except Exception as exc:
            print("disconnected:", exc)
        await asyncio.sleep(backoff)
        backoff = min(backoff * 2, 30)

asyncio.run(main())

// npm install ws, save as consumer.mjs, run: node consumer.mjs   (Node 18+)
import WebSocket from "ws"

// ws_path and WS key: the API access page in your dashboard
const WS_PATH = (process.env.BINANCE_WS_PATH ?? "").split("/").filter(Boolean).join("/")
const WS_KEY = process.env.BINANCE_WS_KEY
if (!WS_PATH || !WS_KEY) throw new Error("Set BINANCE_WS_PATH and BINANCE_WS_KEY")
const WS_URL = "wss://binance.1322.io/" + WS_PATH + "?key=" + encodeURIComponent(WS_KEY)

function handle(frame) {
  const data = frame.data ?? {}
  if (frame.type === "binance.post") {
    console.log(data.username, data.tendency || "-", (data.text ?? "").slice(0, 80))
  } else if (frame.type === "binance.pin.update") {
    console.log("pins changed:", data.username, (data.added ?? []).length, "added,", (data.removed ?? []).length, "removed")
  }
}

let backoff = 1000

function connect() {
  const ws = new WebSocket(WS_URL)
  ws.on("open", () => { backoff = 1000 })
  ws.on("message", (raw) => {
    let event
    try { event = JSON.parse(raw.toString()) } catch { return }
    if (event && typeof event === "object" && !Array.isArray(event)) handle(event)
  })
  ws.on("error", (err) => console.error("socket error:", err.message))
  ws.on("close", () => {
    setTimeout(connect, backoff)
    backoff = Math.min(backoff * 2, 30000)
  })
}

connect()

{
  "type": "binance.post",
  "data": {
    "id": "356349125025001",
    "username": "examplecrypto",
    "display_name": "Example Crypto",
    "content_type": "post",
    "is_reply": false,
    "text": "Watching #bitcoin hold the weekly level.",
    "tendency": "bullish",
    "coin_pairs": [
      "BTCUSDT"
    ],
    "hashtags": [
      "bitcoin"
    ],
    "like_count": 12,
    "view_count": 940,
    "published_at": "2026-10-15T14:03:20Z",
    "detected_at": "2026-10-15T14:03:21Z"
  }
}

curl "https://binance.1322.io/v1/dashboard" \
  -H "X-Api-Key: $BINANCE_API_KEY"

curl -X POST "https://binance.1322.io/v1/track" \
  -H "Content-Type: application/json" \
  -H "X-Api-Key: $BINANCE_API_KEY" \
  -d '{ "username": "examplecrypto" }'

curl -X POST "https://binance.1322.io/v1/untrack" \
  -H "Content-Type: application/json" \
  -H "X-Api-Key: $BINANCE_API_KEY" \
  -d '{ "username": "examplecrypto" }'