Pipedream MCP：连接AI助手与数千个API的自动化工具

Pipedream MCP 是一个开源的自动化工具，核心功能是通过 Model Context Protocol（MCP）连接 AI 助手与超过 2700 个应用程序和 API。它帮助开发者快速构建自动化工作流，支持生产环境开箱即用。用户可以直接使用 Pipedream 托管的 MCP 服务器，也可以在自己的应用中部署服务器。平台提供超过 10,000 个预构建工具，覆盖 Slack、GitHub、Google Sheets 等多种服务，简化了 API 集成和认证管理。Pipedream MCP 支持动态工具发现，允许根据用户需求实时加载工具。它还提供安全的 OAuth 认证和凭据存储，适合开发者构建高效的 AI 驱动应用。代码托管在 GitHub，开发者可以自由探索和定制。

功能列表

• 连接超过 2700 个应用程序和 API，支持 Slack、GitHub、Notion 等。
• 提供 10,000 多个预构建工具，覆盖消息发送、数据处理、代码部署等功能。
• 支持动态工具发现，根据用户指令自动加载所需工具。
• 集成 Pipedream Connect API，管理 OAuth 认证和 API 请求。
• 支持在本地或云端部署 MCP 服务器，灵活适配开发者需求。
• 提供 SSE（Server-Sent Events）和 HTTP 传输方式，简化工具调用。
• 允许运行 Node.js、Python、Golang 和 Bash 代码，满足自定义逻辑需求。
• 支持子代理模式，简化复杂工具配置，自动处理动态属性。

使用帮助

安装与部署

Pipedream MCP 的安装和部署分为两种方式：使用 Pipedream 托管的服务器或在本地/云端自建服务器。以下是详细步骤：

使用托管服务器

1. 访问 https://mcp.pipedream.com，无需额外安装即可使用。
2. 创建 Pipedream 项目：
   • 登录 Pipedream 官网，点击“Create Project”生成项目。
   • 获取 PIPEDREAM_CLIENT_ID、PIPEDREAM_CLIENT_SECRET 和 PIPEDREAM_PROJECT_ID。
3. 使用 MCP Inspector 测试工具：
   • 打开 MCP Inspector，输入项目凭据。
   • 点击“List Tools”查看可用工具列表。
4. 连接应用：
   • 在服务器路径 /external_user_id/app（如 /123/slack）中，输入用户 ID 和应用名称（如 Slack）。
   • 服务器返回连接 URL，用户完成 OAuth 认证后即可调用工具。

自建服务器

1. 克隆代码库：

   git clone https://github.com/PipedreamHQ/pipedream
   cd pipedream/modelcontextprotocol
   

2. 安装依赖：

   pnpm install
   

3. 配置环境变量：
   • 复制 .env.example 文件为 .env。
   • 在 .env 中填入 PIPEDREAM_CLIENT_ID、PIPEDREAM_CLIENT_SECRET 和 PIPEDREAM_PROJECT_ID。
   • 可选：设置 PD_SDK_DEBUG=true 打印 API 请求和响应日志。
4. 启动服务器：

   pnpm dev:http
   

   服务器将在 http://localhost:3010/:external_user_id/:app 运行。

5. 使用 Docker 部署（可选）：

   docker build -t pipedream-connect .
   docker run -d --name pd-mcp -p 3010:3010 --env-file .env pipedream-connect:latest
   

功能操作流程

连接 API 和工具调用

Pipedream MCP 的核心是连接 AI 助手与外部 API。以下是操作步骤：

1. 选择应用：在 mcp.pipedream.com 或自建服务器中，指定目标应用（如 slack、github）。
2. 认证账户：通过服务器提供的 URL 完成 OAuth 认证，绑定用户账户。
3. 调用工具：使用指令调用工具。例如，发送 Slack 消息：
   • 输入指令：Send a message to #general channel in Slack。
   • 服务器自动解析指令，调用 Slack API 的 chat.postMessage 工具。
4. 动态工具发现：若需要新工具，MCP 服务器会根据指令动态加载。例如，查询 GitHub 仓库时，服务器自动提供 search_repos 工具。

子代理模式

子代理模式简化了复杂工具的配置：

1. 工具以单一指令输入，如 instruction: Add a row to Google Sheets with data: name=John, age=30。
2. MCP 服务器调用内部 LLM 处理指令，自动配置参数并执行。
3. 用户无需手动设置动态属性，适合快速开发。

自定义代码

开发者可以运行自定义代码：

1. 在 Pipedream 工作流中添加代码步骤。
2. 支持 Node.js、Python、Golang 或 Bash。例如，Node.js 代码：

   const slack = require('@pipedreamhq/slack');
   await slack.sendMessage({ channel: '#general', text: 'Hello from MCP!' });
   

3. 保存并运行工作流，代码将通过 MCP 服务器执行。

调试与监控

• 使用 PD_SDK_DEBUG=true 查看 API 请求日志。
• 通过 MCP Inspector 检查工具调用状态，确保正确执行。
• 访问 chat.pipedream.com 查看生产环境中的示例应用。

注意事项

• 确保环境变量安全存储，避免泄露 API 凭据。
• 自建服务器需实现 OAuth 认证，保护用户数据。
• 托管服务器免费，但子代理模式可能产生 LLM 费用（测试阶段免费）。

应用场景

1. 生产力自动化
   • 开发者通过 MCP 连接 Google Calendar 和 Gmail，自动安排会议并发送通知邮件。例如，AI 助手根据日程表空闲时间创建会议，并通过 Gmail 通知与会者。
2. 数据分析
   • 数据分析师使用 MCP 连接 Google Sheets，自动查询和更新表格数据。例如，AI 助手提取销售数据，生成报表并存入指定表格。
3. 客户支持
   • 企业通过 MCP 连接 Slack 和 CRM 系统，自动回复客户询问并更新 CRM 记录。例如，AI 助手在 Slack 中回答常见问题，并将新票据记录到 HubSpot。
4. 开发者工作流
   • 开发者使用 MCP 连接 GitHub，自动创建问题或审查代码。例如，AI 助手根据提交信息生成 GitHub Issue，或运行代码审查工具。

QA

1. Pipedream MCP 是否免费？
   • Pipedream 托管的 MCP 服务器对个人开发者免费，但有使用限制。自建服务器无费用，需自行承担托管成本。
2. 如何添加新工具？
   • 在 Pipedream 工作空间中发布自定义工具，上传至公共注册表。服务器会自动加载新工具，或通过动态发现加载。
3. 支持哪些编程语言？
   • 支持 Node.js、Python、Golang 和 Bash，可导入相应语言的包，满足自定义需求。
4. 如何保护用户数据？
   • Pipedream MCP 使用隔离的凭据存储和 OAuth 认证，确保用户数据安全。自建服务器需自行实现 OAuth。