Replicateのポーリングループを使用した非同期AI画像生成 - n8n ワークフロー

結果が即座に返却されない非同期AIタスクの自動化を必要とするユーザー
Replicateのような長時間実行されるAPIサービスを統合するための、信頼性の高いn8nテンプレートを探している開発者
コンテンツ生成にAIモデル（特にcreativeathive/lemaar-door-mockedupモデル）を活用するテクニカルマーケターやデザイナー
コアとなるロジックフロー制御を示す専門的なn8nワークフロー例を探しているすべての人

複雑なAI画像の生成には時間がかかることが多く、最初のAPIリクエストでは最終的な出力ではなく予測IDしか返されません。そのため、ジョブが完了するまでサービスに対して繰り返し「ポーリング（問い合わせ）」を行う必要があります。この専用n8nワークフローは、堅牢で自己修正機能のあるポーリングループを実装することにより、この課題を解決します。

このオートメーションはn8nトリガーで開始され、Replicateでジョブを初期化し、その後「待機(Wait)」ノードと「条件分岐(If)」ノードを使用してループに入ります。このループにより、ワークフローは一時停止（Waitノード）し、ステータスを確認し（HTTPリクエストn8nノード）、生成が「succeeded（成功）」した場合にのみ処理を続行します。この強力なロジックにより、このn8nテンプレートは外部の非同期タスクを処理する上で非常に信頼性が高く、高度なn8nオートメーションにおける重要なパターンとなります。

このn8nワークフローは、非同期APIインタラクション専用に設計された構造化されたシーケンスを通じて実行されます。

1. 手動開始: ワークフローは「Execute（実行）ボタンクリック時(On clicking 'execute')」のn8nトリガーで開始され、手動テストと実行を可能にします。


2. APIキーの設定: 「APIキーの設定(Set API Key)」n8nノードが、必要なReplicate APIキーを初期化し、後続ステップの安全な認証を確保します。


3. 予測の作成: HTTPリクエストn8nノードがPOSTリクエストをReplicate APIに送信し、指定されたモデル（creativeathive/lemaar-door-mockedup）と入力パラメータ（プロンプト、シードなど）を使用してAI生成を開始します。


4. IDの抽出: 「予測IDの抽出(Extract Prediction ID)」n8nノードがAPIレスポンスを即座に処理し、ポーリングに必要な一意の予測IDを抽出し、ステータスチェック用のエンドポイントURLを構築します。


5. ポーリングの開始: ワークフローは「待機(Wait)」n8nノードに進み、ポーリングサイクル中にAPIに負荷をかけすぎないように実行を2秒間一時停止します。


6. ステータスの確認: 「予測ステータスの確認(Check Prediction Status)」HTTPリクエストn8nノードが、抽出したURLとAPIキーを使用して、AI生成ジョブのステータスを照会します。


7. ループ制御: 「完了確認(Check If Complete)」If n8nノードがステータスを分析します。ステータスが「succeeded」の場合、ワークフローは結果の処理に進みます。ステータスがそれ以外（例：「processing（処理中）」、「starting（開始中）」）の場合、ワークフローは「待機(Wait)」ノードにループバックし、2秒間の待機とそれに続くステータスチェックを再開します。このポーリングロジックがn8nワークフローの核となる機能です。


8. 結果の処理: ジョブが完了すると、「結果の処理(Process Result)」n8nノードが、生成された画像のURL、完了メトリクス、その他の関連メタデータを含む最終的な出力データを抽出します。

この包括的なn8nワークフローをデプロイするには、次の手順に従ってください。

1. n8nワークフローのインポート: 提供されているJSONコードをコピーし、「ワークフロー(Workflows)」セクションの「JSONからインポート(Import from JSON)」ボタンを使用して、n8nインスタンスに直接インポートします。


2. Replicate認証情報の設定: Replicate APIキーが必要です。このキーはReplicateアカウント設定から取得してください。


3. APIキーノードの設定: インポートしたワークフロー内の「APIキーの設定(Set API Key)」n8nノードを見つけます。replicateapikeyの割り当て設定で、プレースホルダー値YOURREPLICATEAPI_KEYを実際のReplicate APIキーに置き換えます。


4. 入力プロンプトの設定: 「予測の作成(Create Prediction)」n8nノードを見つけます。JSONボディを編集して、目的のprompt値を設定し、必要に応じてモデルに合わせてseed、width、heightなどの入力を調整します。


5. 有効化とテスト: n8nワークフローを有効化し、「ワークフロー実行(Execute Workflow)」ボタンをクリックして、完全な非同期ポーリングシーケンスをテストします。

このn8nワークフローは、その複雑なロジックを管理するためにいくつかの主要なn8nノードタイプを活用しています。

実行ボタンクリック時 (On clicking 'execute') (手動トリガーn8nトリガー): この特定n8nワークフローテンプレートの開始点であり、プロセスの手動開始を可能にします。
APIキーの設定 (Set API Key) (Set n8nノード): 必要なReplicate APIキーをワークフローのデータストリームに安全に挿入するために使用され、後続のHTTPリクエストの認証を可能にします。
予測の作成 (Create Prediction) (HTTP Request n8nノード): 非同期の画像生成ジョブを開始するためにReplicate APIを呼び出す役割を担います。入力プロンプトとモデル設定を送信します。
予測IDの抽出 (Extract Prediction ID) (Code n8nノード): ポーリングプロセスに必要な一意のIDを抽出し、ステータスチェックのエンドポイントURLを生成する、重要なカスタムコードn8nノードです。
待機 (Wait) (Wait n8nノード): ポーリングループ内で必要な時間遅延（2秒）を実装し、ワークフローが外部APIを過度に呼び出すのを防ぎ、処理のための時間を確保します。
予測ステータスの確認 (Check Prediction Status) (HTTP Request n8nノード): ポーリングメカニズムの核となります。このn8nノードは、予測IDに基づいてReplicateサービスのステータスを繰り返し照会します。
完了確認 (Check If Complete) (If n8nノード): n8nワークフローのフロー制御を提供します。ステータスが「succeeded」と等しいかを確認します。真（True）の場合、ワークフローはループを終了します。偽（False）の場合、Waitノードにルーティングし直されます。
結果の処理 (Process Result) (Code n8nノード): 完了時に実行され、最終的な画像出力URLとメタデータを後続の使用のために整形・提示します。