Pipedream

Pipedream is a low-code agent building and workflow automation platform that lets you connect APIs, automate workflows, and build event-driven applications. The Airweave integration provides a set of actions that enable you to search your synced data to retrieve relevant context, manage your collections, and trigger syncs from any Pipedream workflow, agent or automation.

Prerequisites

Before you start you’ll need:

• A Pipedream account: Sign up at pipedream.com
• A collection with data: At least one source connection must have completed its initial sync. See the Quickstart if you need to set this up.
• An API key: Create one in the Airweave dashboard under API Keys.

Connecting Airweave to Pipedream

1. Open Pipedream and create a new workflow
2. Add an Airweave action step
3. Click Connect Account when prompted
4. Enter your Airweave API key
5. Optionally specify a custom base URL if you’re using a self-hosted Airweave instance

Available Actions

The Airweave integration provides the following actions:

Search Collection

Search across all data sources within a collection using semantic and keyword search.

List Collections

Get all collections in your organization.

Get Collection

Retrieve details of a specific collection by its readable ID.

Create Collection

Create a new collection to group data sources.

Delete Collection

Permanently remove a collection and all associated data. This action cannot be undone.

List Sources

Get all available data source connectors that Airweave can connect to (e.g., GitHub, Slack, Google Drive, PostgreSQL).

No parameters required.

Trigger Source Connection Sync

Manually trigger a data sync for a source connection. The sync runs asynchronously and returns immediately with job details.

Example Workflows

Slack Q&A Bot

Build a Slack bot that answers questions using your organization’s data:

1. Trigger: Slack - New Slash Command
2. Action: Airweave - Search Collection (with responseType: "completion")
3. Action: Slack - Reply to Command

Support Ticket Enrichment

Automatically enrich support tickets with relevant documentation:

1. Trigger: Zendesk - New Ticket
2. Action: Airweave - Search Collection (search ticket content)
3. Action: Zendesk - Add Internal Note (with search results)

Scheduled Data Sync

Keep your Airweave data fresh with scheduled syncs:

1. Trigger: Schedule - Every hour
2. Action: Airweave - Trigger Source Connection Sync

GitHub Issue Assistant

Auto-comment on GitHub issues with relevant code references:

1. Trigger: GitHub - New Issue
2. Action: Airweave - Search Collection (search issue title and body)
3. Action: GitHub - Create Comment (with relevant code context)

Using with Code Steps

You can also use the Airweave app programmatically in Pipedream code steps:

1
import { axios } from "@pipedream/platform";
2
3
export default defineComponent({
4
  props: {
5
    airweave: {
6
      type: "app",
7
      app: "airweave",
8
    },
9
  },
10
  async run({ steps, $ }) {
11
    const response = await axios($, {
12
      url: `${this.airweave.$auth.base_url || "https://api.airweave.ai"}/collections/my-collection/search`,
13
      method: "POST",
14
      headers: {
15
        "Authorization": `Bearer ${this.airweave.$auth.api_key}`,
16
        "Content-Type": "application/json",
17
      },
18
      data: {
19
        query: "quarterly revenue report",
20
        limit: 10,
21
        response_type: "results",
22
      },
23
    });
24
    return response;
25
  },
26
});

Self-Hosted Instances

If you’re running a self-hosted Airweave instance, specify your custom base URL when connecting your Airweave account in Pipedream. The base URL field accepts any valid URL (e.g., https://airweave.your-company.com).

Learn More

• Pipedream Documentation
• Airweave on Pipedream
• Airweave API Reference
• Airweave GitHub