第3章: 実践！ワークフロー構築 - 自動化を形にする

この章では、実際に n8n を使ってワークフローを構築する手順を、環境構築から具体的な例、デバッグ方法まで含めて解説します。手を動かしながら n8n の使い方をマスターしましょう。

3.1. 導入準備 - 環境構築と初期設定

n8n を使い始めるための最初のステップである、環境構築と基本的なエディタ操作について説明します。

3.1.1. インストール方法 (Docker, npm, etc.)

Self-Hosted 環境で n8n を利用する場合、いくつかのインストール方法があります。Docker を利用する方法が最も一般的で推奨されています。

Docker での基本的な起動例:

# 最新版の n8n イメージを取得  
docker pull n8n.io/n8nio/n8n

# n8n コンテナを起動 (-it はフォアグラウンド実行、-p でポート公開、--name で名前付け、--rm で終了時削除、-v でデータ永続化)  
docker run -it --rm   
  --name n8n   
  -p 5678:5678   
  -v ~/.n8n:/home/node/.n8n   
  n8n.io/n8nio/n8n

• -v ~/.n8n:/home/node/.n8n は、ホストマシンの ~/.n8n ディレクトリをコンテナ内の n8n データディレクトリにマウントし、ワークフローや設定を永続化します。本番環境では必ず設定してください。
• 重要: 本番環境では、必ず N8N_ENCRYPTION_KEY や認証情報 (N8N_BASIC_AUTH_USER, N8N_BASIC_AUTH_PASSWORD) を環境変数で設定してください。Docker Compose を使うと管理が容易です。

3.1.2. n8n Cloud のセットアップ

n8n Cloud を利用する場合は、インストール作業は不要です。

1. 公式サイトへアクセス: n8n の公式サイト (n8n.io) にアクセスします。
2. サインアップ: 「Get Started」や「Sign Up」などのボタンから、アカウント作成画面に進みます。メールアドレスとパスワード、または Google/GitHub アカウントで登録できます。
3. プラン選択: 無料の Starter プランまたは有料プランを選択します。（多くの場合、最初は Starter プランで試せます）
4. ダッシュボードへ: 登録が完了すると、n8n Cloud のダッシュボードにアクセスできるようになります。ここから新しいワークフローを作成できます。

3.1.3. n8n エディタの基本操作

n8n のワークフローは、Web ブラウザ上のエディタ（キャンバス）で作成します。

3.2. 初めてのワークフロー作成 - ステップ・バイ・ステップ

簡単な例を通して、ワークフロー作成の流れを体験してみましょう。

3.2.1. シンプルなWebhookトリガーの例

目的: 外部から特定の URL に JSON データが POST されると、そのデータに含まれる message を Slack に通知する。

手順:

1. 新規ワークフロー作成: n8n エディタで「New」をクリックして新しい空のワークフローを作成します。
2. トリガーノード追加:
   • ノードパネルの検索窓に「Webhook」と入力し、Webhook ノードをキャンバスにドラッグ＆ドロップします。
3. Webhook ノード設定:
   • Webhook ノードをクリックして設定パネルを開きます。
   • 「HTTP Method」が「POST」になっていることを確認します。
   • 「Webhook URLs」に表示されている Test URL をコピーします。（後でテストに使います）
4. Slack ノード追加:
   • ノードパネルで「Slack」を検索し、Slack ノードをキャンバスに追加します。
5. ノード接続: Webhook ノードの右側にある円（出力コネクタ）から、Slack ノードの左側にある円（入力コネクタ）へドラッグして接続します。
6. Slack ノード設定:
   • Slack ノードをクリックして設定パネルを開きます。
   • 認証情報 (Credential): 「Slack Account」のドロップダウンで「Create New」を選択し、画面の指示に従って Slack アカウントとの連携認証を行います。（初回のみ）
   • Resource: 「Message」を選択します。
   • Operation: 「Send」を選択します。
   • Channel: 通知を送りたい Slack チャンネル名を指定します（例: #general や @自分のユーザー名）。
   • Text: ここに通知内容を入力します。Webhook で受け取った message を表示したいので、式 (Expression) を使います。
     • Text 欄の右にある </> アイコンをクリックします。
     • エディタが開くので、 {{ $json.body.message }} と入力します。（Webhook は通常、受け取ったデータを body プロパティに入れます）
     • Add Expression をクリックします。
7. ワークフロー保存: 右上の「Save」ボタンでワークフローに名前を付けて保存します（例: Webhook to Slack）。
8. テスト実行:

   • Webhook ノードの設定パネルにある「Listen For Test Event」ボタンをクリックします。n8n がテスト用のリクエストを待ち受け状態になります。

   • 別のターミナルや API クライアントツール (curl, Postman など) を使って、先ほどコピーした Test URL に対して以下のような JSON データを POST します。
     curl -X POST -H "Content-Type: application/json" -d '{"message": "これはテスト通知です！"}' <ここにTest URLをペースト>

   • n8n エディタに戻ると、Webhook ノードと Slack ノードに緑色のチェックマークが付き、データが流れたことが視覚的に表示されます。指定した Slack チャンネルにも通知が届けば成功です。

9. アクティブ化: テストが成功したら、右上のトグルスイッチを「Active」にしてワークフローを有効化します。これで、Webhook ノードの Production URL に対してリクエストが送られるたびに、Slack 通知が実行されるようになります。

3.2.2. 定期実行タスクの例 (スケジュールトリガー)

目的: 毎日午前9時に、特定の公開 API (例: OpenWeatherMap) から天気情報を取得し、その最高気温を Google Sheets に記録する。

手順:

1. 新規ワークフロー作成: 新しいワークフローを作成します。
2. トリガーノード追加: ノードパネルから「Schedule」ノードをキャンバスに追加します。
3. Schedule ノード設定:
   • 「Trigger Interval」を「Every Day」に設定します。
   • 「Hour」を「9」に設定します。
   • 「Timezone」を自分のタイムゾーン (例: Asia/Tokyo) に設定します。
4. HTTP Request ノード追加: ノードパネルから「HTTP Request」ノードを追加し、Schedule ノードに接続します。
5. HTTP Request ノード設定:
   • URL: 天気情報 API のエンドポイント URL を入力します (例: OpenWeatherMap の URL。API キーが必要な場合はクエリパラメータに含める)。
   • Method: 「GET」を選択します。
   • Options > Send Query Parameters: 必要に応じて都市名などを指定します。
   • Options > Response Format: 「JSON」を選択します。
   • (必要であれば) Authentication: API キーが必要な場合は、適切な認証タイプ (API Key Auth など) を選択し、Credential を作成・設定します。
6. Set ノード追加 (任意だが推奨): HTTP Request ノードの次に「Set」ノードを追加します。これは、API から取得した複雑な JSON データの中から、必要な情報（最高気温）だけを抽出・整形するために使います。
7. Set ノード設定:
   • 「Keep Only Set」を有効にすると、ここで設定した値だけが次のノードに渡されます。
   • 「Add Value」をクリックし、「Name」に分かりやすい名前 (例: max_temp) を付けます。
   • 「Value」欄で式エディタを開き、HTTP Request ノードのレスポンス JSON から最高気温のデータを参照する式を入力します (例: {{ $node["HTTP Request"].json.main.temp_max }} - API のレスポンス構造によります)。
8. Google Sheets ノード追加: Set ノードの次に「Google Sheets」ノードを追加します。
9. Google Sheets ノード設定:
   • 認証情報 (Credential): Google アカウントとの連携認証を行います（初回のみ）。
   • Resource: 「Sheet」を選択します。
   • Operation: 「Append」を選択します（新しい行として追記）。
   • Spreadsheet ID: 記録したい Google スプレッドシートの ID を入力します (URL から取得)。
   • Sheet Name: 対象のシート名を入力します。
   • Columns > Mode: 「Columns defined below」を選択します。
   • Columns > Add Column:
     • 「Header」にスプレッドシートの列名 (例: 日付) を入力します。
     • 「Value」で式エディタを開き、現在の日付を取得する式 {{ $now.toISODate() }} を入力します。
     • 「Add Column」でさらに列を追加します。
     • 「Header」に 最高気温 と入力します。
     • 「Value」で式エディタを開き、Set ノードで設定した max_temp を参照する式 {{ $json.max_temp }} を入力します。
10. ワークフロー保存・テスト: ワークフローを保存します。Schedule トリガーは手動実行ボタンでテストできます。「Execute Workflow」ボタンを押すと、現在の時刻で処理が実行され、Google Sheets にデータが追記されるか確認します。各ノードの実行結果（Input/Output Data）も確認してデバッグします。
11. アクティブ化: テストが成功したら、ワークフローをアクティブ化します。これで毎日午前9時に自動実行されるようになります。

3.3. 実用的なワークフロー設計パターン

より複雑で実用的なワークフローを構築する際に役立つ、共通のパターンやテクニックを紹介します。

3.3.1. 条件分岐 (IFノード)

入力データの内容に応じて、処理の流れを変えたい場合に使います。

• 設定: IF ノードで条件を設定します。「Add Condition」で複数の条件を組み合わせることも可能です (AND/OR)。
• 条件の種類: 数値の比較 (Equal, Greater than 等)、文字列の比較 (Contains, Starts with 等)、存在チェック (Exists, Is Empty 等) などが利用できます。式 (Expression) を使って複雑な条件も定義できます。
• 出力: 条件が満たされた (True) 場合と、満たされなかった (False) 場合で、それぞれ別のノードに接続します。

3.3.2. ループ処理 (SplitInBatchesノードなど)

複数のアイテム（例: スプレッドシートの全行、API から取得した複数ユーザー）に対して、同じ処理を繰り返したい場合に使います。n8n には直接的なループ専用ノードはありませんが、SplitInBatches ノードを使うのが一般的です。

• SplitInBatches 設定:
  • 「Batch Size」を 1 に設定します。これにより、入力されたアイテムが1つずつのバッチ（塊）に分割されます。
  • SplitInBatches ノードは、各バッチを順番に後続のノード（図の C）に渡します。
  • 後続ノード（C）の処理が終わると、自動的に SplitInBatches ノードに戻り、次のバッチ（次のアイテム）が処理されます。
• 完了処理: 全てのバッチ（アイテム）の処理が終わると、SplitInBatches ノードの「Done」出力から、ループ完了後の処理（図の D）に進みます。
• 注意点: ループ内で API を呼び出す場合、API のレート制限（短時間での呼び出し回数上限）に注意が必要です。必要に応じて Wait ノードをループ内に入れて、実行間隔を調整します。

• Function ノードでのループ: より複雑なループ制御が必要な場合は、Function ノード内で JavaScript の for ループなどを使って実装することも可能です。

3.3.3. エラーハンドリング (Error Trigger, Continue on Fail)

ワークフロー実行中に予期せぬエラー（API 接続失敗、データ形式不正など）が発生した場合に備える仕組みです。

方法1: エラー発生時にワークフローを停止させず、処理を継続 (ノード設定)

• 各ノードの設定パネルの「Settings」タブにある「Continue On Fail」オプションを有効にします。
• そのノードでエラーが発生してもワークフロー全体は停止せず、エラー情報を持ったデータが次のノードに渡されます（またはデータなしで渡される）。
• IF ノードなどを使って、エラーが発生したかどうかをチェックし、後続の処理を分岐させることができます（例: エラー発生時のみ通知を送る）。

方法2: エラー発生時に別のワークフローを起動 (Error Trigger)

• エラーハンドリング専用の新しいワークフローを作成します。
• トリガーとして「Error Trigger」ノードを配置します。
• Error Trigger ノードは、同じ n8n インスタンス内の他のワークフローでエラーが発生すると自動的に起動します。
• 起動時に、エラーが発生したワークフロー名、ノード名、エラーメッセージなどの情報を受け取れます。
• 受け取ったエラー情報を使って、Slack やメールで管理者に通知したり、エラーログを記録したりする処理を実装します。

3.3.4. データのマージと分割 (Merge, Item Lists ノード)

複数のソースからのデータを組み合わせたり、アイテムのリストを操作したりするパターンです。

Merge ノード: 異なる処理経路から来たデータを、特定のキーを基に結合します。

• 設定: Merge ノードで、どの入力 (Input 1, Input 2) からのデータを、どのキー (customer_id など) を使って結合するかを指定します。
• モード: Merge By Key (キーが一致するアイテム同士を結合)、Append (単純に両方のアイテムリストを連結)、Pass-through (片方のデータだけを通す) などのモードがあります。

Item Lists ノード: アイテムのリストに対して、フィルタリング、ソート、集計などの操作を行います。

• Operation: Filter (条件に合うアイテムのみ抽出)、Sort (指定キーで並び替え)、Summarize (合計、平均、最大/最小などを計算)、Split Out Items (リスト内の各アイテムを個別のアイテムとして出力) などの操作を選択できます。

3.4. 具体的なユースケース別ワークフロー例

実際の業務で役立つような、より具体的なワークフローの構築例をいくつか紹介します。

3.4.1. 例1: Slack通知ボット

特定のキーワードを含むメールを受信したらSlackに通知する、あるいはフォーム送信内容をSlackに投稿するなど、Slack連携ボットの作成例です。

3.4.2. 例2: Google Sheets とのデータ連携

Webフォームからの入力をGoogle Sheetsに記録する、あるいはGoogle Sheetsのデータを読み取って他のサービスに連携するなど、スプレッドシート連携の例です。

3.4.3. 例3: 定期的なAPIデータ取得と保存

外部の公開APIから定期的にデータを取得し、整形してデータベース（PostgreSQL, MySQLなど）に保存するワークフローの例です。

• 他にも様々な自動化ができます
  • CRMリードの自動割り当て: 新規リードが CRM に追加されたら、条件に基づいて担当者を自動で割り当て、通知する。
  • ファイル処理: 特定のフォルダにファイルがアップロードされたら、内容を読み取って処理し、結果を別の場所に保存する。
  • レポート自動生成: 複数のデータソースから情報を集め、整形し、定期的にレポート（PDFやスプレッドシート）を作成してメールで送信する。

3.5. デバッグとテスト

作成したワークフローが意図通りに動作するか確認し、問題発生時に原因を特定するための方法を解説します。

3.5.1. 実行履歴の確認と分析

• アクセス: n8n エディタ左側のメニューから「Executions」を選択します。
• リスト表示: 過去のワークフロー実行がリスト形式で表示されます。成功（緑）、失敗（赤）、実行中（青）などのステータス、開始日時、実行時間などが分かります。
• 詳細表示: 各実行履歴をクリックすると、その実行におけるワークフローの経路と、各ノードの 入力 (Input Data) と 出力 (Output Data) を確認できます。
  • Input Data: そのノードが前のノードから何を受け取ったか。
  • Output Data: そのノードが処理を実行した結果、何を出力したか。
• エラー確認: 実行が失敗した場合、エラーが発生したノードが赤く表示され、クリックするとエラーメッセージやスタックトレースなどの詳細情報が表示されます。これが問題解決の最大のヒントになります。

3.5.2. ノードごとのテスト実行

ワークフロー全体を動かす前に、個々のノードが正しく設定されているか、期待通りのデータを取得・処理できるかを確認できます。

• 方法: キャンバス上でテストしたいノードを選択し、設定パネルの上部にある 再生ボタン (Execute Node) をクリックします。
• 動作: そのノードが（もしあれば前のノードからの仮データを使って）実行され、結果（Output Data）が設定パネル内に表示されます。
• 利点: API 接続の確認、データ形式の確認、式の評価結果の確認などを、ワークフロー全体を動かすことなく迅速に行えます。

3.5.3. 一般的なエラーとその対処法

ワークフロー構築中には様々なエラーに遭遇します。

エラーメッセージをよく読み、どのノードで何が問題なのかを特定することがデバッグの第一歩です。実行履歴の Input/Output Data と照らし合わせながら原因を探りましょう。