import websocket
import json
def on_message(ws, message):
msg = json.loads(message)
if msg["type"] == "rfq":
print("RFQ event:", msg["data"])
elif msg["type"] == "mve_trades":
print("MVE trade:", msg["data"])
def on_open(ws):
ws.send(json.dumps({
"action": "subscribe",
"market_ids": ["KXATPMATCH-26FEB13FRIKOR-FRI"],
"message_types": ["rfq", "mve_trades"]
}))
ws = websocket.WebSocketApp(
"wss://api.delphiterminal.co/ws/parlays?api_key=dphi_live_your_key_here",
on_message=on_message,
on_open=on_open,
)
ws.run_forever()