save_to_storage.py

async def main() -> dict:
    async with redis.client() as conn:
        while True:
            chunk = []
            for _ in range(0, 100):
                item = await conn.lpop("votos_bd")
                if item is not None:
                    chunk = chunk + json.loads(item)
                else:
                    break
            if not chunk:
                return
            else:
                block_id = str(uuid.uuid4())
                container_client.upload_blob(name=block_id, data=json.dumps(chunk))