Pipedream MCP Server MCP Server

About

## Pipedream MCP Server: Developer-First Workflow Automation The **Pipedream MCP Server** connects Google Antigravity to the code-first automation platform, enabling developers to build workflows with real code, trigger events, and integrate with APIs using familiar programming patterns. ### Why Pipedream MCP? - **Code-first** - Write real Node.js or Python in workflows - **Event sources** - Create custom event triggers - **HTTP triggers** - Instant webhook endpoints - **SQL querying** - Query workflow data with SQL - **Version control** - Git-based workflow management ### Key Features #### 1. Workflow Execution ```python # Trigger workflow result = await mcp.call("pipedream", "trigger_workflow", { "workflow_id": "p_xxx", "data": { "event": "new_order", "order_id": "ORD-12345" } }) print(f"Execution: {result[\"execution_id\"]}") # Get execution result execution = await mcp.call("pipedream", "get_execution", { "execution_id": result["execution_id"] }) ``` #### 2. Event Sources ```python # Create event source source = await mcp.call("pipedream", "create_source", { "name": "GitHub Issues", "app": "github", "component": "new-issue" }) # List events from source events = await mcp.call("pipedream", "list_events", { "source_id": source["id"], "limit": 10 }) ``` #### 3. HTTP Endpoints ```python # Get workflow endpoint endpoint = await mcp.call("pipedream", "get_endpoint", { "workflow_id": "p_xxx" }) print(f"URL: {endpoint[\"url\"]}") # Trigger via HTTP await mcp.call("pipedream", "http_trigger", { "url": endpoint["url"], "method": "POST", "data": {"action": "process"} }) ``` #### 4. Data Store ```python # Store data await mcp.call("pipedream", "set_data", { "key": "last_sync", "value": "2024-01-15T10:00:00Z" }) # Get data value = await mcp.call("pipedream", "get_data", { "key": "last_sync" }) ``` ### Configuration ```json { "mcpServers": { "pipedream": { "command": "npx", "args": ["-y", "@anthropic/mcp-pipedream"], "env": { "PIPEDREAM_API_KEY": "your-api-key" } } } } ``` ### Use Cases **API Integration**: Build integrations with real code, not just config. **Event Processing**: React to events from any connected source. **Webhook Endpoints**: Create instant API endpoints for workflows. **Data Pipelines**: Transform and route data between systems. The Pipedream MCP Server enables code-first workflow automation.

Installation

{
  "mcpServers": {
    "pipedream": {
      "mcpServers": {
        "pipedream": {
          "url": "https://mcp.pipedream.com",
          "type": "streamable-http"
        }
      }
    }
  }
}

How to Use

1. 12,500+ APIs
2. 2Workflow automation
3. 3Event triggers