Websocet tutorial 5: Redis relay

ws5.py

from aioredis.pubsub import Receiver

REDIS_URL = 'localhost'
REDIS_PORT = 6379

async def redis_relay(websocket):
    conn = aioredis.create_connection((REDIS_URL, REDIS_PORT)) 
    receiver = Receiver()
    connection.execute_pubsub('subscribe', receiver.channel(‘updates’))
    while (await receiver.wait_message()):
        message = await receiver.get()
        await websocket.send(message)