ws_client.py

import aiohttp
import asyncio

async def main():
    session = aiohttp.ClientSession()
    ws = await session.ws_connect(
        'wss://ws.example.com/channel')

    while True:
        msg = await ws.receive()

        if msg.type == aiohttp.WSMsgType.TEXT:
            if msg.data == 'close':
                await ws.close()
                break
            else:
                print(msg.data)
                # ws.send_str(msg.data + '/answer')
        elif msg.tp == aiohttp.MsgType.closed:
            break
        elif msg.tp == aiohttp.MsgType.error:
            break


loop = asyncio.get_event_loop()
loop.run_until_complete(main())