Replicate AI画像生成のポーリングループ - n8n ワークフロー

• 処理に時間を要する生成AIタスク（画像や動画作成など）の自動化が必要なユーザー。


• Replicateのようなサードパーティの非同期APIをn8nワークフローに統合する開発者。


• 高度な制御フローとポーリングロジックを示す堅牢なn8nテンプレートを探している方。


• ligua033/lorealcantaraモデルを利用するコンテンツクリエイター。

Replicateを含む多くの生成AIサービスは非同期で動作します。リソース（画像など）をリクエストすると、APIは最終的な出力ではなく、予測IDを即座に返します。課題となるのは、そのIDがタスク完了まで継続的にチェックされること、つまりポーリングというプロセスです。

この専門的なn8nワークフローは、厳密なポーリングループを実装することでこの問題を解決します。生成リクエストを初期化し、一意の予測IDを取得した後、n8nのWaitノードとIfノードを組み合わせてステータスURLを繰り返しチェックします。これにより、n8nの自動化が効率的に待機し、結果が準備でき次第処理が進行するため、複雑なAI統合において信頼性の高いn8nテンプレートとなります。

このn8nワークフローは、非同期API呼び出しを管理するために設計された構造化されたシーケンスを通じて動作します:

1. 開始とセットアップ: ワークフローは主要なn8nトリガーとして機能する手動トリガーで開始されます。直後に、「APIキーの設定 (Set API Key)」n8nノードが、その後のHTTPリクエストに必要な replicateapikey を設定します。


2. 生成の開始: 「予測の作成 (Create Prediction)」HTTPリクエストn8nノードが、指定された ligua033/lorealcantara モデルと入力パラメーターを使用してコンテンツ生成を開始するため、Replicate APIにPOSTリクエストを送信します。


3. IDの抽出: 「予測IDの抽出 (Extract Prediction ID)」Code n8nノードが初期応答を処理し、重要な予測IDを抽出し、ステータス確認用のURLを構築します。


4. ポーリングループへの突入: n8nワークフローは、「Wait (待機)」n8nノードから始まるポーリングシーケンスに入ります。これはAPIへのリクエスト過多を防ぐため、実行を2秒間一時停止します。


5. ステータスの確認: 「予測ステータスの確認 (Check Prediction Status)」HTTPリクエストn8nノードが、予測URLに対してGETリクエストを実行し、現在のステータス（例: 'processing'、'succeeded'、'failed'）を取得します。


6. 条件判定: 「完了の確認 (Check If Complete)」n8n Ifノードが返されたステータスを評価します。ステータスが 'succeeded'（True分岐）の場合、ワークフローは出力を処理するために進みます。ステータスがそれ以外の場合（False分岐）、n8nテンプレートは「Wait (待機)」ノードにループバックし、完了するまで2秒の遅延とステータスチェックを再開します。


7. 最終出力: ステータスが 'succeeded' になったら、「結果の処理 (Process Result)」Code n8nノードが、生成されたコンテンツURL（Replicateからの出力配列）を含む最終結果を整形して出力します。

この強力なn8nワークフローをデプロイするには、以下の手順に従ってください:

1. インポート: JSONデータをコピーし、「新規 (New)」→「JSONからインポート (Import from JSON)」機能を使用して、お使いのn8nインスタンスに貼り付けます。


2. API認証情報: 「APIキーの設定 (Set API Key)」n8nノードを見つけます。replicateapikey の値を実際のReplicate APIキーに更新してください。このキーは、その後のすべてHTTPリクエストn8nノードでBearerトークン認証のために動的に使用されます。


3. 入力設定: 「予測の作成 (Create Prediction)」n8nノードで、jsonBody パラメーター（prompt、seed、width、height、lora_scale）を確認し、希望するコンテンツ仕様に合わせて変更します。


4. 有効化: n8nワークフローがアクティブになっていることを確認し、テストのために「実行をクリック時 (On clicking 'execute')」n8nトリガーを使用して実行します。

実行をクリック時 (On clicking 'execute') (手動トリガー)

• 機能: 即時のテストとn8nワークフローの実行のための開始n8nトリガーとして機能します。


• 主な設定: なし（標準の手動実行）。

APIキーの設定 (Set API Key) (Set)

• 機能: replicateapikey 変数を安全に定義し、様々なn8nノードでBearerトークンとしてアクセスできるようにします。


• 主な設定: replicateapikey の割り当てを定義します。

予測の作成 (Create Prediction) (HTTP Request)

• 機能: ligua033/lorealcantara モデルのReplicate APIエンドポイントに対し、初期の非同期生成リクエストを送信します。


• 主な設定: メソッド POST、URL https://api.replicate.com/v1/predictions、動的に取得したAPIキーを使用した認証（Generic HTTP Header）、入力プロンプトとモデル設定を定義する jsonBody。

予測IDの抽出 (Extract Prediction ID) (Code)

• 機能: 予測作成ステップからのJSON応答を解析し、一意の predictionId を分離し、ポーリングに必要な predictionUrl を構築します。


• 主な設定: カスタムJavaScriptを使用して predictionId、status、および predictionUrl を返します。

待機 (Wait) (Wait)

• 機能: n8nワークフローの実行を2秒間一時停止します。この一時停止は、APIリクエストの頻度を管理するためにポーリングループで要求される遅延を実装するために不可欠です。


• 主な設定: 量: 2、単位: seconds（秒）。

予測ステータスの確認 (Check Prediction Status) (HTTP Request)

• 機能: 抽出された predictionUrl を使用してGETリクエストを実行し、AI生成が完了したかどうかを確認します。


• 主な設定: URLは ={{ $json.predictionUrl }} を使用して動的に設定され、APIキーで認証されます。

完了の確認 (Check If Complete) (If)

• 機能: ポーリングループの流れを制御します。前のHTTPリクエストn8nノードから返されたステータスが 'succeeded' と等しいかどうかをチェックします。


• 主な設定: 条件: $json.status が succeeded と等しい。偽の場合、実行をWaitノードに戻します。

結果の処理 (Process Result) (Code)

• 機能: 正常に完了した際に実行され、生成された画像URLや処理メトリクスを含む最終出力をクリーンアップおよび構造化し、n8nワークフローを完了させます。