pipedream-workflows

Overview

Pipedream is a serverless integration and compute platform. It lets you build event-driven workflows with Node.js code steps, 1000+ pre-built app actions, and HTTP triggers — all running on serverless infrastructure.

Capabilities

• Build workflows with HTTP, cron, or app event triggers
• Write Node.js code steps with full npm access
• Use 1000+ pre-built app actions
• Store data in built-in Data Stores
• Make HTTP requests to any API
• Deploy as REST API endpoints
• Use connected accounts for OAuth apps

When to Use

Trigger phrases:

• "pipedream workflows"

• "Building event-driven automation with custom code"

• "Needing serverless compute for integration logic"

• "Wanting npm package access in automation workflows"

• Building event-driven automation with custom code

• Needing serverless compute for integration logic

• Wanting npm package access in automation workflows

• Building webhook receivers and API endpoints

• Replacing custom scripts with managed workflows

When NOT to Use

• Task is simple enough for Zapier (use Zapier for no-code)
• You need complex workflow orchestration (use n8n)
• Task is about data storage, not workflow automation
• You don't have API access to the services being integrated
• Task requires real-time processing (use streaming tools)
• You need to build a custom application (use development tools)

Pseudo Code

Implementation patterns for common use cases with this skill.

Workflow Structure

Trigger → Code Step → HTTP Request → IF → Pre-built Action → Code Step

Trigger Types

Code Step (Node.js)

// Access previous step data
const prevData = $.steps.trigger.event;

// Use npm packages
const axios = require('axios');
const _ = require('lodash');

// Make HTTP request
const response = await axios.get('https://api.example.com/data', {
  headers: { Authorization: `Bearer ${$.auth.api_key}` },
});

// Process data
const filtered = _.filter(response.data, item => item.active);

// Return data to next step
return {
  count: filtered.length,
  items: filtered,
};