Sample Websockets code in python; Receive via the data variable; Requirements: pip3 install asyncio websockets

sample_websockets.py

import asyncio
import websockets
import json

# Requirements
# pip3 install asyncio websockets

# TODO: Replace wss endpoint
stream = 'wss://stream...'

async def main():
  async with websockets.connect(stream) as ws:
    while True:
      try:
        data = await ws.recv()
        
        # Wss data comes out here
        print(f"{data}")
        
      except TypeError as e:
        print(f"TypeError: {e}")
      except KeyboardInterrupt as e:
        print(f"KeyboardInterrupt: {e}"
        
if __name__ == "__main__":
  loop.asyncio.new_event_loop()
  loop.run_until_completion(main())