n8n Automation
n8n Automation Architect's Master Reference
Enterprise-grade workflows, expressions, and production blueprints.
To build scalable, enterprise-grade n8n automations that won't fail silently or leak credentials, follow these production standards:
- Always Use Credentials Store: Never hardcode API keys, tokens, or basic auth passwords in Code or HTTP Request nodes. Reference them via n8n's encrypted credential manager.
- Implement Global Error Triggers: Create a dedicated error-handling workflow using the
Error Triggernode to catch workflow execution failures and send instant alerts to Slack, Discord, or Email. - Enable Execution Pruning: Turn on
EXECUTIONS_DATA_PRUNE=truein your environment parameters to automatically clear old execution logs and prevent your database disk space from filling up over time. - Sub-Workflow Modularization: Break massive workflows into sub-workflows called via the
Execute Workflownode. This makes troubleshooting far simpler and enables code reusability.
Node Directory
| Node Name | Category | Common Use Case |
|---|---|---|
| Webhook | Trigger | Receive incoming POST/GET payloads from external services to start a workflow. |
| HTTP Request | Action | Make custom API calls (REST/GraphQL) when a dedicated integration node doesn't exist. |
| Code | Logic | Write custom JavaScript or Python to map, transform, or filter complex JSON arrays. |
| Switch | Routing | Route data down different workflow paths based on expression rules (e.g., Status == 'Paid'). |
| Loop Over Items | Flow Control | Process arrays in batches to prevent API rate limits or database socket timeouts. |
| AI Agent | Advanced AI | Connect LLMs, memory, and custom tools to build autonomous decision-making agents. |
| Schedule (Cron) | Trigger | Fire workflows at specific intervals (e.g., every day at midnight for database syncing). |
| Error Trigger | Trigger | Global catch node that fires automatically whenever an unhandled error occurs in any workflow. |
| Execute Workflow | Flow Control | Call sub-workflows as modular functions, passing inputs and returning outputs seamlessly. |
| Wait Node | Flow Control | Pause execution for a fixed duration, until a specific date, or until a webhook callback is received. |
| GraphQL | Action | Execute structured GraphQL queries and mutations against modern microservice APIs. |
| AWS S3 / Cloud Storage | Storage | Upload, download, or manage binary files, backups, and media assets in cloud storage buckets. |
| Redis | Database | High-speed caching, atomic lock management, and pub/sub queue operations. |
| PostgreSQL | Database | Execute relational SQL queries, upserts, bulk updates, and database row transactions. |
Architectural Blueprints & Setup Guides
Initialize Trigger & AI Agent Node
Add a Chat Trigger node or Webhook node to receive human prompts. Connect it directly to the input of an AI Agent node configured in Tools Agent mode.
Attach Model Provider & Memory
Attach an LLM node (e.g., OpenAI Chat Model or Anthropic Chat Model) into the model port. Connect a Window Buffer Memory node to give the agent conversation history context.
Bind Custom Tools
Connect tools into the AI Agent's tool sub-node inputs. Use standard integrations (e.g., Google Sheets, Slack) or create a Custom Tool node that calls an internal API endpoint.
Set Up Authentication Headers or HMAC
In your Webhook node settings, set Authentication to Header Auth or verify incoming signatures using an HMAC SHA256 secret key in a Code node.
Compute HMAC Signature in Code Node
Use Node.js crypto module to hash the incoming raw body payload and compare it against the provider's signature header:
Batch Items with Loop Over Items
When fetching thousands of rows from PostgreSQL or MySQL, process them in managed batches using the Loop Over Items node configured for 50–100 items per batch iteration.
Execute Upserts (Update on Conflict)
Use the database node's Upsert operation rather than raw insert. Specify a unique primary key column (e.g. id or email) to update existing records seamlessly without raising duplicate key errors.
Expression Reference & Code Snippets
Data Access Expressions
Date & Luxon Functions
String & Text Transformation
Array & Data Filtering
Official Developer Resources
Top 50 Production Workflow Blueprints
| # | Blueprint Name & Core Objective | Category | Target Tech Stack | Actions |
|---|---|---|---|---|
| 01 | AI Support Ticket Auto-Categorization & Response Extract sentiment, assign priority tags, and draft auto-replies for helpdesk agents. |
AI & LLMs | Zendesk OpenAI Slack | |
| 02 | RAG Document Question-Answering Agent Vectorize PDFs/docs into vector DB and query with contextual AI memory. |
AI & LLMs | Pinecone LangChain OpenAI | |
| 03 | Automated Web Scraping & AI Summarizer to Notion Fetch URLs from RSS feeds, extract body copy, summarize key points, and push to database. |
AI & LLMs | HTTP Request Claude Notion | |
| 04 | Social Media Content Calendar Generator Generate platform-specific marketing posts from blog URLs and queue publishing schedules. |
AI & LLMs | OpenAI Buffer Airtable | |
| 05 | Voice Note Transcriber & Action Item Extractor Convert audio recordings to text via Speech-to-Text and email action items to team. |
AI & LLMs | Whisper GPT-4o Gmail | |
| 06 | Lead Enrichment & Scoring Agent Fetch company metrics on new signups and compute lead qualification score. |
AI & LLMs | Clearbit OpenAI HubSpot | |
| 07 | Customer Feedback Sentiment & Topic Clustering Analyze app store reviews and cluster feedback into actionable Jira tasks. |
AI & LLMs | Webhook LLM Chain Jira | |
| 08 | Autonomous Web Research Agent Execute multi-query search searches, aggregate findings, and produce Markdown briefs. |
AI & LLMs | SerpAPI AI Agent Google Docs | |
| 09 | Multilingual Content Translation Pipeline Translate app UI strings into 12 languages while maintaining HTML formatting tags. |
AI & LLMs | GitHub DeepL OpenAI | |
| 10 | GitHub Issue Auto-Triage & Solution Suggestion Analyze bug reports against codebase docs and post AI suggestions in comments. |
AI & LLMs | GitHub Vector Store OpenAI | |
| 11 | SSL Certificate Expiry Monitor & Alerting Scan company domains daily and notify DevOps on Slack when certificates expire in <14 days. |
DevOps & Security | Cron Code (TLS) Slack | |
| 12 | AWS CloudWatch Cost Spike Anomaly Detector Compare hourly cloud infrastructure spend against historical baselines and ping alerts. |
DevOps & Security | AWS Cost API Switch PagerDuty | |
| 13 | Incident Escalation & On-Call Dispatch Route critical web server downtime events to SMS, Telegram, and team incident channels. |
DevOps & Security | PagerDuty Twilio Telegram | |
| 14 | GitHub PR Vulnerability & Dependency Auditor Block or warn open PRs containing flagged outdated packages or credential leaks. |
DevOps & Security | GitHub Webhook Snyk Code | |
| 15 | Docker Container Health Check & Auto-Restart Alert Poll container engine health metrics and trigger recovery commands on crash. |
DevOps & Security | Docker Socket SSH Discord | |
| 16 | Dynamic DNS (DDNS) Update & Cloudflare Sync Detect external IP change for self-hosted instances and update DNS records instantly. |
DevOps & Security | Schedule ipify API Cloudflare | |
| 17 | Automated Database Backup to AWS S3 Dump database snapshots nightly, compress, upload to cloud storage, and enforce lifecycle rules. |
DevOps & Security | Execute Command S3 Email | |
| 18 | User Offboarding & Identity Revocation Workflow Deactivate user across identity providers, SaaS applications, and revoke API tokens. |
DevOps & Security | Okta Google Workspace GitHub | |
| 19 | Sentry Application Error Aggregator to Jira Group recurring software exceptions and generate auto-prioritized Jira tickets. |
DevOps & Security | Sentry Filter Jira Software | |
| 20 | Uptime Monitoring with Webhook Failovers Ping API endpoints every 60 seconds and switch DNS route on failure detection. |
DevOps & Security | Cron HTTP Request AWS Route53 | |
| 21 | Round-Robin Inbound Lead Routing & Rep Assignment Distribute incoming website sales leads evenly among online sales reps. |
Sales & CRM | HubSpot Redis Slack | |
| 22 | Stripe Failed Payment Recovery & Dunning Sequence Catch payment failures, send update links via email, and pause subscription features. |
Sales & CRM | Stripe SendGrid PostgreSQL | |
| 23 | Cold Email Outreach Campaign Sync Sync warm leads who replied in outreach software back into CRM pipeline stage. |
Sales & CRM | Instantly Pipedrive Airtable | |
| 24 | Typeform Entry to Salesforce Lead Creation Normalize form responses and perform deduplication check before creating contacts. |
Sales & CRM | Typeform Salesforce Switch | |
| 25 | LinkedIn Lead Gen Form Direct Sync to CRM Pull ad conversion lead data in real-time and notify rep in account channel. |
Sales & CRM | LinkedIn Ads HubSpot Slack | |
| 26 | Automated Webinar Attendee Follow-up Sequence Segment live attendees vs no-shows and trigger tailored nurture campaigns. |
Sales & CRM | Zoom ActiveCampaign Code | |
| 27 | Customer Churn Risk Predictor & CSM Alert System Flag accounts with declining app logins and trigger customer success check-ins. |
Sales & CRM | Mixpanel Gainsight Slack | |
| 28 | Offline Conversion Event Sync to Google Ads Upload closed-won deal values from CRM to optimize ad bidding algorithms. |
Sales & CRM | Salesforce Google Ads API Cron | |
| 29 | Calendar Booking Sync & Zoom Room Creator Create unique video call links upon booking and append details to CRM deal notes. |
Sales & CRM | Calendly Zoom Google Calendar | |
| 30 | E-commerce Abandoned Cart Auto-Reminder Pipeline Send personalized SMS discount code 2 hours after shopper abandons cart. |
Sales & CRM | Shopify Klaviyo Twilio | |
| 31 | PostgreSQL to Snowflake Scheduled ETL Pipeline Extract updated rows, transform to Parquet/JSON schema, and load into data warehouse. |
Data & ETL | PostgreSQL S3 Snowflake | |
| 32 | MySQL CDC to Kafka Message Stream Capture row inserts/updates and stream event payloads to Kafka cluster topic. |
Data & ETL | MySQL Code Kafka | |
| 33 | Google Sheets to Airtable Continuous Two-Way Sync Reconcile row changes between spreadsheets with conflict-handling timestamps. |
Data & ETL | Google Sheets Airtable Code | |
| 34 | Email Attachment CSV Ingestion & DB Validation Extract CSVs from inbox, validate headers and data types, and bulk insert into DB. |
Data & ETL | IMAP Spreadsheet File Postgres | |
| 35 | Webhook Data Normalization & JSON Schema Validator Sanitize third-party API payloads against JSON Schema definition before ingestion. |
Data & ETL | Webhook Code (Ajv) Database | |
| 36 | BigQuery Analytics Reporting to Slack Digest Execute daily SQL metrics queries and format key performance charts for executive channels. |
Data & ETL | BigQuery QuickChart API Slack | |
| 37 | Notion Database to Google Drive PDF Exporter Render Notion workspace documents to clean PDFs and back them up to company drive. |
Data & ETL | Notion HTML-to-PDF Google Drive | |
| 38 | ElasticSearch Error Log Aggregator & Alert Trigger Query application logs for 5xx errors and post summary stats to DevOps room. |
Data & ETL | ElasticSearch Loop Discord | |
| 39 | Supabase Realtime Listener to Webhook Router Listen to database mutations and trigger down-stream microservices instantly. |
Data & ETL | Supabase Switch HTTP Request | |
| 40 | Redis Cache Invalidation Trigger on DB Record Mutation Clear cached key-value store entries whenever admin edits product details in CMS. |
Data & ETL | PostgreSQL Redis Logger | |
| 41 | Daily Executive AI Briefing via Email Aggregate calendar events, open tasks, unread priority emails, and sales numbers. |
Operations & HR | Google Calendar OpenAI Gmail | |
| 42 | Automated Invoice OCR Extraction & Accounting Sync Scan PDF invoices, extract totals/line items, and register vendor bills in accounting tool. |
Operations & HR | Google Drive Mindee OCR QuickBooks | |
| 43 | Slack Message to Jira Task Converter via Reaction Emoji Tagging a message with 🎫 creates a structured Jira ticket with link references. |
Operations & HR | Slack Trigger Jira Switch | |
| 44 | Expense Receipt Parsing & Monthly Reimbursement Generator Extract merchant names and costs from photos and build monthly CSV expense logs. |
Operations & HR | Telegram Bot GPT-4 Vision Sheets | |
| 45 | New Hire Onboarding Document & IT Provisioning Checklist Send welcome packets, generate email accounts, and assign HR completion tasks. |
Operations & HR | BambooHR Google Workspace Asana | |
| 46 | Meeting Notes Transcriber & Action Item Task Assigner Parse call transcripts and automatically assign tasks to attendees in project manager. |
Operations & HR | Otter.ai OpenAI Trello | |
| 47 | Google Drive Shared Folder Security & Permission Auditor Scan company Drive weekly and revoke public sharing links on sensitive documents. |
Operations & HR | Google Drive API Code Email | |
| 48 | Weekly Team Status Update Aggregator & Digest Prompt team members on Friday for updates and compile a summary for leadership. |
Operations & HR | Slack Google Forms Email | |
| 49 | E-Signature Contract Tracker & Automated Storage Save signed client agreements to Drive folder and mark deal as Closed-Won. |
Operations & HR | DocuSign Google Drive HubSpot | |
| 50 | Cross-Timezone Team Availability Assistant Calculate overlapping working hours across remote teams and suggest ideal meeting slots. |
Operations & HR | Slack Command Code (Luxon) Google Cal |