パイプドリームMCPサーバー

これはPipedream MCPサーバーのリファレンス実装です。Pipedream Connectを搭載しており、2,500以上のアプリとAPIに対応した独自のMCPサーバーを実行できます。

あなたはできる：

• npx @pipedream/mcpを使用してサーバーをローカルで実行する

• アプリ内や会社内で使用するためにサーバーを自分でホストする

mcp.pipedream.comおよびchat.pipedream.comでサーバーの動作をご覧ください。

このコードはリファレンスとして公開しましたので、Pipedream Connectをこのようなアプリケーションで使用する方法をより深くご理解いただけます。まだ開発中であり、完全なドキュメントは整備されていません。ご質問等ございましたら、お気軽にお問い合わせください。

⭐ 特徴

• 2,500 以上のアプリと APIに対応する独自の MCP サーバーを実行

• 独自のアプリでユーザーのサーバーを管理します。

• アカウントの接続、パラメータの設定、APIリクエストの送信はすべてツールを介して行います

• 完全に管理された OAuth および資格情報ストレージ ( セキュリティ ドキュメントを参照)

Related MCP server: Integrations MCP

🚀 はじめに

PipedreamのMCPサーバーは、認証管理とAPIリクエストの送信にPipedream Connect APIを使用します。MCPサーバーを実行するには、PipedreamプロジェクトとPipedream API認証情報が必要です。

1. Pipedreamに登録する

2. プロジェクトを作成します。MCP 経由で接続されたアカウントはすべてここに保存されます。

3. Pipedream OAuthクライアントを作成する

4. 環境変数を設定します ( .env.exampleを参照) (シェル セッション、ドット ファイルなどで直接)。

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サーバーは2つのルートパラメータを受け入れます。

1. external_user_id — システム内でのユーザーIDです。ユーザーを一意に識別するために使用するIDです。このルートへのリクエストはすべてエンドユーザーに紐付けられ、Pipedreamが保存する認証情報が使用されます。詳細はドキュメントをご覧ください。

2. app — アプリの「名前スラッグ」（アプリ固有の識別子）。Pipedreamアプリの認証セクションに表示されます。例えば、 Slackのアプリスラッグはslackです。

ユーザー123 slack MCPサーバーに接続したい場合、MCPクライアントは/123/slackルートにリクエストを送信します。詳細は、以下のSSEドキュメントをご覧ください。

サーバー概要

この MCP サーバーを使用するには 2 つの方法があります。

1 - アプリ固有の/{external_user_id}/{app}これは現在mcp.pipedream.comで利用可能です。アプリごとにエンドポイントを使用できます。そのエンドポイントでは、そのアプリで利用可能なすべてのツールを利用できます。

2 - 動的/{external_user_id}これはツールが動的に更新できることを前提としているため、実験的なバージョンです。chat.pipedream.comのツールは、このサーバーを使用して動作します。

[!NOTE] 動的 MCP サーバーのコードはこのリポジトリで入手できますが、内部データベースに依存しているため、まだローカルで実行することはできません。

これを自分で実行したい場合はお知らせください。

独自のサーバーをホストする

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

ストリーミング可能なHTTPトランスポートでサーバーを起動する

pnpm dev:http

オプションの環境変数PD_SDK_DEBUGを使用して、Connect APIに送信されるすべてのリクエストとレスポンスを出力できます。

PD_SDK_DEBUG=true pnpm dev:http

次にインスペクターを実行します。

npx @modelcontextprotocol/inspector

ストリーミング可能な HTTP トランスポートの場合はhttp://localhost:3010/v1/{external_user_id}/{app}を使用し、SSE トランスポートの場合はhttp://localhost:3010/{external_user_id}/{app}使用します。

これらの URL は他のクライアント (例: Cursor) でも使用できます。

Stdioトランスポートのセットアップ

Stdio は MCP Inspector でのみテストされています。

npx @modelcontextprotocol/inspector bun src/stdio.ts

インスペクター URL についてはログを参照してください。

インスペクターの左側がこれと一致していることを確認します。

次に、「List Tools」を押して、MCP ツールのリストを取得します。

ライセンス

Pipedream Source 利用可能なライセンス バージョン 1.0 - https://github.com/PipedreamHQ/pipedream/blob/master/LICENSEを参照してください