覆盖每类资产的实时行情数据 API

# AllTick — Real-time Financial Market Data API
# Real-time Forex, Stocks, Crypto, Commodities and Indices market data

import asyncio, json, os, uuid
import websockets

subscribe = {
    "cmd_id": 22004,
    "seq_id": 1,
    "trace": str(uuid.uuid4()),
    "data": {"symbol_list": [{"code": "EURUSD"}]},
}
heartbeat = {"cmd_id": 22000, "seq_id": 1, "trace": "heartbeat", "data": {}}

async def stream():
    token = os.environ["ALLTICK_API_TOKEN"]
    uri = f"wss://quote.alltick.co/quote-b-ws-api?token={token}"
    async with websockets.connect(uri) as socket:
        await socket.send(json.dumps(subscribe))

        async def keep_alive():
            while True:
                await asyncio.sleep(10)
                await socket.send(json.dumps(heartbeat))

        asyncio.create_task(keep_alive())
        async for message in socket:
            print(json.loads(message))

asyncio.run(stream())