WebSocket Streaming

wss://api.tradingnews.press/v1/stream?api_key=YOUR_KEY

{
  "id": "01KNKV33C9DDADR1HRRWGCSA8V",
  "content": "BREAKING: Fed announces emergency rate cut",
  "urgency": "breaking",
  "sentiment": null,
  "published_at": "2026-04-07T14:30:00+00:00",
  "received_at": "2026-04-07T14:30:02.123456+00:00"
}

import asyncio
import json
import websockets

async def stream_with_reconnect():
    backoff = 1
    while True:
        try:
            async with websockets.connect(
                "wss://api.tradingnews.press/v1/stream?api_key=YOUR_KEY"
            ) as ws:
                backoff = 1  # reset on success
                async for msg in ws:
                    article = json.loads(msg)
                    process(article)
        except websockets.ConnectionClosed:
            await asyncio.sleep(backoff)
            backoff = min(backoff * 2, 60)