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

AI開発者およびインテグレーター: Replicateなどでホストされている時間のかかる非同期AIモデルを、標準的な業務プロセスに組み込む必要があるユーザー。
n8nパワーユーザー: Code n8nノードやフロー制御構造 (IfやWait) を使用して外部APIを処理する高度な例を探している個人。
コンテンツ自動化スペシャリスト: プロンプトに基づいたクリエイティブなコンテンツ生成のための、信頼性の高いn8nテンプレートを探している人。
技術系自動化担当者: 複雑な計算ジョブを開始するための、堅牢なn8nトリガー機構を必要とするユーザー。

複雑なコンテンツの生成では、ジョブを非同期で実行する必要があることがよくあります。つまり、最初のリクエストですぐにステータスが返されますが、最終的な出力は遅延します。この堅牢なn8nワークフローは、Replicate APIに合わせたカスタムのノンブロッキングポーリングシーケンスを実装することで、この問題を解決します。

より単純なインテグレーションとは異なり、このn8nテンプレートは、予測の開始、ジョブIDの抽出、そしてその後2秒ごとにステータスを継続的に確認することで信頼性を確保します。httpRequest n8nノードの使用と、Code n8nノードでのデータ操作を組み合わせることで、あらゆる非同期サービスをn8n環境に統合するための強力で再利用可能なフレームワークを提供します。この構造は、n8nを使用してミッションクリティカルな自動化を構築するために不可欠です。

この強力なn8nワークフローは、n8nの手動トリガーから開始されます:

1. 初期化: ワークフローは、「実行をクリックしたとき」のn8nトリガー経由で手動実行されます。直後に、「APIキーの設定」n8nノードがReplicate APIキーを次のHTTPリクエストのために変数として安全に注入します。


2. 予測の開始: 「予測の作成」n8nノード（HTTPリクエスト）は、モデルバージョンと必要な入力プロンプトを指定して、ReplicateにPOSTリクエストを送信します。これにより、非同期AIジョブが開始されます。


3. 抽出: 作成リクエストのレスポンスにはジョブIDが含まれています。「予測IDの抽出」Code n8nノードがこのレスポンスを解析し、ポーリングに必要な予測IDとURLを保存します。


4. ポーリングループへの入口: 実行はポーリングループに入ります。まず「待機」n8nノードに到達し、過剰なAPI呼び出しを避けるためにn8nワークフロー全体を2秒間一時停止します。


5. ステータス確認: 「予測ステータスの確認」httpRequest n8nノードは、抽出した予測URLに対してクエリを実行し、実行中のAIジョブの現在のステータスを取得します。


6. 条件確認: 「完了確認」If n8nノードがステータスを評価します。ステータスが「succeeded」と等しい場合（Trueブランチ）、ジョブは完了し、n8nワークフローは結果の処理に進みます。ステータスがそれ以外の場合（Falseブランチ）、接続は「待機」n8nノードにループバックし、完了するまでポーリングプロセスを再開します。


7. 結果の処理: 成功すると、「結果の処理」Code n8nノードが最終的に生成されたコンテンツ（多くの場合アセットへのURL）を抽出し、n8nワークフローでの後続の使用のためにきれいに整形します。

このn8nワークフローテンプレートを使用するには、次の手順に従ってください:

1. インポート: 提供されたJSONコードをコピーし、お使いのn8nインスタンスに直接インポートします。


2. APIキーの設定（Replicate）: 「APIキーの設定」n8nノードを見つけます。

1. モデル入力の設定: 「予測の作成」n8nノードを見つけます。そのJSONボディ設定内で、promptの値やその他の入力パラメーター（width、heightなど）を希望する生成要件に合わせて変更します。JSONボディ内のモデルバージョンが正しいことを確認してください。


2. 実行: 「実行をクリックしたとき」のn8nトリガーノードにある「ワークフローの実行」ボタンを使用してn8nワークフローを手動で実行し、インテグレーションとポーリングループをテストします。

「実行をクリックしたとき」（手動トリガー）: n8nワークフロー全体の開始トリガーとして機能し、テストと設定のために手動実行を可能にします。
APIキーの設定 (Set): Replicate APIキーを安全に定義するために使用される重要なn8nノード。これにより、n8nワークフローの残りの部分で式 ($($Set API Key).item.json.replicateapikey) としてアクセス可能になります。
予測の作成 (HTTP Request): 非同期POSTリクエストをReplicate APIに送信し、AI生成ジョブを開始します。これには、上記で定義したAPIキーを使用した認証のためのカスタムヘッダーが含まれます。
予測IDの抽出 (Code): 最初の予測リクエストのレスポンスを読み取るために極めて重要なカスタムCode n8nノードです。一意のpredictionIdを抽出し、n8nワークフロー内の後続リクエストのために必要なポーリングURLを構築します。
待機 (Wait): 設定された期間（2秒）n8nワークフローを一時停止することでフロー制御を管理し、ポーリングループ中のAPIリクエストの連打を防ぎます。
予測ステータスの確認 (HTTP Request): 抽出した予測URLを使用してGETリクエストを実行し、実行中のAIジョブのステータスを確認します。これがこのn8nテンプレートの中核となるポーリング手順です。
完了確認 (If): n8nワークフローのロジックを指示するフロー制御n8nノードです。ステータスが「succeeded」であれば結果ハンドラに進み、そうでなければ「待機」n8nノードに戻りポーリングを続行します。
結果の処理 (Code): 成功した場合にのみ実行される最終的なCode n8nノードです。最終的な出力（生成されたアセットのURLを含む）を構造化して抽出し、n8nワークフローの次のステップのためにデータをクリーニングします。