Pipedream is an integration platform for developers.

Pipedream provides a free, hosted platform for connecting apps and developing event-driven automations. The platform has over 1,000 fully-integrated applications, so you can use pre-built components to quickly send messages to Slack, add a new row to Google Sheets, and more. You can also run any Node.js, Python, Golang, or Bash code when you need custom logic. Pipedream has demonstrated SOC 2 compliance and can provide a SOC 2 Type 2 report upon request (please email[email protected]).

This repo contains:

• The code for all pre-built integration components
• The product roadmap
• The Pipedream docs
• And other source code related to Pipedream.

ThisREADMEexplains the key features of the platform and how to get started.

To get support, please visithttps://pipedream.com/support.

Key Features

• Workflows- Workflows run automations. Workflows are sequences of steps - pre-built actions or customNode.js,Python,Golang,orBashcode - triggered by an event (HTTP request, timer, when a new row is added to a Google Sheets, and more).
• Event Sources- Sources trigger workflows. They emit events from services like GitHub, Slack, Airtable, RSS andmore.When you want to run a workflow when an event happens in any third-party app, you're using an event source.
• Actions- Actions are pre-built code steps that you can use in a workflow to perform common operations across Pipedream's 1,000+ API integrations. For example, you can use actions to send email, add a row to a Google Sheet,and more.
• Custom code- Most integrations require custom logic. Code is often the best way to express that logic, so Pipedream allows you to run anyNode.js,Python,Golang,orBashcode. You can import any package from the languages' package managers, connect to any Pipedream connected app, and more. Pipedream is "low-code" in the best way: you can use pre-built components when you're performing common actions, but you can write custom code when you need to.
• Destinations- Deliver events asynchronously to common destinations like Amazon S3, Snowflake, HTTP and email.
• Free- No fees for individual developers (seelimits)

Demo

Click the image below to watch a brief demo on YouTube.

Workflows

Workflows are sequences of linearstepstriggered by an event (like an HTTP request, or when a new row is added to a Google sheet). You can quickly develop complex automations using workflows and connect to any of our 1,000+ integrated apps.

See our workflow quickstartto get started.

Event Sources

Event Sourceswatch for new data from services like GitHub, Slack, Airtable, RSS andmore.When a source finds a new event, it emits it, triggering any linked workflows.

You can also consume events emitted by sources usingPipedream's REST APIor a private, real-timeSSE stream.

When a pre-built source doesn't exist for your use case,you can build your own.Here is the simplest event source: it exposes an HTTP endpoint you can send any request to, and prints the contents of the request when invoked:

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

You can find the code for all pre-built sources inthecomponentsdirectory.If you find a bug or want to contribute a feature,see our contribution guide.

Actions

Actionsare pre-built code steps that you can use in a workflow to perform common operations across Pipedream's 500+ API integrations. For example, you can use actions to send email, add a row to a Google Sheet,and more.

You cancreate your own actions,which you can re-use across workflows. You can alsopublish actions to the entire Pipedream community,making them available for anyone to use.

Here's an action that accepts anameas input and prints it to the workflow's logs:

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

You can find the code for all pre-built actions inthecomponentsdirectory.If you find a bug or want to contribute a feature,see our contribution guide.

Custom code

Most integrations require custom logic. Code is often the best way to express that logic, so Pipedream allows you to run custom code in a workflow using:

You can import any package from the languages' package managers by declaring the imports directly in code. Pipedream will parse and download the necessary dependencies.

// Node.js
importaxiosfrom"axios";

# Python
importpandasaspd

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

You can alsoconnect to any Pipedream connected app in custom code steps.For example, you can connect your Slack account and send a message to a channel:

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

exportdefaultdefineComponent({
props:{
// This creates a connection called "slack" that connects a Slack account.
slack:{
type:"app",
app:"slack",
},
},
asyncrun({steps,$}){
constweb=newWebClient(this.slack.$auth.oauth_access_token);

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

Destinations

Destinations,like actions, abstract the connection, batching, and delivery logic required to send events to services like Amazon S3, or targets like HTTP and email.

For example, sending data to an Amazon S3 bucket is as simple as calling$send.s3():

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

Pipedream supports the following destinations:

• Amazon S3
• Snowflake
• HTTP
• Email
• SSE

Contributors

Thank you to everyone who has contributed to the Pipedream codebase. We appreciate you!

Pricing

Pipedream has agenerous free tier.You can run sources and workflows for free within the limits of the free tier. If you hit these limits, you can upgrade to one of ourpaid tiers.

Limits

The Pipedream platform imposes some runtime limits on sources and workflows.Read more about those in our docs.

Found a Bug? Have a Feature to suggest?

Before adding an issue, please search theexisting issuesorreach out to our teamto see if a similar request already exists.

If an issue exists, pleaseadd a reactionor add a comment detailing your specific use case.

If an issuedoesn'tyet exist and you need to create one, pleaseuse the issue templates.

Security

You can read about our platform security and privacyhere.

If you'd like to report a suspected vulnerability or security issue, or have any questions about the security of the product, please contact our security team at[email protected].