Coordina procesosa gran escala

# Responder ya, hacer el trabajo lento después
@app.post("/informes")
async def crear_informe(datos: Filtro):
    # no se genera aquí: se encola
    job = generar_informe.delay(datos.dict())
    return {"job_id": job.id, "estado": "en_cola"}, 202

# Consumidor idempotente: procesar dos veces no rompe
@app.task(bind=True, max_retries=3)
def generar_informe(self, datos):
    if ya_procesado(datos["id"]):
        return  # deduplicación
    try:
        construir_y_guardar(datos)
    except TransitorioError as e:
        raise self.retry(exc=e, countdown=2 ** self.request.retries)

// Empujar al cliente en vez de que pregunte
io.on('connection', (socket) => {
  socket.join(`sala:${salaId}`);
});

// Al ocurrir un evento, avisar a toda la sala
bus.on('mensaje.nuevo', (m) => {
  io.to(`sala:${m.salaId}`).emit('mensaje', m);
});