WebSocket API

import asyncio, json, os
from websockets.asyncio.client import connect

URL = "wss://mobs.ws/v1/ws/metar?airports=KNYC,KLGA"
HEADERS = {"Authorization": f"Bearer {os.environ['MOBS_API_KEY']}"}

async def heartbeat(ws):
    while True:
        await asyncio.sleep(20)
        await ws.send(json.dumps({"action": "ping"}))

async def main():
    async with connect(URL, additional_headers=HEADERS) as ws:
        beat = asyncio.create_task(heartbeat(ws))
        try:
            async for text in ws:
                msg = json.loads(text)
                if msg["type"] == "new_metar_arrived":
                    for rec in msg["data"]:
                        print(rec["icao"], rec["raw_metar"])
        finally:
            beat.cancel()

asyncio.run(main())

websocat -H "Authorization: Bearer $MOBS_API_KEY" \
  "wss://mobs.ws/v1/ws/metar?airports=KNYC,KLGA"

// Browsers cannot set socket headers; use ?token= here only.
const ws = new WebSocket(
  "wss://mobs.ws/v1/ws/metar?airports=KNYC&token=YOUR_API_KEY");
setInterval(() => ws.send('{"action":"ping"}'), 20000);
ws.onmessage = (e) => console.log(JSON.parse(e.data));