MCP 服务器

Pipedream

运行您自己的 MCP 服务器，支持超过 2,500 个应用程序和 API。 * 运行您自己的 MCP 服务器，支持超过 2,500 个 API * 在您自己的应用程序中，管理您用户的服务器。 * 通过工具连接账户、配置参数并发出 API 请求。 * 完全托管的 OAuth 和凭证存储。

README

Pipedream 是一个面向开发者的集成平台。

Pipedream 提供了一个免费的托管平台，用于连接应用程序和开发事件驱动的自动化。该平台拥有 1,000 多个完全集成的应用程序，因此您可以使用预构建的组件快速向 Slack 发送消息、向 Google Sheets 添加新行等等。您还可以在需要自定义逻辑时运行任何 Node.js、Python、Golang 或 Bash 代码。Pipedream 已通过 SOC 2 合规性验证，并可根据要求提供 SOC 2 Type 2 报告（请发送电子邮件至 support@pipedream.com）。

此仓库包含：

所有预构建集成组件的代码
产品路线图
Pipedream 文档
以及与 Pipedream 相关的其他源代码。

此 README 解释了平台的主要功能以及如何开始使用。

要获得支持，请访问 https://pipedream.com/support。

主要功能

工作流 - 工作流运行自动化。工作流是步骤的序列 - 预构建的操作或自定义 Node.js、Python、Golang 或 Bash 代码 - 由事件触发（HTTP 请求、计时器、向 Google Sheets 添加新行等等）。
事件源 - 源触发工作流。它们从 GitHub、Slack、Airtable、RSS 和更多服务发出事件。当您希望在任何第三方应用程序中发生事件时运行工作流时，您正在使用事件源。
操作 - 操作是预构建的代码步骤，您可以在工作流中使用它们来执行 Pipedream 的 1,000 多个 API 集成中的常见操作。例如，您可以使用操作发送电子邮件、向 Google Sheet 添加行等等。
自定义代码 - 大多数集成都需要自定义逻辑。代码通常是表达该逻辑的最佳方式，因此 Pipedream 允许您运行任何 Node.js、Python、Golang 或 Bash 代码。您可以从语言的包管理器导入任何包，连接到任何 Pipedream 连接的应用程序等等。Pipedream 以最佳方式实现“低代码”：您可以在执行常见操作时使用预构建的组件，但在需要时可以编写自定义代码。
目标 - 将事件异步传递到常见的目标，如 Amazon S3、Snowflake、HTTP 和电子邮件。
免费 - 个人开发者无需付费（请参阅限制）

演示

单击下面的图像以在 YouTube 上观看简短的演示。

工作流

工作流是由事件（如 HTTP 请求或向 Google Sheet 添加新行）触发的线性步骤序列。您可以使用工作流快速开发复杂的自动化，并连接到我们的 1,000 多个集成应用程序中的任何一个。

请参阅我们的工作流快速入门以开始使用。

事件源

事件源监视来自 GitHub、Slack、Airtable、RSS 和更多服务的新数据。当源找到新事件时，它会发出该事件，从而触发任何链接的工作流。

您还可以使用 Pipedream 的 REST API 或私有的实时 SSE 流来使用源发出的事件。

当不存在适合您用例的预构建源时，您可以构建自己的源。这是最简单的事件源：它公开了一个 HTTP 端点，您可以向其发送任何请求，并在调用时打印请求的内容：

export default {
  name: "http",
  version: "0.0.1",
  props: {
    http: "$.interface.http",
  },
  run(event) {
    console.log(event); // event contains the method, payload, etc.
  },
};

您可以在 components 目录中找到所有预构建源的代码。如果您发现错误或想要贡献功能，请参阅我们的贡献指南。

操作

操作是预构建的代码步骤，您可以在工作流中使用它们来执行 Pipedream 的 500 多个 API 集成中的常见操作。例如，您可以使用操作发送电子邮件、向 Google Sheet 添加行等等。

您可以创建自己的操作，您可以在工作流中重复使用这些操作。您还可以将操作发布到整个 Pipedream 社区，使它们可供任何人使用。

这是一个接受 name 作为输入并将其打印到工作流日志的操作：

export default {
  name: "Action Demo",
  description: "This is a demo action",
  key: "action_demo",
  version: "0.0.1",
  type: "action",
  props: {
    name: {
      type: "string",
      label: "Name",
    },
  },
  async run() {
    return `hello ${this.name}!`;
  },
};

您可以在 components 目录中找到所有预构建操作的代码。如果您发现错误或想要贡献功能，请参阅我们的贡献指南。

自定义代码

大多数集成都需要自定义逻辑。代码通常是表达该逻辑的最佳方式，因此 Pipedream 允许您使用以下方式在工作流中运行自定义代码：

您可以通过直接在代码中声明导入来从语言的包管理器导入任何包。Pipedream 将解析并下载必要的依赖项。

// Node.js
import axios from "axios";

# Python
import pandas as pd

// Go
import (
    "fmt"
    pd "github.com/PipedreamHQ/pipedream-go"
)

您还可以在自定义代码步骤中连接到任何 Pipedream 连接的应用程序。例如，您可以连接您的 Slack 帐户并向频道发送消息：

import { WebClient } from "@slack/web-api";

export default defineComponent({
  props: {
    // This creates a connection called "slack" that connects a Slack account.
    slack: {
      type: "app",
      app: "slack",
    },
  },
  async run({ steps, $ }) {
    const web = new WebClient(this.slack.$auth.oauth_access_token);

    return await web.chat.postMessage({
      text: "Hello, world!",
      channel: "#general",
    });
  },
});

目标

目标（如操作）抽象了将事件发送到 Amazon S3 等服务或 HTTP 和电子邮件等目标所需的连接、批处理和传递逻辑。

例如，将数据发送到 Amazon S3 存储桶就像调用 $send.s3() 一样简单：

$send.s3({
  bucket: "your-bucket-here",
  prefix: "your-prefix/",
  payload: event.body,
});

Pipedream 支持以下目标：

贡献者

感谢所有为 Pipedream 代码库做出贡献的人。我们感谢您！

定价

Pipedream 具有慷慨的免费层级。您可以在免费层级的限制范围内免费运行源和工作流。如果您达到这些限制，您可以升级到我们的付费层级之一。

限制

Pipedream 平台对源和工作流施加了一些运行时限制。在我们的文档中阅读有关这些限制的更多信息。

发现错误？有功能建议？

在添加问题之前，请搜索现有问题或联系我们的团队，以查看是否已存在类似请求。

如果存在问题，请添加反应或添加评论，详细说明您的特定用例。

如果问题_尚不存在_并且您需要创建一个问题，请使用问题模板。

安全

您可以在此处阅读有关我们平台安全和隐私的信息。

如果您想报告可疑的漏洞或安全问题，或者对产品的安全性有任何疑问，请通过 security@pipedream.com 联系我们的安全团队。

Pipedream

README

主要功能

演示

工作流

事件源

操作

自定义代码

目标

贡献者

定价

限制

发现错误？有功能建议？

安全

推荐服务器