computo.py

async def main():
    global total_votes
    async with redis.client() as conn:
        while True:
            chunk = []
            votes = {}
            for _ in range(0, 1000):
                item = await conn.lpop("votos")
                if item is not None:
                    obj = json.loads(item)
                    option = "votos_" + obj["body"].split("=")[1]
                    if option in votes:
                        votes[option] += 1
                    else:
                        votes[option] = 1
                    chunk.append(obj)
                else:
                    break
            if chunk:
                for option in votes.keys():
                    await conn.incrby(option, amount=votes[option])
                await conn.rpush("votos_bd", json.dumps(chunk))
                total_votes += len(chunk)
            else:
                return