WSS

export OPENNEWS_TOKEN="YOUR_TOKEN"

import asyncio
import json
import os
from contextlib import suppress
from urllib.parse import quote
from websockets.asyncio.client import connect

async def heartbeat(ws):
    while True:
        await ws.send("ping")
        await asyncio.sleep(20)

async def main():
    token = quote(os.environ["OPENNEWS_TOKEN"], safe="")
    url = f"wss://ai.6551.io/open/news_wss?token={token}"
    subscription = {"jsonrpc": "2.0", "id": 1, "method": "news.subscribe",
        "params": {"coins": ["BTC", "ETH"], "engineTypes": {"news": []}}}
    async with connect(url, ping_interval=None) as ws:
        await ws.send(json.dumps(subscription))
        keepalive = asyncio.create_task(heartbeat(ws))
        try:
            async for message in ws:
                if message != "pong":
                    print(json.dumps(json.loads(message), ensure_ascii=False))
        finally:
            keepalive.cancel()
            with suppress(asyncio.CancelledError):
                await keepalive

if __name__ == "__main__":
    try:
        asyncio.run(main())
    except KeyboardInterrupt:
        pass

python -m pip install "websockets>=14,<18"
python wss_demo.py