インスタンス間ワークフロー同期ユーティリティ - n8n ワークフロー

複数のステージングおよび本番n8n環境を管理するオートメーションアーキテクト
異なるセルフホスト型インスタンス間で一貫性のあるn8nワークフローの更新を展開する必要がある技術チーム
特定n8nテンプレートをアカウント間でバックアップまたは移動するための信頼性の高い方法を求めるユーザー
管理およびDevSecOpsタスクでn8n APIを活用しているすべての方

複数のn8nインスタンスの管理は、同期の課題を引き起こしがちです。複雑なn8nワークフロー定義を手動でエクスポートおよびインポートするのは、時間がかかりエラーが発生しやすくなります。この専用n8nワークフローは、ソースインスタンスに存在するが宛先インスタンスにないワークフローを自動的に識別して複製することで、この問題を解決します。

Mergeノード内のネイティブn8nノード機能とSQL比較ロジックを活用することで、この自動化は高い忠実度での同期を保証します。不足しているn8nワークフローを複製した後、高度なHTTPリクエストステップを使用して、宛先インスタンス上の特定のプロジェクトに新しいワークフローを任意で割り当て、新しいn8nテンプレート展開に対する完全な管理制御を提供します。

この自動化は、「Test workflowをクリックしたとき」のn8nトリガーから開始されます。

1. ワークフローの取得: n8nワークフローは即座に分岐し、ソースインスタンスのワークフローについてはGET - Workflows n8nノード、宛先インスタンスのワークフローについてはGET - Destination Workflows n8nノードに対して同時にクエリを実行します。


2. データの準備: 両インスタンスからのデータは、Split Out Workflows n8nノードのバリアントを使用して分離されます。


3. 不足ワークフローの特定: コアルールはMerge Workflows n8nノードにあり、SQLのLEFT JOIN比較を使用します。これは、ソース（入力1）からのワークフロー名と宛先（入力2）からのワークフロー名を比較します。WHERE input2.name IS NULL句により、ソースに存在するが宛先に存在しないワークフローのみが後続に渡されます。


4. バッチ処理: Loop Over Items n8nノードは、特定されたワークフローを少量のバッチ（1バッチあたり5アイテム）で処理します。


5. ワークフローの作成: 不足している各ワークフローについて、CREATE - Workflow n8nノードは宛先インスタンスのn8n API認証情報を使用して、ノード、接続、設定を含め、ワークフローを再作成します。


6. プロジェクトへの割り当て（オプション）: 作成後、ワークフローはHTTPリクエストとフィルタリングを使用して、宛先インスタンス上のターゲットプロジェクトIDを動的に検索します。最後に、PUT - Workflow in Project n8nノードが新しく作成されたn8nワークフローを指定されたプロジェクトに移管します。

この強力なn8nワークフローを展開し、n8nテンプレートを管理するには、次の手順に従ってください。

1. JSONのインポート: 提供されたn8nワークフローJSONコードをコピーし、「新規」メニュー -> 「JSONからインポート」を使用してn8nインスタンスにインポートします。


2. ソースインスタンスの認証情報設定: GET - Workflows n8nノードを見つけます。「n8n API」認証情報（テンプレート内では「AK n8n original account」とラベル付け）を、ソースn8nインスタンスを指すように更新します。


3. 宛先インスタンスの認証情報設定: GET - Destination Workflows および CREATE - Workflow で使用される「n8n API」認証情報（テンプレート内では「AlexK1919 n8n ent account」とラベル付け）を、宛先n8nインスタンスを指すように更新します。


4. APIキー: 設定した認証情報が、n8nワークフロー項目を一覧表示および作成するために必要な権限（通常はAll権限）を持っていることを確認してください。


5. プロジェクトフィルターの設定（オプション）: プロジェクト割り当て機能を使用したい場合は、Filter Project n8nノードに移動し、条件内のrightValueを変更して、新しく作成するn8nワークフローを宛先インスタンスのどのプロジェクトに移管したいかの正確な名前に一致させます。

このn8nワークフローは、コアノードとn8n APIに依存しています。

「Test workflow」をクリックしたとき（手動トリガー）: クローニングプロセスを開始するための必須のn8nトリガー。即時同期テストに使用されます。
GET - Workflows / GET - Destination Workflows (n8nノード): n8n APIリソースを使用し、それぞれソースインスタンスと宛先インスタンスからすべてのワークフローを取得します。
Merge Workflows (Mergeノード): ロジック制御に不可欠です。SQLによる結合モードを使用し、LEFT JOINを用いて、ワークフロー名に基づき宛先インスタンスに既に存在するn8nワークフローを除外します。
CREATE - Workflow (n8nノード): 最終的なアクションノード。不足しているn8nワークフローの完全なJSON定義を宛先インスタンスのAPIにPOSTする役割を担います。
Filter Project (Filterノード): プロジェクト名（例：「z Original n8n Workflows from AlexK1919」）を照合することにより、宛先インスタンス上の特定のプロジェクトIDを識別するために使用されます。
PUT - Workflow in Project (HTTP Requestノード): 新しく作成されたn8nワークフローを指定されたプロジェクトコンテナに移管するためのAPIコールを行う高度なユーティリティn8nノードです。