Generación de IA Asíncrona Usando un Bucle de Sondeo (Polling) con Replicate - Flujo de trabajo de n8n

Desarrolladores e Integradores de IA: Usuarios que necesitan incorporar modelos de IA asíncronos y de larga ejecución (como los alojados en Replicate) en sus procesos de negocio estándar.
Usuarios avanzados de n8n: Personas que buscan ejemplos avanzados del uso del nodo Code de n8n y estructuras de control de flujo (If y Wait) para gestionar APIs externas.
Especialistas en Automatización de Contenidos: Cualquiera que busque plantillas fiables de n8n para generar contenido creativo basado en indicaciones (prompts).
Automatizadores Técnicos: Usuarios que necesitan un mecanismo de activación (trigger) robusto en n8n para iniciar trabajos de cómputo complejos.

Generar contenido complejo a menudo requiere ejecutar trabajos de forma asíncrona, lo que significa que la solicitud inicial devuelve un estado inmediatamente, pero el resultado final se retrasa. Este robusto flujo de trabajo de n8n soluciona esto implementando una secuencia de sondeo (polling) personalizada y no bloqueante adaptada para la API de Replicate.

A diferencia de las integraciones más sencillas, esta plantilla de n8n garantiza la fiabilidad iniciando la predicción, extrayendo el ID del trabajo y luego comprobando continuamente el estado cada dos segundos hasta que el trabajo se complete con éxito. El uso del nodo httpRequest de n8n, combinado con la manipulación de datos en el nodo Code de n8n, proporciona un marco potente y reutilizable para integrar cualquier servicio asíncrono en tu entorno n8n. Esta estructura es esencial para construir automatizaciones de misión crítica usando n8n.

Este potente flujo de trabajo de n8n comienza con un disparador (trigger) manual de n8n:

1. Inicialización: El flujo de trabajo se ejecuta manualmente a través del disparador de n8n 'On clicking 'execute'' (Al hacer clic en 'ejecutar'). Inmediatamente después, el nodo 'Set API Key' de n8n inyecta de forma segura tu clave API de Replicate como variable para las solicitudes HTTP subsiguientes.


2. Iniciar Predicción: El nodo 'Create Prediction' de n8n (una Solicitud HTTP) envía una solicitud POST a Replicate, especificando la versión del modelo y la indicación (prompt) de entrada requerida. Esto pone en marcha el trabajo de IA asíncrono.


3. Extracción: La respuesta de la solicitud de creación contiene el ID del trabajo. El nodo Code de n8n 'Extract Prediction ID' analiza esta respuesta, almacenando el ID de predicción y la URL necesaria para el sondeo.


4. Entrada al Bucle de Sondeo: La ejecución entra en el bucle de sondeo. Primero llega al nodo 'Wait' de n8n, pausando todo el flujo de trabajo de n8n durante 2 segundos para evitar llamadas excesivas a la API.


5. Comprobación de Estado: El nodo httpRequest de n8n 'Check Prediction Status' consulta entonces la URL de predicción extraída previamente para obtener el estado actual del trabajo de IA.


6. Comprobación Condicional: El nodo If de n8n 'Check If Complete' evalúa el estado. Si el estado es igual a 'succeeded' (rama Verdadera), el trabajo ha finalizado y el flujo de trabajo de n8n procede a procesar el resultado. Si el estado es cualquier otra cosa (rama Falsa), la conexión vuelve al nodo 'Wait' de n8n, reiniciando el proceso de sondeo hasta su finalización.


7. Procesamiento del Resultado: Una vez exitoso, el nodo Code de n8n 'Process Result' extrae el contenido generado final (a menudo una URL del recurso) y lo formatea pulcramente para su uso posterior en tu flujo de trabajo de n8n.

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.


2. Configuración de la Clave API (Replicate): Localiza el nodo de n8n 'Set API Key'.

1. Configurar Entrada del Modelo: Localiza el nodo 'Create Prediction' de n8n. Dentro de su configuración del Cuerpo JSON, modifica el valor de prompt y cualquier otro parámetro de entrada (como width, height, etc.) para que coincida con tus requisitos de generación deseados. Asegúrate de que la versión del modelo en el cuerpo JSON sea la correcta.


2. Ejecución: Ejecuta el flujo de trabajo de n8n manualmente usando el botón 'Execute Workflow' en el nodo disparador 'On clicking 'execute'' de n8n para probar la integración y el bucle de sondeo.

On clicking 'execute' (Disparador Manual): Sirve como el disparador inicial de n8n para todo el flujo de trabajo, permitiendo la ejecución manual para pruebas y configuración.
Set API Key (Set): Un nodo crítico de n8n utilizado para definir de forma segura la clave API de Replicate, haciéndola accesible como una expresión ($($Set API Key).item.json.replicateapikey) en el resto del flujo de trabajo de n8n.
Create Prediction (HTTP Request): Envía la solicitud POST asíncrona inicial a la API de Replicate, iniciando el trabajo de generación de IA. Incluye encabezados personalizados para la autorización usando la clave API definida anteriormente.
Extract Prediction ID (Code): Un nodo Code personalizado de n8n crucial para leer la respuesta de la solicitud de predicción inicial. Extrae el predictionId único y construye la URL de sondeo necesaria para las solicitudes subsiguientes en el flujo de trabajo de n8n.
Wait (Wait): Gestiona el control de flujo pausando el flujo de trabajo de n8n durante una duración establecida (2 segundos), evitando solicitudes API rápidas durante el bucle de sondeo.
Check Prediction Status (HTTP Request): Realiza una solicitud GET usando la URL de predicción extraída para comprobar el estado del trabajo de IA en ejecución. Este es el paso central de sondeo en esta plantilla de n8n.
Check If Complete (If): Un nodo de control de flujo de n8n que dirige la lógica del flujo de trabajo de n8n. Si el estado es 'succeeded', procede al gestor de resultados; de lo contrario, regresa al nodo 'Wait' de n8n para continuar sondeando.
Process Result (Code): El nodo Code final de n8n que se ejecuta solo tras el éxito. Estructura y extrae la salida finalizada, incluyendo métricas y la URL del recurso generado, limpiando los datos para los siguientes pasos en tu flujo de trabajo de n8n más amplio.