Estoy ejecutando en un servidor fastify y cuando envío una solicitud, obtengo una tonelada de datos de mongodb y empiezo un ciclo for para procesar cada elemento. Esto puede tomar ~ 30 minutos. Cada elemento se "procesa" enviándolo a ffmpeg, redis pub->sub y luego un socket al cliente.
// Streams controller exports.renderStreams = async function (req, reply) { const streams = await Stream.find({}).sort({ createdAt: -1 })//.limit(5) const renderedStreams = renderStreams(this, streams); return { success: true, streams: streams.length }; } // renderStreams const renderStreams = (fastify, streams = []) => { const { redis } = fastify; const channel = "streams"; for (let i = 0; i < streams.length; i++) { setTimeout(async () => { const stream = streams[i]; await renderStream(redis, channel, stream); }, i * 200) } } Me pregunto en este ciclo for, ¿cómo puedo "pausarlo" o detenerlo por completo (o ambos) a través de otra solicitud, tal vez cuando llamo a /api/streams/stop .
¿Cómo podría ser esto posible?
Puede usar socket.io para comunicarse con su secuencia de comandos mientras aún se está ejecutando, por lo que crearía una función para detener el ciclo y cuando reciba la notificación de socket.io, la ejecutará. Enlace de documentación: https://socket.io/docs/v4/