Replicate 폴링 루프를 사용한 비동기 AI 생성 - n8n 워크플로우

AI 개발자 및 통합자: Replicate와 같이 장기 실행되는 비동기 AI 모델을 표준 비즈니스 프로세스에 통합해야 하는 사용자.
n8n 파워 유저: Code n8n 노드와 흐름 제어 구조(If, Wait)를 사용하여 외부 API를 처리하는 고급 예시를 찾는 사용자.
콘텐츠 자동화 전문가: 프롬프트를 기반으로 창의적인 콘텐츠를 생성하기 위한 안정적인 n8n 템플릿을 찾는 모든 사람.
기술 자동화 사용자: 복잡한 컴퓨팅 작업을 시작하기 위해 강력한 n8n 트리거 메커니즘이 필요한 사용자.

복잡한 콘텐츠를 생성하려면 종종 작업을 비동기적으로 실행해야 합니다. 즉, 초기 요청은 즉시 상태를 반환하지만 최종 출력은 지연됩니다. 이 강력한 n8n 워크플로우는 Replicate API에 맞게 조정된 맞춤형 비차단(non-blocking) 폴링 시퀀스를 구현하여 이 문제를 해결합니다.

간단한 통합과 달리, 이 n8n 템플릿은 예측(prediction)을 시작하고, 작업 ID를 추출한 다음, 작업이 성공할 때까지 2초마다 지속적으로 상태를 확인하여 안정성을 보장합니다. httpRequest n8n 노드의 사용과 Code n8n 노드 내의 데이터 조작을 결합하여 모든 비동기 서비스를 n8n 환경에 통합하기 위한 강력하고 재사용 가능한 프레임워크를 제공합니다. 이 구조는 n8n을 사용하여 미션 크리티컬한 자동화를 구축하는 데 필수적입니다.

이 강력한 n8n 워크플로우는 수동 n8n 트리거로 시작됩니다:

1. 초기화: 워크플로우는 'On clicking 'execute'' n8n 트리거를 통해 수동으로 실행됩니다. 직후에 'Set API Key' n8n 노드가 후속 HTTP 요청을 위해 Replicate API 키를 변수로 안전하게 주입합니다.


2. 예측 시작: 'Create Prediction' n8n 노드(HTTP 요청)는 모델 버전과 필요한 입력 프롬프트를 지정하여 Replicate에 POST 요청을 보냅니다. 이로써 비동기 AI 작업이 시작됩니다.


3. 추출: 생성 요청의 응답에 작업 ID가 포함됩니다. 'Extract Prediction ID' Code n8n 노드는 이 응답을 구문 분석하여 예측 ID와 폴링에 필요한 URL을 저장합니다.


4. 폴링 루프 진입: 실행이 폴링 루프에 들어갑니다. 먼저 'Wait' n8n 노드를 거치며 과도한 API 호출을 피하기 위해 전체 n8n 워크플로우를 2초 동안 일시 중지합니다.


5. 상태 확인: 'Check Prediction Status' httpRequest n8n 노드는 이전에 추출된 예측 URL을 쿼리하여 AI 작업의 현재 상태를 검색합니다.


6. 조건부 확인: 'Check If Complete' If n8n 노드는 상태를 평가합니다. 상태가 'succeeded'와 같으면(True 분기), 작업이 완료되어 n8n 워크플로우는 결과를 처리하기 위해 진행됩니다. 상태가 다른 경우(False 분기)에는 연결이 'Wait' n8n 노드로 루프백되어 완료될 때까지 폴링 프로세스를 재개합니다.


7. 결과 처리: 성공하면 'Process Result' Code n8n 노드가 최종 생성된 콘텐츠(종종 에셋 URL)를 추출하고 n8n 워크플로우의 후속 단계에서 사용하기 좋게 깔끔하게 형식을 지정합니다.

이 n8n 워크플로우 템플릿을 사용하려면 다음 단계를 따르십시오:

1. 가져오기: 제공된 JSON 코드를 복사하여 n8n 인스턴스에 직접 가져옵니다.


2. API 키 설정 (Replicate): 'Set API Key' n8n 노드를 찾습니다.

1. 모델 입력 구성: 'Create Prediction' n8n 노드를 찾습니다. JSON 본문 구성 내에서 prompt 값 및 기타 입력 매개변수(예: width, height 등)를 원하는 생성 요구 사항에 맞게 수정합니다. JSON 본문의 모델 버전이 올바른지 확인합니다.


2. 실행: 'On clicking 'execute'' n8n 트리거 노드에서 'Execute Workflow' 버튼을 사용하여 n8n 워크플로우를 수동으로 실행하여 통합 및 폴링 루프를 테스트합니다.

On clicking 'execute' (수동 트리거): 전체 n8n 워크플로우의 시작 트리거 역할을 하며 테스트 및 구성을 위해 수동 실행을 허용합니다.
Set API Key (Set): Replicate API 키를 안전하게 정의하는 데 사용되는 중요한 n8n 노드로, n8n 워크플로우의 나머지 부분에서 표현식($($Set API Key).item.json.replicateapikey)으로 접근할 수 있게 합니다.
Create Prediction (HTTP 요청): 초기 비동기 POST 요청을 Replicate API에 보내 AI 생성 작업을 시작합니다. 이전에 정의된 API 키를 사용하여 권한 부여를 위한 사용자 지정 헤더가 포함됩니다.
Extract Prediction ID (Code): 초기 예측 요청의 응답을 읽는 데 중요한 맞춤형 Code n8n 노드입니다. 고유한 predictionId를 추출하고 후속 요청에 필요한 폴링 URL을 구성합니다.
Wait (Wait): 설정된 기간(2초) 동안 n8n 워크플로우를 일시 중지하여 흐름을 제어하며, 폴링 루프 동안 너무 빠른 API 호출을 방지합니다.
Check Prediction Status (HTTP 요청): 추출된 예측 URL을 사용하여 GET 요청을 수행하여 실행 중인 AI 작업의 상태를 확인합니다. 이것이 이 n8n 템플릿의 핵심 폴링 단계입니다.
Check If Complete (If): n8n 워크플로우 로직을 지시하는 흐름 제어 n8n 노드입니다. 상태가 'succeeded'이면 결과 처리기로 진행하고, 그렇지 않으면 'Wait' n8n 노드로 돌아가 폴링을 계속합니다.
Process Result (Code): 성공했을 때만 실행되는 최종 Code n8n 노드입니다. 최종 출력(메트릭 및 생성된 에셋 URL 포함)을 구조화하고 추출하여 n8n 워크플로우의 다음 단계를 위해 데이터를 정리합니다.