MCP-сервер Pipedream

Это эталонная реализация сервера Pipedream MCP. Вы можете запустить свой собственный сервер MCP для более чем 2500 приложений и API , работающий на Pipedream Connect .

Ты можешь:

• Запустите серверы локально с помощью npx @pipedream/mcp

• Размещайте серверы самостоятельно , чтобы использовать их в своем приложении или компании.

Посмотрите на сервер в действии на mcp.pipedream.com и chat.pipedream.com

Мы опубликовали этот код в качестве справочного материала, чтобы вы могли лучше понять, как использовать Pipedream Connect для такого приложения. Это все еще находится в стадии разработки и не полностью документировано. Пожалуйста, свяжитесь с нами, если у вас есть какие-либо вопросы.

⭐ Особенности

• Запустите собственный сервер MCP для более чем 2500 приложений и API

• Управляйте серверами для своих пользователей в собственном приложении.

• Подключайте учетные записи, настраивайте параметры и делайте запросы API — все это с помощью инструментов

• Полностью управляемый OAuth и хранилище учетных данных ( см. документацию по безопасности )

Related MCP server: Integrations MCP

🚀 Начало работы

MCP-серверы Pipedream используют API Pipedream Connect для управления аутентификацией и выполнения запросов API. Для запуска MCP-сервера вам понадобятся проект Pipedream и учетные данные API Pipedream.

1. Подпишитесь на Pipedream

2. Создать проект . Здесь будут храниться все учетные записи, подключенные через MCP.

3. Создайте клиент Pipedream OAuth

4. Установите переменные окружения (см. .env.example ) (непосредственно в сеансе оболочки, dot-файлах и т. д.):

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

Непостижимые концепции для понимания

Если вы используете серверы MCP для своего приложения, вы, вероятно, захотите использовать интерфейс SSE . Сервер SSE принимает два параметра маршрута:

1. external_user_id — Это идентификатор вашего пользователя в вашей системе — то, что вы используете для его уникальной идентификации. Любые запросы, сделанные по этому маршруту, связаны с этим конечным пользователем и будут использовать хранилища Pipedream для аутентификации этого пользователя. Подробнее см. в документации .

2. app — «Имя слага» приложения (уникальный идентификатор приложения), который находится в разделе «Аутентификация» любого приложения Pipedream . Например, слаг приложения для Slack — slack .

Если ваш пользователь 123 хочет подключиться к серверу MCP slack , ваш клиент MCP сделает запрос к маршруту /123/slack . Подробнее см. в документации SSE ниже .

Обзор сервера

Есть два способа использования этого MCP-сервера.

1 - App Specific /{external_user_id}/{app} В настоящее время доступно на mcp.pipedream.com . Вы можете использовать конечную точку для каждого приложения. Все инструменты, доступные для этого приложения, будут доступны в этой конечной точке.

2 - Динамический /{external_user_id} Это экспериментальная версия, поскольку она полагается на инструменты, способные обновляться динамически. Мы используем этот сервер для питания инструментов на chat.pipedream.com .

[!ПРИМЕЧАНИЕ] Код для динамического сервера MCP доступен в этом репозитории, но вы пока не сможете запустить его локально, поскольку он использует внутреннюю базу данных.

Если вы хотите провести это самостоятельно, сообщите нам об этом.

Хостинг собственного сервера

Использование Dockerfile

Если у вас локально установлен Docker, вы можете собрать и запустить контейнер:

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

Это открывает доступ к универсальному серверу MCP по адресу http://localhost:3010/:external_user_id/:app .

Разработка

cp .env.example .env и заполните данные вашего проекта разработки.

pnpm install

Запустите сервер с потоковым HTTP-транспортом

pnpm dev:http

Вы можете использовать необязательную переменную окружения PD_SDK_DEBUG для вывода всех запросов и ответов, поступающих в API Connect.

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 Transport

Stdio тестировался только с MCP Inspector.

npx @modelcontextprotocol/inspector bun src/stdio.ts

URL-адрес инспектора смотрите в журналах.

Убедитесь, что левая сторона инспектора соответствует этому:

Затем нажмите «Список инструментов», чтобы получить список инструментов MCP.

Лицензия

Доступная лицензия Pipedream Source Version 1.0 — см. https://github.com/PipedreamHQ/pipedream/blob/master/LICENSE