Live Odds API

import json
import os
from urllib.parse import quote, urlencode
from urllib.request import Request, urlopen

base = "https://api.odds-api.net/v1"
headers = {"X-API-Key": os.environ["ODDS_API_KEY"]}

def get(path, **params):
    request = Request(f"{base}{path}?{urlencode(params)}", headers=headers)
    with urlopen(request, timeout=20) as response:
        return json.load(response)

events = get("/events", event_states="in_play", limit=50)["items"]
event = next((event for event in events
              if "betfair" in (event.get("bookmakers") or {})), None)
if event is None:
    raise RuntimeError("No in-play Betfair event found in this event page.")

event_id = quote(str(event["event_id"]), safe="")
snapshot = get(f"/events/{event_id}/exchange/orderbook/snapshot",
               exchanges="betfair", depth=3, refresh="true")
books = [book for book in snapshot.get("items", [])
         if book.get("exchange") == "betfair" and book.get("in_play")]
if not books:
    raise RuntimeError("No in-play Betfair order book returned for this event.")

print(json.dumps({"event_id": event["event_id"], "items": books,
                  "resume": snapshot.get("resume")}, indent=2))

# Find an in-play event that lists betfair.
curl --get "https://api.odds-api.net/v1/events" \
  --header "X-API-Key: $ODDS_API_KEY" \
  --data-urlencode "event_states=in_play" \
  --data-urlencode "limit=50"

# Set EVENT_ID to its event_id, then load the order book.
curl --get "https://api.odds-api.net/v1/events/$EVENT_ID/exchange/orderbook/snapshot" \
  --header "X-API-Key: $ODDS_API_KEY" \
  --data-urlencode "exchanges=betfair" \
  --data-urlencode "depth=3" \
  --data-urlencode "refresh=true"

# Use the event_id and resume token from your snapshot.
curl --no-buffer --get \
  "https://api.odds-api.net/v1/events/$EVENT_ID/exchange/orderbook/stream" \
  --header "X-API-Key: $ODDS_API_KEY" \
  --header "Accept: text/event-stream" \
  --data-urlencode "exchanges=betfair" \
  --data-urlencode "depth=3" \
  --data-urlencode "since=$RESUME" \
  --data-urlencode "catchup=true"

# delta: apply changes and retain the newest resume token.
# heartbeat: keep the connection open.
# resync: reload the snapshot and reconnect from its resume token.

// Server-side Node.js. Install: npm install ws
import WebSocket from "ws";

if (!process.env.EVENT_ID || !process.env.RESUME || !process.env.ODDS_API_KEY) {
  throw new Error("Set EVENT_ID, RESUME and ODDS_API_KEY from your snapshot.");
}
const eventId = encodeURIComponent(process.env.EVENT_ID);
const url = new URL(
  `wss://api.odds-api.net/v1/events/${eventId}/exchange/orderbook/ws`
);
url.search = new URLSearchParams({
  exchanges: "betfair", depth: "3", catchup: "true",
  since: process.env.RESUME
}).toString();

const socket = new WebSocket(url, {
  headers: { "X-API-Key": process.env.ODDS_API_KEY }
});
socket.on("message", (raw) => {
  const message = JSON.parse(raw.toString());
  if (message.event === "resync") {
    console.log("Reload the snapshot, then reconnect with its resume token.");
    socket.close();
    return;
  }
  console.log(message.event, message.data);
});
socket.on("error", console.error);