Python Asyncio Loop Forever

loop forever.py

import asyncio

async def listener():
    while True:
        message = await sqs.poll()
        if message:
            asyncio.ensure_future(handle(message))
            
async def handler(message):
    await ...

loop = asyncio.get_event_loop()
asyncio.ensure_future(listener)
loop.run_forever()

Web Socket version and Queue

@asyncio.coroutine
def consumer(queue):
    while True:
        message = yield from queue.get()
        yield from handle(message)

@asyncio.coroutine
def listener(queue):
    for i in range(5):
         asyncio.ensure_future(consumer(queue))
    while True:
        message = yield from websocket.recieve_message()
        if message:
            yield from q.put(message)

q = asyncio.Queue()
loop = asyncio.get_event_loop()
loop.run_until_complete(listener(q))