n8n workflow automation patterns and API integration. This skill should be used when creating n8n workflows, using webhooks, managing workflows via REST API, or integrating n8n with MCP servers.
This skill enables creating and managing n8n workflows for automation tasks.
n8n instance running with API access:
N8N_HOST=localhost
N8N_PORT=5678
N8N_API_KEY=your-api-key
Every n8n workflow is JSON with this structure:
{
"name": "Workflow Name",
"nodes": [],
"connections": {},
"settings": {
"executionOrder": "v1"
}
}
Each node has:
{
"id": "unique-id",
"name": "Display Name",
"type": "n8n-nodes-base.nodetype",
"typeVersion": 1,
"position": [x, y],
"parameters": {},
"credentials": {}
}
Connections define data flow between nodes:
{
"Source Node": {
"main": [
[{"node": "Target Node", "type": "main", "index": 0}]
]
}
}
Creates an HTTP endpoint that triggers workflow execution:
{
"name": "Webhook Handler",
"nodes": [
{
"id": "webhook",
"name": "Webhook",
"type": "n8n-nodes-base.webhook",
"typeVersion": 2,
"position": [250, 300],
"webhookId": "my-webhook",
"parameters": {
"path": "my-endpoint",
"httpMethod": "POST",
"responseMode": "responseNode"
}
},
{
"id": "respond",
"name": "Respond",
"type": "n8n-nodes-base.respondToWebhook",
"typeVersion": 1.1,
"position": [450, 300],
"parameters": {
"respondWith": "json",
"responseBody": "={{ $json }}"
}
}
],
"connections": {
"Webhook": {
"main": [[{"node": "Respond", "type": "main", "index": 0}]]
}
}
}
Access at: http://localhost:5678/webhook/my-endpoint
Make external API calls:
{
"id": "http",
"name": "HTTP Request",
"type": "n8n-nodes-base.httpRequest",
"typeVersion": 4.2,
"position": [450, 300],
"parameters": {
"method": "POST",
"url": "https://api.example.com/endpoint",
"authentication": "predefinedCredentialType",
"nodeCredentialType": "myApiCredential",
"sendBody": true,
"specifyBody": "json",
"jsonBody": "={{ JSON.stringify($json) }}"
},
"credentials": {
"myApiCredential": {"id": "cred-id", "name": "My Credential"}
}
}
Route data based on conditions:
{
"id": "if",
"name": "IF",
"type": "n8n-nodes-base.if",
"typeVersion": 2,
"position": [450, 300],
"parameters": {
"conditions": {
"options": {
"caseSensitive": true,
"leftValue": "",
"typeValidation": "strict"
},
"conditions": [
{
"leftValue": "={{ $json.status }}",
"rightValue": "success",
"operator": {
"type": "string",
"operation": "equals"
}
}
],
"combinator": "and"
}
}
}
Process items in batches:
{
"id": "batch",
"name": "Loop Over Items",
"type": "n8n-nodes-base.splitInBatches",
"typeVersion": 3,
"position": [450, 300],
"parameters": {
"batchSize": 10,
"options": {}
}
}
curl -s "http://localhost:5678/api/v1/workflows" \
-H "X-N8N-API-KEY: $N8N_API_KEY"
curl -s "http://localhost:5678/api/v1/workflows/{id}" \
-H "X-N8N-API-KEY: $N8N_API_KEY"
curl -s -X POST "http://localhost:5678/api/v1/workflows" \
-H "X-N8N-API-KEY: $N8N_API_KEY" \
-H "Content-Type: application/json" \
-d '{"name": "New Workflow", "nodes": [...], "connections": {...}}'
curl -s -X PUT "http://localhost:5678/api/v1/workflows/{id}" \
-H "X-N8N-API-KEY: $N8N_API_KEY" \
-H "Content-Type: application/json" \
-d '{"name": "Updated", "nodes": [...], "connections": {...}}'
curl -s -X POST "http://localhost:5678/api/v1/workflows/{id}/activate" \
-H "X-N8N-API-KEY: $N8N_API_KEY"
curl -s -X POST "http://localhost:5678/api/v1/workflows/{id}/deactivate" \
-H "X-N8N-API-KEY: $N8N_API_KEY"
curl -s "http://localhost:5678/api/v1/executions?workflowId={id}&limit=10&includeData=true" \
-H "X-N8N-API-KEY: $N8N_API_KEY"
n8n uses expressions for dynamic values:
| Syntax | Description |
|---|---|
={{ $json.field }} |
Access current item field |
={{ $json.body.param }} |
Access nested field |
={{ $('Node Name').item.json.field }} |
Access output from specific node |
={{ $input.first().json }} |
First input item |
={{ $input.all() }} |
All input items |
={{ JSON.stringify($json) }} |
Convert to JSON string |
| Node | Type | Purpose |
|---|---|---|
| Webhook | n8n-nodes-base.webhook |
HTTP trigger |
| HTTP Request | n8n-nodes-base.httpRequest |
API calls |
| Respond to Webhook | n8n-nodes-base.respondToWebhook |
Return HTTP response |
| IF | n8n-nodes-base.if |
Conditional branching |
| Switch | n8n-nodes-base.switch |
Multi-way branching |
| Set | n8n-nodes-base.set |
Transform data |
| Code | n8n-nodes-base.code |
Custom JavaScript |
| Split In Batches | n8n-nodes-base.splitInBatches |
Loop processing |
| Merge | n8n-nodes-base.merge |
Combine branches |
n8n can expose workflows as MCP tools via the built-in MCP server:
"availableInMCP": truehttp://localhost:5678/mcp-server/httpresponseMode: "responseNode" with Respond node for control/webhook-test/ path during development