Python

pip install websockets

import asyncio, json
from urllib.parse import urlencode

import websockets

KEY = "mts_live_YOUR_KEY"
CHANNELS = ["metar.obs.eglc", "metar.obs.rksi"]

async def stream():
    url = "wss://stream.metar.ws/v1/ws?" + urlencode({"key": KEY})
    async with websockets.connect(url) as ws:
        ack = json.loads(await ws.recv())
        print("connected:", ack["plan"], ack["limits"])

        await ws.send(json.dumps({"action": "subscribe", "channels": CHANNELS}))

        async for frame in ws:
            msg = json.loads(frame)
            if msg["type"] == "publication":
                d = msg["data"]
                print(f'{d["station"]}: {d["temp_c"]}°C at {d["report_time"]}')
            elif msg["type"] == "error":
                print("error:", msg["code"], msg.get("channel", ""))

async def main():
    while True:  # reconnect loop; deploys and blips are normal
        try:
            await stream()
        except Exception as e:
            print(f"disconnected: {e} - reconnecting in 3s")
            await asyncio.sleep(3)

asyncio.run(main())