Bucle de sondeo y generación de asistente de IA con Replicate - Flujo de trabajo de n8n

Desarrolladores que necesitan que el procesamiento de IA asíncrono se gestione automáticamente.
Científicos de datos que integran modelos especializados de Replicate (como aihilums/sehatsanjha) en herramientas de producción.
Especialistas en automatización que buscan plantillas reutilizables de n8n para hacer polling de tareas de larga duración.
Usuarios que necesitan una estructura de nodo n8n fiable para la interacción con APIs externas y la comprobación de estado.

Cuando se trata de modelos de IA computacionalmente intensivos, los resultados rara vez son instantáneos. Replicate utiliza un sistema de predicción asíncrono, lo que significa que la solicitud inicial devuelve una ID y debes consultar (hacer polling a) esa ID hasta que el trabajo se complete. Este flujo de trabajo especializado de n8n soluciona por completo esta complejidad. Actúa como un mecanismo de sondeo resistente, asegurando que una vez creada la predicción inicial mediante el nodo HTTP Request de n8n, el proceso se pausa y comprueba continuamente el estado hasta recibir el mensaje de 'succeeded' (completado). Esto elimina la carga manual de gestionar tareas largas y proporciona un flujo de trabajo de n8n potente y autocontenido para integrar capacidades avanzadas de IA. Esta plantilla de flujo de trabajo específica de n8n utiliza el modelo aihilums/sehatsanjha, demostrando una aplicación práctica del control de flujo de lógica central dentro de n8n.

El flujo de trabajo de n8n comienza con un activador manual de n8n.

1. Inicialización: El activador de n8n inicia el proceso, y el primer nodo de n8n (Set API Key) define la clave API de Replicate como una variable de flujo.


2. Iniciar Predicción: Un nodo HTTP Request de n8n envía una solicitud POST a Replicate para iniciar el trabajo de generación de IA, utilizando la clave API almacenada para la autorización.


3. Extraer ID: Un nodo Code de n8n (Extract Prediction ID) captura la ID de Predicción devuelta por Replicate, junto con la URL de sondeo.


4. Esperar: El flujo de trabajo de n8n se pausa durante 2 segundos usando el nodo Wait de n8n para evitar un sondeo agresivo y la limitación de peticiones (rate limiting).


5. Comprobar Estado: Otro nodo HTTP Request de n8n (Check Prediction Status) utiliza la URL de predicción extraída para consultar a Replicate sobre el estado actual del trabajo.


6. Control del Bucle: Un nodo IF de n8n (Check If Complete) comprueba si el estado es 'succeeded' (completado). Si la predicción no se ha completado, el flujo de trabajo de n8n vuelve al nodo Wait de n8n, repitiendo el ciclo de sondeo.


7. Finalizar: Si el estado de la predicción es 'succeeded', el flujo de trabajo de n8n sale del bucle y pasa la salida final al nodo Code de n8n Process Result para obtener una salida de datos estructurada.

Para utilizar esta plantilla de flujo de trabajo de n8n, sigue estos pasos:

1. Importar: Copia el código JSON proporcionado e impórtalo directamente en tu instancia de n8n a través del menú 'New' (Templates o Import from JSON).


2. Configuración de la Clave API: Localiza el nodo de n8n Set API Key. Reemplaza el valor marcador de posición YOURREPLICATEAPI_KEY con tu clave API real de Replicate.


3. Configuración del Modelo (Opcional): Revisa el nodo HTTP Request de n8n Create Prediction. El cuerpo JSON define la versión del modelo (actualmente 8d601ed5dfe3c91d7dacdc17a127497519acfdb4c4eefbec3db17b6d87734a69). Ajusta los parámetros version e input si deseas utilizar un modelo de Replicate diferente o entradas específicas.


4. Ejecución: Dado que este flujo de trabajo de n8n comienza con un activador manual de n8n, simplemente haz clic en el botón 'Execute Workflow' para ejecutar tu automatización.

Este flujo de trabajo de n8n se basa en varios tipos de nodos centrales de n8n para gestionar las llamadas a la API asíncronas:

Al hacer clic en 'execute' (Activador Manual): Sirve como el activador inicial de n8n, permitiendo al usuario iniciar el flujo de trabajo de n8n bajo demanda.
Set API Key (nodo Set de n8n): Esencial para una configuración segura. Almacena la clave API de Replicate como un elemento, que luego es referenciado dinámicamente por las llamadas subsiguientes del nodo HTTP Request de n8n.
Create Prediction (nodo HTTP Request de n8n):
Función: Inicia el proceso de generación de IA accediendo al endpoint /v1/predictions de Replicate.
Configuración Clave: Utiliza el Tipo de Credencial Genérico para establecer dinámicamente la cabecera Authorization mediante una expresión: ={{ 'Bearer ' + $('Set API Key').item.json.replicateapikey }}.
Extract Prediction ID (nodo Code de n8n):
Función: Analiza el cuerpo de respuesta inicial para extraer la ID de predicción única y construye la URL de sondeo necesaria (predictionUrl). Estos datos son cruciales para el bucle de sondeo continuo gestionado por otros nodos de n8n.
Wait (nodo Wait de n8n):
Función: Implementa una demora de 2 segundos entre intentos de sondeo para gestionar el uso de recursos y cumplir con las mejores prácticas de la API. Esto asegura que el flujo de trabajo de n8n sea eficiente.
Check Prediction Status (nodo HTTP Request de n8n):
Función: Realiza un sondeo a la URL de predicción específica para recuperar el estado actual del trabajo de IA.
Check If Complete (nodo IF de n8n):
Función: Controla la lógica del flujo. Comprueba si $json.status es igual a succeeded. Si es verdadero, el flujo de trabajo de n8n continúa; de lo contrario, vuelve al nodo Wait de n8n.
Process Result (nodo Code de n8n):
* Función: Una vez que el trabajo se completa con éxito, este nodo final de n8n estructura la salida, extrayendo métricas clave, la URL de salida final y metadatos para un fácil consumo por parte de sistemas posteriores.