The integration
layer for AI agents

Managed auth and 10,000+ tools across 3,000+ APIs, for the agents you’re building.

$ npm i @pipedream/sdk

Give your agent 10,000+ tools

agent.ts

// Point any MCP client at Pipedream's remote server
await client.connect({
  url: "https://remote.mcp.pipedream.net",
  headers: {
    "x-pd-external-user-id": "sarah@acme.com",
  },
})

// Your agent picks the tool — auth is already handled
await client.callTool({
  name: "slack-send-message",
  arguments: {
    channel: "#deploys",
    text: "Shipped :rocket:",
  },
})

Or call any API from code

server.ts

await pd.proxy.post({
  url: "https://slack.com/api/chat.postMessage",
  externalUserId: "sarah@acme.com",
  accountId: "apn_jhwl3Kz",
  body: {
    channel: "#deploys",
    text: "Shipped :rocket:",
  },
})

Join thousands of teams building on Pipedream

10,000+

Prebuilt tools & triggers

3,000+

Integrated APIs

1M+

Accounts connected

For developers

Connect

Integration infrastructure for building agents. Managed auth, 10,000+ prebuilt tools and triggers, and a raw proxy for everything else.

See how it works ↓

For companies · Early access

Conduit

A gateway that lets employees safely connect their apps to AI agents. SSO, access policies, per-user permissions, and a full audit trail — managed in one place.

Meet Conduit →

One integration layer

Everything between your agent and the API.

Your agent on one side, your users’ apps on the other — Connect runs everything in between.

Connect

Drop in Connect Link or build your own UI. Your users authorize their accounts, and Pipedream stores and refreshes the credentials.

Call

Use prebuilt tools, the raw API through the proxy, or MCP — fresh tokens are injected on every request, per user.

Ship

Launch a full integration catalog in days. Requests run in Pipedream's managed runtime — no OAuth apps to register, nothing to host or scale.

The toolkit

The end-to-end integration toolkit.Auth, tools, triggers, and raw API access.

MCP servers for your agents

Give your agent 10,000+ tools through one MCP endpoint. Use Pipedream's remote server for tool discovery and per-user auth.

Works with any MCP client
Tools run with each user's connected accounts
Tool discovery built in — agents find what they need

Your agent

Invoice the new Stripe customers from this week and post a summary in #finance

Running tools Ran 2 tools

stripe-list-customers Stripe

slack-send-message Slack

Done — 12 new customers invoiced, summary posted to #finance.

Invoice the new Stripe customers from this week and post a summary in #finance Ask your agent Auto

Managed auth for 3,000+ APIs

Pipedream runs the entire authorization flow: hosted OAuth clients, secure token storage, and automatic refresh. Your users connect their accounts in seconds — you never touch a credential.

Hosted connect flows with Connect Link — nothing to build
Bring your own OAuth clients when you want them
Credentials encrypted at rest, scoped per project

server.ts

// Send a hosted Connect Link URL —
// Pipedream handles the OAuth dance and refresh
const { connectLinkUrl } = await pd.tokens.create({
  externalUserId: "sarah@acme.com",
})
// → pipedream.com/_static/connect?token=ctok_…

// Or embed the flow with the browser SDK
pd.connectAccount({
  app: "slack",
  token,
  onSuccess: (account) => save(account.id),
})

Slack connected

sarah@acme.com · production

Approved

10,000+ prebuilt triggers and actions

Every integration ships with tools from Pipedream's public registry: actions that write to APIs, and triggers that stream events to your app in real time.

Run actions with per-user auth in a single call
Deploy triggers that webhook events to your app
All on GitHub — extend any tool or write your own

server.ts

// Events from your user's apps, in real time
await pd.triggers.deploy({
  id: "gmail-new-email-received",
  externalUserId: "sarah@acme.com",
  webhookUrl: "https://api.yourapp.com/events",
})

new-email Gmail · 2s ago

row-added Sheets · 1s ago

new-message Slack · delivering

A proxy for everything else

No prebuilt tool for the endpoint you need? Send any request to any of the 3,000+ APIs through the Connect proxy — Pipedream attaches your user's credentials and returns the response.

Any endpoint, any HTTP method
Auth headers injected automatically
Credentials never route through your servers

server.ts

await pd.proxy.post({
  url: "https://api.notion.com/v1/pages",
  externalUserId: "sarah@acme.com",
  accountId: "apn_V1hMoE7",
  body: {
    parent: { database_id: "..." },
    properties: {
      title: [{ text: { content: "Hi" } }],
    },
  },
})

Your agent

Invoice the new Stripe customers from this week and post a summary in #finance

Running tools Ran 2 tools

stripe-list-customers Stripe

slack-send-message Slack

Done — 12 new customers invoiced, summary posted to #finance.

Invoice the new Stripe customers from this week and post a summary in #finance Ask your agent Auto

server.ts

// Send a hosted Connect Link URL —
// Pipedream handles the OAuth dance and refresh
const { connectLinkUrl } = await pd.tokens.create({
  externalUserId: "sarah@acme.com",
})
// → pipedream.com/_static/connect?token=ctok_…

// Or embed the flow with the browser SDK
pd.connectAccount({
  app: "slack",
  token,
  onSuccess: (account) => save(account.id),
})

// Events from your user's apps, in real time
await pd.triggers.deploy({
  id: "gmail-new-email-received",
  externalUserId: "sarah@acme.com",
  webhookUrl: "https://api.yourapp.com/events",
})

await pd.proxy.post({
  url: "https://api.notion.com/v1/pages",
  externalUserId: "sarah@acme.com",
  accountId: "apn_V1hMoE7",
  body: {
    parent: { database_id: "..." },
    properties: {
      title: [{ text: { content: "Hi" } }],
    },
  },
})