WebSocket 实时推送

const API_KEY = "your-api-key";
const URL = `wss://api.tickflow.org/v1/ws/stream?api_key=${API_KEY}`;

const ws = new WebSocket(URL);

ws.onopen = () => {
  ws.send(JSON.stringify({ op: "subscribe", channel: "quotes", symbols: ["600000.SH"] }));
  ws.send(JSON.stringify({ op: "subscribe", channel: "depth",  symbols: ["600000.SH"] }));
};

ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);

  if (msg.op === "subscribed") {
    console.log(`[${msg.channel}] 已订阅 ${msg.total} 个标的`);
  } else if (msg.op === "quotes") {
    for (const q of msg.data) {
      console.log(`${q.symbol}: ${q.last_price}`);
    }
  } else if (msg.op === "depth") {
    for (const d of msg.data) {
      console.log(`[盘口] ${d.symbol} 买1:${d.bid_prices[0]} 卖1:${d.ask_prices[0]}`);
    }
  } else if (msg.op === "error") {
    console.error("错误:", msg.message);
  }
};

ws.onerror = (err) => console.error("WebSocket error:", err);
ws.onclose = (e) => console.log("连接关闭:", e.code, e.reason);

pip install "tickflow[all]" --upgrade

from tickflow import TickFlow

tf = TickFlow(api_key="your-api-key")
stream = tf.stream

@stream.on_quotes
def on_quotes(quotes):
    for q in quotes:
        print(f"{q['symbol']}: {q['last_price']}")

@stream.on_depth
def on_depth(depths):
    for d in depths:
        print(f"[盘口] {d['symbol']} 买1:{d['bid_prices'][0]}×{d['bid_volumes'][0]}")

@stream.on_error
def on_error(msg):
    print(f"错误: {msg}")

stream.subscribe("quotes", ["600000.SH", "000001.SZ"])
stream.subscribe("depth", ["600000.SH"])
stream.connect()  # 阻塞直到 close() 或 Ctrl+C

stream.connect(block=False)  # 后台线程运行
stream.subscribe("quotes", ["AAPL.US"])  # 动态追加订阅