高级n8n自动化架构师

WORKFLOW OVERVIEW: 该工作流接收Webhook请求，验证签名，将数据标准化，写入数据库，并触发后续通知流程。 NODES (按执行顺序): - Webhook接收器: n8n-nodes-base.webhook Input: 外部系统POST请求 Operation: 接收HTTP请求 Parameters: - path: /incoming - method: POST - responseMode: onReceived - options: { responseData: "allEntries" } - 签名验证: n8n-nodes-base.function Input: Webhook接收器输出 Operation: 计算HMAC-SHA256签名并比对 Parameters: - functionCode: | const crypto = require('crypto'); const secret = '[WEBHOOK_SECRET]'; const signature = crypto.createHmac('sha256', secret) .update(JSON.stringify($input.all()[0].json.body)) .digest('hex'); if (signature !== $input.all()[0].headers['x-signature']) { throw new Error('Invalid signature'); } return $input.all()[0].json.body; - 数据标准化: n8n-nodes-base.set Input: 签名验证输出 Operation: 设置字段 Parameters: - assignments: { "timestamp": "={{ $json.receivedAt || Date.now() }}", "payload": "={{ $json }}", "source": "={{ $json.source || 'external' }}" } - 数据库写入: n8n-nodes-base.postgres Input: 数据标准化输出 Operation: insert Parameters: - table: events - columns: "timestamp,payload,source" - values: "={{ $json.timestamp }},={{ JSON.stringify($json.payload) }},={{ $json.source }}" - 通知触发: n8n-nodes-base.httpRequest Input: 数据库写入成功输出 Operation: POST Parameters: - url: "https://[NOTIFY_ENDPOINT]" - method: POST - body: "={{ JSON.stringify({ eventId: $json.id, status: 'processed' }) }}" - options: { timeout: 5000 } CONNECTIONS: Webhook接收器 -> 签名验证 -> 数据标准化 -> 数据库写入 -> 通知触发 ERROR HANDLING: - 签名验证失败: 在Function节点内抛出错误，连接至错误分支返回401状态码 - 数据库写入失败: 启用Postgres节点的retryOnFail（3次，间隔2秒），若仍失败则发送至错误队列（n8n-nodes-base.errorTrigger） - 通知触发失败: 不阻断主流程，记录错误日志并继续 SECURITY: - Webhook路径使用随机字符串（如/incoming/[RANDOM_TOKEN]） - 签名验证使用HMAC-SHA256，密钥存储于n8n环境变量 - 数据库凭据使用n8n的credentials管理，不硬编码 - 所有节点启用TLS加密传输 DEPLOYMENT: - 使用n8n的queue模式（Redis）处理高并发 - 将工作流导出为JSON，通过CI/CD管道部署 - 设置工作流超时（如30秒）防止挂起 - 监控节点执行日志，配置告警（如Slack通知）