n8n与ChatGPT集成实战：从零搭建自动化工作流

3次阅读

没有评论

共计 2270 个字符，预计需要花费 6 分钟才能阅读完成。

n8n 是一款开源的自动化工作流工具，它通过可视化界面让开发者能够轻松连接不同的应用和服务。它的优势在于：

完全开源，可自行部署
支持超过 200 种应用和服务的集成
提供强大的工作流设计器
支持自定义 JavaScript 代码

ChatGPT 作为当前最先进的对话式 AI，在业务场景中有广泛应用：

自动客服系统
内容生成与摘要
数据分析与报告
代码辅助

优点：

响应速度快
完全控制请求流程

缺点：

需要自行处理错误重试
需要管理速率限制
上下文管理复杂

优点：

内置错误重试机制
可视化调试
集成上下文管理
简化认证流程

缺点：

有一定的性能开销
需要学习 n8n 的特定语法

以下是完整的 HTTP Request 节点参数配置：

{
  "url": "https://api.openai.com/v1/chat/completions",
  "method": "POST",
  "headers": {
    "Content-Type": "application/json",
    "Authorization": "Bearer {{YOUR_API_KEY}}"
  },
  "body": {
    "model": "gpt-3.5-turbo",
    "messages": [
      {
        "role": "user",
        "content": "{{input}}"
      }
    ],
    "temperature": 0.7
  },
  "json": true
}

处理 API 响应的完整 JavaScript 函数：

/**
 * 处理 ChatGPT API 响应
 * @param {Object} response - API 响应对象
 * @returns {Object} 处理后的结果
 */
function processResponse(response) {
  try {if (!response || !response.choices) {throw new Error('Invalid API response');
    }

    const result = {content: response.choices[0].message.content,
      usage: response.usage,
      timestamp: new Date().toISOString()
    };

    // 记录日志
    console.log(`ChatGPT response processed at ${result.timestamp}`);

    return result;
  } catch (error) {
    // 错误处理
    console.error('Error processing response:', error);

    // 返回错误信息
    return {
      error: error.message,
      stack: error.stack,
      timestamp: new Date().toISOString()
    };
  }
}

构建对话上下文的关键步骤：

初始化对话上下文数组
在每次交互时更新上下文
限制上下文长度以避免 token 超限

示例代码：

/**
 * 管理对话上下文
 */
class ConversationContext {constructor(maxTokens = 1000) {this.messages = [];
    this.maxTokens = maxTokens;
  }

  /**
   * 添加消息到上下文
   * @param {string} role - 角色（user/assistant）* @param {string} content - 消息内容
   */
  addMessage(role, content) {this.messages.push({ role, content});
    this.trimContext();}

  /**
   * 修剪上下文以符合 token 限制
   */
  trimContext() {
    // 简单实现：限制消息数量
    while (this.messages.length > 10) {this.messages.shift();
    }
  }

  /**
   * 获取当前上下文
   * @returns {Array} 消息数组
   */
  getContext() {return [...this.messages];
  }
}