コアフローの構築

このワークフローは、Airtableから**「Ready」ASINを取得し、ステータスをIn Progressに変更した後、単一のHTTPリクエストでRainforest APIから最新の商品情報を取得します。タスク管理にはAirtable**、自動化にはn8nコアノード（Trigger、Airtable、HTTP Request）、データソースにはRainforest APIを組み合わせて、製品分析フローのためのクリーンで信頼性の高い出発点を構築します。

トリガーとReady ASINの取得

まず、ワークフローのエントリーポイントを作成し、Airtableから1件のReady ASINレコードを取得します。これにより、ワークフローは常に処理対象となる単一かつクリーンなアイテムから開始され、重複や過負荷を防ぎます。

• Triggerを手動で追加

• Airtable → Search Recordsを追加

• Resource: Records

• Operation: Search

• Base/Table: your ASIN queue

次に、Airtableデータをフィルタリングし、ワークフローがReadyとマークされたASINのみを取得するようにします。Filter by formulaフィールドに、次の式を入力します：

{Status} = "Ready"

これにより、n8nは処理待ちのASINを1件だけ選択します。Return allをOff、Max resultsを1に設定し、常に1レコードのみを扱うようにします。その後、ノードを実行して、ASIN、Status、および関連フィールドを含むアイテムが取得できることを確認します。

レコードを「進行中」にマーク

ASINレコードを取得した後、次のステップはそのステータスを更新し、誤って再処理しないようにすることです。これにより、レコードが進行中としてマークされ、現在ワークフローで処理中であることを示します。

• Airtable と レコードの更新を追加

  • Base/Table: 以前と同じ；

  • 一致させるID: Search Recordsの出力（スキーマビュー）からレコードのidをマッピング；

  • 更新するフィールド：

    • Status を 進行中 に設定；
    • 監査やログ記録のためにASINをマッピング。

ノードを実行し、AirtableでレコードのStatusが進行中に変更されたことを確認。

レコードを進行中にマークした後は、Rainforest APIからライブ商品情報を取得します。このステップで、AirtableのASINをAmazonのリアルタイムデータに接続し、後続処理に必要なすべての情報を取得します。

• HTTP Requestノードを追加

• Method: GET

• Response: JSON

• URL: https://api.rainforestapi.com/request

次に、APIが返すデータを定義するためのクエリパラメータを設定します。

ノードを一度実行し、レスポンスにtitle、ASIN、images、price、rating、reviewsなど、すべての期待される商品フィールドが含まれていることを確認。