html_parse

def get_data(html):
    ...


async def reader():
    sub = await aioredis.create_redis('redis://localhost')
    ch = await sub.subscribe('chan:1')
    with Pool(cpu_count()) as pool:
        while (await ch[0].wait_message()):
            data = await ch[0].get_json()
            pool.apply_async(get_data, (data,))
    await sub.unsubscribe('chan:1')
    sub.close()


if __name__ == '__main__':
    asyncio.get_event_loop().run_until_complete(reader())