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

• Ilearnmate ICTSのような特定のカスタムAI/MLモデルをバックエンドプロセスに統合する必要があるユーザー。


• 非同期APIジョブとポーリングを処理するn8nワークフローを必要とする開発者。


• If n8nノードおよびWait n8nノードを使用した高度なフロー制御の例を探しているオートメーションスペシャリスト。

高度なAI出力を生成するプロセスは非同期処理を伴うことが多く、初期リクエストですぐにジョブIDが返され、最終結果は後でポーリング（問い合わせ）する必要があります。この特定のn8nワークフローは、ReplicateのAIサービスを利用する際に、この技術的に難しい要件を処理するための完全なソリューションを提供します。

この堅牢なn8nテンプレートは、spuuntries/ilearnmate-ictsモデルの予測を開始し、その後、制御されたポーリングループに入ります。AI生成ジョブが真に完了したときにのみオートメーションが進行することを保証し、タイムアウトを防ぎ効率を最大化します。これは、信頼性の高いAI統合を実現するための極めて重要なn8nワークフローパターンです。

この複雑なn8nワークフローは、セットアップ、実行初期化、非同期ポーリングの3つの主要なステージで動作します。

1. トリガーとセットアップ: プロセスは「'execute'をクリックしたとき (On clicking 'execute')」のn8nトリガーから始まります。続く「APIキーの設定 (Set API Key)」n8nノードがReplicate APIキーを安全に設定します。


2. 予測の初期化: 「予測の作成 (Create Prediction)」HTTPリクエストn8nノードがReplicate APIにPOSTリクエストを送信し、指定されたモデルバージョンを使用してAIジョブを開始します。このアクションにより、予測IDと初期ステータス（通常は'starting'または'processing'）が即座に返されます。


3. IDの抽出とポーリングの開始: 「予測IDの抽出 (Extract Prediction ID)」コードn8nノードが固有の予測IDを取得し、ジョブステータスを確認するために必要なポーリングURLを構築します。


4. 待機と確認: ワークフローはポーリングループに入り、「待機 (Wait)」n8nノードから始まり、実行を2秒間一時停止します。その後、「予測ステータスの確認 (Check Prediction Status)」HTTPリクエストn8nノードが、抽出したURLとAPIキーを使用してジョブの現在のステータスを取得します。


5. フロー制御ロジック: 「完了確認 (Check If Complete)」If n8nノードがステータスを検査します。ステータスが 'succeeded'（真のブランチ）の場合、ワークフローは出力を処理するために進みます。ステータスがそれ以外の場合（偽のブランチ）、n8nワークフローは「待機 (Wait)」n8nノードにループバックし、2秒の遅延とステータスチェックを再開します。このループはジョブが完了するまで続行されます。


6. 結果の処理: 'succeeded'になると、「結果の処理 (Process Result)」コードn8nノードが最終的なAI出力、生成メトリクス、メタデータを抽出し、この強力なn8nテンプレートの実行を完了します。

このn8nワークフローを使用するには、次の手順に従ってください。

1. n8nテンプレートのインポート: 提供されたJSONコードをコピーし、n8nインスタンスの「新規 (New)」メニュー（JSONからインポート）経由でインポートします。


2. APIクレデンシャルの設定: 「APIキーの設定 (Set API Key)」n8nノードを見つけます。

1. モデル入力の更新（オプション）: 「予測の作成 (Create Prediction)」HTTPリクエストn8nノードを確認します。Ilearnmate ICTSモデルに対して異なる入力を要求する場合、JSONボディ内の seed または numexamplesperside パラメータを調整しても構いません。


2. 実行: 設定後、「ワークフローの実行 (Execute Workflow)」ボタンを使用してn8nワークフローを実行し、n8nトリガーとポーリングロジックをテストします。

'execute'をクリックしたとき (On clicking 'execute') (手動トリガー n8nトリガー): テストとデプロイのためにn8nワークフロー全体を手動で開始します。
APIキーの設定 (Set API Key) (Set n8nノード): Replicate APIキーを安全に変数値として保存し、後続のHTTPリクエストヘッダーに動的に挿入するために使用されます。
予測の作成 (Create Prediction) (HTTP Request n8nノード): AI生成ジョブを開始するために、Replicateへ初期APIコールを送信します。POSTメソッドで設定され、モデルバージョンと入力パラメータを指定します。
予測IDの抽出 (Extract Prediction ID) (Code n8nノード): 応答を解析し、固有の id を抽出し、後続のポーリングリクエストに必要な特定の予測URLを構成するために使用されるカスタムJavaScript n8nノードです。
待機 (Wait) (Wait n8nノード): ポーリングプロセス中のレートリミットの問題を防ぐため、n8nワークフローの実行を2秒間一時停止する重要な待機時間を実装します。
予測ステータスの確認 (Check Prediction Status) (HTTP Request n8nノード): ポーリングを行うn8nノードです。APIキーで設定された Authorization ヘッダーを使用し、特定の予測URLに対してGETリクエストを送信します。
完了確認 (Check If Complete) (If n8nノード): 中核となる制御フローn8nノードです。ワークフローが結果処理に進むべきか（succeededステータス）、それともポーリングを続行するために「待機 (Wait)」n8nノードにループバックすべきかを判断します。
結果の処理 (Process Result) (Code n8nノード): 最終的なクリーンアップn8nノードです。最終的な成功したAPI応答から重要なフィールド（出力、ステータス、メトリクス）を抽出・整形します。