Pipedream MCP 服务器

这是 Pipedream MCP 服务器的参考实现。您可以为超过 2,500 个应用和 API运行您自己的 MCP 服务器，该服务器由Pipedream Connect提供支持。

你可以：

• 使用npx @pipedream/mcp在本地运行服务器

• 自行托管服务器以便在您的应用程序或公司内使用它们

请访问mcp.pipedream.com和chat.pipedream.com查看服务器的运行情况

我们发布了此代码作为参考，以便您更好地了解如何使用 Pipedream Connect 开发此类应用程序。这项工作仍在进行中，且尚未提供完整的文档。如有任何疑问，请联系我们。

⭐ 功能

• 为超过 2,500 个应用程序和 API运行您自己的 MCP 服务器

• 在您自己的应用程序中为您的用户管理服务器。

• 通过工具连接账户、配置参数并发出 API 请求

• 完全管理的 OAuth 和凭证存储（ 参见安全文档）

Related MCP server: Integrations MCP

🚀 入门

Pipedream 的 MCP 服务器使用Pipedream Connect API来管理身份验证并发出 API 请求。要运行 MCP 服务器，您需要一个 Pipedream 项目和 Pipedream API 凭证。

1. 注册 Pipedream

2. 创建一个项目。所有通过 MCP 连接的账户都将存储在这里。

3. 创建 Pipedream OAuth 客户端

4. 设置环境变量（参见.env.example ）（直接在您的 shell 会话、点文件等中）：

PIPEDREAM_CLIENT_ID=your_client_id
PIPEDREAM_CLIENT_SECRET=your_client_secret
PIPEDREAM_PROJECT_ID=your_project_id
PIPEDREAM_PROJECT_ENVIRONMENT=development

Pipedream 概念理解

如果您的应用正在运行 MCP 服务器，您可能需要使用SSE 接口。SSE 服务器接受两个路由参数：

1. external_user_id — 这是您系统中用户的 ID，无论您使用什么来唯一标识他们。任何发送到该路由的请求都会与该最终用户关联，并使用 Pipedream 中针对该用户的授权存储。更多详情，请参阅文档。

2. app — 应用程序的“名称 slug”（应用程序的唯一标识符），可以在任何 Pipedream 应用程序的身份验证部分找到。例如， Slack的应用程序 slug 是slack 。

如果您的用户123想要连接到slack MCP 服务器，您的 MCP 客户端会向/123/slack路由发出请求。更多详细信息，请参阅下方的 SSE 文档。

服务器概述

有两种方法可以使用此 MCP 服务器。

1 - 应用专用/{external_user_id}/{app}该功能目前可在mcp.pipedream.com上获取。您可以为每个应用使用一个端点。该应用的所有可用工具都将在该端点上可用。

2 - 动态/{external_user_id}这是一个实验版本，因为它依赖于工具的动态更新能力。我们使用此服务器为chat.pipedream.com上的工具提供支持。

[!NOTE] 动态 MCP 服务器的代码在此 repo 中可用，但您还无法在本地运行它，因为它依赖于内部数据库。

如果您想自己运行它，请告诉我们。

托管您自己的服务器

使用Dockerfile

如果您已在本地安装了 Docker，则可以构建并运行容器：

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

这将在http://localhost:3010/:external_user_id/:app公开一个通用的 MCP 服务器。

发展

cp .env.example .env并填写您的开发项目的详细信息。

pnpm install

使用 Streamable HTTP Transport 启动服务器

pnpm dev:http

您可以使用可选的环境变量PD_SDK_DEBUG打印出发送到 Connect API 的所有请求和响应

PD_SDK_DEBUG=true pnpm dev:http

然后运行检查器：

npx @modelcontextprotocol/inspector

使用http://localhost:3010/v1/{external_user_id}/{app}进行可流式 HTTP 传输或http://localhost:3010/{external_user_id}/{app}进行 SSE 传输。

这些 URL 也可以被其他客户端（例如 Cursor）使用。

Stdio 传输设置

Stdio 仅通过 MCP Inspector 进行测试。

npx @modelcontextprotocol/inspector bun src/stdio.ts

查看日志以获取检查器 URL。

确保检查器的左侧与此相符：

然后按“列出工具”来获取 MCP 工具列表。

执照

Pipedream 源可用许可证版本 1.0 - 请参阅https://github.com/PipedreamHQ/pipedream/blob/master/LICENSE