import asyncioimport websocketsimport jsonimport pprintasync def aggTrade(): symbol = 'btcusdt' uri = f'wss://fstream.binance.com/ws/{symbol}@aggTrade' async with websockets.connect(uri) as websocket: try: while True: message = await websocket.recv() data = json.loads(message) pprint.pprint(data) except asyncio.Cancel..