n8n統合
概要
n8nは、ユーザーが視覚的なインターフェースを通じて複雑なワークフローを作成、展開、管理できる強力なオープンソース自動化プラットフォームです。300以上のアプリケーションやサービスとの統合をサポートし、webhookやスケジュールトリガーなど多様なトリガー方式を提供します。
OneAIとn8nの双方向統合により、ユーザーに強力な自動化機能を提供します：
- OneAIからn8nワークフローの呼び出し：スキルプラグイン機構を通じて、n8nワークフローをOneAIの拡張機能として利用し、AIが複雑な自動化フローをトリガー・実行できるようにします。これによりデータ処理やシステム統合などの機能を実現します。
- n8nからOneAI APIの呼び出し：n8nワークフロー内でシームレスにOneAIのインテリジェントサービスを呼び出し、自動化フローにAI機能（テキスト分析、コンテンツ生成、ナレッジQAなど）を組み込むことができます。
この双方向統合は、企業に柔軟な自動化ソリューションを提供し、カスタマーサービス自動化、データ処理フロー、システム間業務プロセスのオーケストレーション、インテリジェント通知などのシナリオで活用でき、運用効率の向上と人的コストの削減に貢献します。
n8n からOneAI APIの呼び出し
OneAIコミュニティノードのインストール
n8nワ ークベンチ左下の ... > Setting から設定ページに入り、Community nodesで n8n-nodes-oneai をインストールします：
tip
コミュニティノードのインストール後はn8nサービスを再起動してください。そうしないとノードパネルにOneAIノードが重複して表示される場合があります。
OneAI Credentialの追加
Credential追加画面でOneAIを選択します。
以下の情報を入力してください：
- Base URL：OneAIサーバーアドレス。末尾に
/を付けないでください - Client ID：OneAIのClient Managementで作成・取得
- Client Secret：OneAIのClient Managementで作成・取得
- User Account：ユーザー管理のUser Name。該当ユーザーの権限でAPIを呼び出し ますので、十分なAPI権限があることを確認してください
保存後、Credentialは自動的にテストされ、正しく設定されていればConnection tested successfullyと表示されます：
方法1：One AI NodeでOpenAPIを呼び出す
One AIノードを選択します：
実行したいAction（操作）を選択します：
ノードのテスト：
- 適切なパラメータを設定
- "Test Step"ボタンをクリックしてテストを実行
- 右側パネルで実行結果を確認
具体的なテスト手順：
- OneAI Credentialが正しく選択されていることを確認
- 必要な入力パラメータを入力
- ノードを実行し、返却結果が期待通りか検証
- 実行失敗の場合はエラーメッセージを確認し、設定を調整
方法2：HTTP Request NodeでOpenAPIを呼び出す
OneAI Nodeは現時点で一部のOpenAPI Operationのみ提供しています。必要なAPIがOneAI NodeのOperationリストにない場合は、HTTP Request Nodeで直接APIを呼び出せます。
HTTP Requestノードを選択します：
リクエストパラメータを設定：
- Method：適切なHTTPメソッド（GET/POST/PUTなど）を選択
- URL：OneAI APIの完全なURLパスを入力
- Headers：必要に応じてリクエストヘッダーを追加
- Query Parameters/Body：API仕様に従って設定
tip
Import cURLでインポート可能ですが、HeaderのAuthorizationは削除してください。下記のAuthentication設定と競合します。
Authenticationの設定：
- Authentication：Predefined Credential Typeを選択
- Credential Type：OneAI APIを選択
- OneAI API：既存のOneAI Credentialを選択、または新規作成
ノードのテスト：
- すべてのパラメータ設定が正しいことを確認
- "Execute Node"ボタンをクリックしてテストを実行
- 返却結果が期待通りか確認
OneAI からn8nワークフローの呼び出し
n8nフローの作成
まず、ワークフローを作成し、名前をEchoとし、TriggerをWebhookに設定します。作成後、右上の"Active"ボタンをクリックしてフローを有効化します。
Webhookの設定：
- HTTP Method：POSTを選択
- Path：このフローを呼び出すアドレス。デフォルト値を使用可能
- Authentication：
Header Authを選択し、Credentialを作成。HeaderとValueを保存しておき、後でスキルプラグイン設定時に使用します - Respond：
Using 'Respond to Webhook' Nodeを選択
Respond to Webhookノードを追加し、以下のように設定します：
- Respond With：JSONを選択
- Response Body：FixedをExpressionに切り替え、以下のjsonを入力
{
"output": "{{ $json.body.input }}"
}
スキルを追加しn8nフローに紐付け
OneAIプラットフォームで以下の設定を行い ます：
- Code：echoを入力
- Name：echoを入力し、魔法の杖アイコンで自動翻訳
- Description：echoを入力し、魔法の杖アイコンで自動翻訳
- Request header：前述のn8n webhookでHeader Authを設定した場合、ここで対応するHeaderとValueを追加し、認証が通るようにします
- OpenAPI / Swagger Schema (JSON)：以下のテンプレートを基に修正
tip
{n8n_server_url}をn8nサーバーのURLに、{n8n_webhook_path}をn8n webhookノードのpathに置き換えてください
{
"openapi": "3.0.3",
"info": {
"title": "N8N echo example",
"version": "1.0.0"
},
"servers": [
{
"url": "{n8n_server_url}"
}
],
"paths": {
"/webhook/{n8n_webhook_path}": {
"post": {
"operationId": "echo",
"summary": "echo",
"requestBody": {
"required": true,
"content": {
"application/json": {
"schema": {
"type": "object",
"properties": {
"input": {
"type": "string",
"description": "Text content from user input"
}
},
"required": [
"input"
]
}
}
}
},
"responses": {
"200": {
"description": "Echo success",
"content": {
"application/json": {
"schema": {
"type": "object",
"properties": {
"output": {
"type": "string",
"description": "Echo output"
}
},
"required": [
"output"
]
}
}
}
}
}
}
}
}
}
設定後、"debug"ボタンをクリックしてテストできます：
Agentからスキルを呼び出す
Agentにechoスキルを追加します：
AgentのPromptを修正し、スキル呼び出しを誘導します。
Prompt例：
# Skill echo
If the user enters the `echo` command, please call the `echo` function and return `output` in the result.
スキルのテスト（echo 1+1=?と入力し、1+1=?が返り、echoスキルが呼び出されたことを確認）：
n8nフローの実行状況を確認：
より複雑なフローは、このサンプルを基に拡張可能です。
例：n8nでデータベースを検索しデータを返す場合、WebhookとRespond to Webhookノードの間にDatabaseノードを追加し、DB接続情報を設定します。 その後、Respond to webhookのBodyの値を調整し、クエリ結果を正しく返すようにします。
ベストプラクティスとトラブルシューティング
ベストプラクティス
- 各ワークフローに明確なコメントと説明を記載
- 適切なエラーハンドリングでフローの安定性を確保
- 定期的にワークフローの実行履歴とログを確認
- 複雑なフローはテスト環境で事前検証を推奨
よくある問題のトラブルシュート
-
認証失敗
- Credential設定が正しいか確認
- Client IDとSecretが有効か確認
- ユーザーアカウントに十分な権限があるか検証
-
Webhook呼び出し失敗
- n8nサービスがOneAIサーバーからアクセス可能か確認
- 認証ヘッダー情報が正しく設定されているか確認
- webhookパスが正しいか検証
-
ノード実行エラー
- 入力データ形式が要件を満たしているか確認
- APIバージョンの互換性を確認
- 詳細なエラーログを確認
n8nのデプロイ
n8nは様々な環境向けのデプロイメントドキュメントを提供しています。n8nセルフホスティングを参考に、最適なデプロイ方法を選択してください。
Azureプラットフォーム上でn8nを迅速にデプロイしたい場合、Terraformに精通していれば、以下のスクリプトを参考にできます：
main.tf
terraform {
required_providers {
azurerm = {
source = "hashicorp/azurerm"
version = "4.27.0"
}
}
}
provider "azurerm" {
features {}
subscription_id = var.subscription_id
tenant_id = var.tenant_id
}
# Variable definitions
variable "subscription_id" {
description = "Azure Subscription ID"
type = string
default = "your-subscription-id"
}
variable "tenant_id" {
description = "Azure Tenant ID"
type = string
default = "your-tenant-id"
}
variable "application_name" {
description = "Application name"
type = string
default = "n8n"
}
variable "environment" {
description = "Environment"
type = string
default = "dev"
}
variable "location" {
description = "Azure region"
type = string
default = "eastasia"
}
variable "container_image" {
description = "N8N container image"
type = string
default = "n8nio/n8n:latest"
}
variable "n8n_host" {
description = "N8N URL"
type = string
default = "your-app-url.azurewebsites.net"
}
variable "random_suffix" {
description = "Random string"
type = string
default = "suffix"
}
variable "app_service_sku" {
description = "App Service Plan SKU"
type = string
default = "B2"
}
# Account and password variables
variable "n8n_encryption_key" {
description = "N8N encryption key"
type = string
default = "your-encryption-key"
sensitive = true
}
variable "n8n_basic_auth_user" {
description = "N8N basic auth username"
type = string
default = "admin"
}
variable "n8n_basic_auth_password" {
description = "N8N basic auth password"
type = string
default = "your-secure-password"
sensitive = true
}
variable "postgresql_admin_username" {
description = "PostgreSQL admin username"
type = string
default = "psqladmin"
}
variable "postgresql_admin_password" {
description = "PostgreSQL admin password"
type = string
default = "your-secure-password"
sensitive = true
}
# Resource Group
resource "azurerm_resource_group" "n8n" {
name = "rg-${var.application_name}-${var.environment}"
location = var.location
}
# App Service Plan
resource "azurerm_service_plan" "n8n" {
name = "asp-${var.application_name}-${var.environment}"
resource_group_name = azurerm_resource_group.n8n.name
location = azurerm_resource_group.n8n.location
os_type = "Linux"
sku_name = var.app_service_sku
}
# App Service (Web App for Containers)
resource "azurerm_linux_web_app" "n8n" {
name = "app-${var.application_name}-${var.environment}-${var.random_suffix}"
resource_group_name = azurerm_resource_group.n8n.name
location = azurerm_resource_group.n8n.location
service_plan_id = azurerm_service_plan.n8n.id
app_settings = {
"N8N_ENCRYPTION_KEY" = var.n8n_encryption_key
"N8N_HOST" = "${var.n8n_host}"
"N8N_PORT" = "443"
"N8N_PROTOCOL" = "https"
"N8N_WEBHOOK_URL" = "https://${var.n8n_host}/"
"GENERIC_TIMEZONE" = "Asia/Shanghai"
"N8N_BASIC_AUTH_ACTIVE" = "true"
"N8N_BASIC_AUTH_USER" = var.n8n_basic_auth_user
"N8N_BASIC_AUTH_PASSWORD" = var.n8n_basic_auth_password
"EXECUTIONS_DATA_PRUNE" = "true"
"EXECUTIONS_DATA_MAX_AGE" = "336"
"WEBSITES_PORT" = "443"
# DB Config
"DB_TYPE" = "postgresdb"
"DB_POSTGRESDB_HOST" = "${azurerm_postgresql_flexible_server.postgresql_server.fqdn}"
"DB_POSTGRESDB_PORT" = "5432"
"DB_POSTGRESDB_DATABASE" = "${azurerm_postgresql_flexible_server_database.postgresql_database.name}"
"DB_POSTGRESDB_USER" = var.postgresql_admin_username
"DB_POSTGRESDB_PASSWORD" = var.postgresql_admin_password
"DB_POSTGRESDB_SSL_REJECT_UNAUTHORIZED" = "false"
}
site_config {
always_on = true
websockets_enabled = true
application_stack {
docker_image_name = "${var.container_image}"
docker_registry_url = "https://docker.n8n.io"
}
}
}
# PostgreSQL database server
resource "azurerm_postgresql_flexible_server" "postgresql_server" {
name = "psql-${var.application_name}-${var.environment}"
resource_group_name = azurerm_resource_group.n8n.name
location = azurerm_resource_group.n8n.location
administrator_login = var.postgresql_admin_username
administrator_password = var.postgresql_admin_password
version = "16"
sku_name = "B_Standard_B1ms"
# 128GB
storage_mb = 131072
backup_retention_days = 35
geo_redundant_backup_enabled = true
public_network_access_enabled = true
lifecycle {
ignore_changes = [
zone,
]
}
}
# PostgreSQL firewall rule
resource "azurerm_postgresql_flexible_server_firewall_rule" "postgresql_firewall_rule" {
name = "AllowAzureServicesAccessPGSQL"
server_id = azurerm_postgresql_flexible_server.postgresql_server.id
start_ip_address = "0.0.0.0"
end_ip_address = "0.0.0.0"
}
# PostgreSQL database instance
resource "azurerm_postgresql_flexible_server_database" "postgresql_database" {
name = "psqldb-${var.application_name}-${var.environment}"
server_id = azurerm_postgresql_flexible_server.postgresql_server.id
charset = "UTF8"
collation = "en_US.utf8"
}
# Output
output "n8n_url" {
description = "N8N access url"
value = "https://${azurerm_linux_web_app.n8n.default_hostname}"
}