Data Stores

Use Pipedream Data Stores to manage state throughout your workflows.

Integrate the Data Stores API with the Filter API

Setup the Data Stores API trigger to run a workflow which integrates with the Filter API. Pipedream's integration platform allows you to integrate Data Stores and Filter remarkably fast. Free for developers.

Add or update a single record with the Data Stores API

Add or update a single record in your Pipedream Data Store.

 
Try it
Continue execution if a condition Is met with the Filter API

Continue workflow execution only if a condition is met

 
Try it
Add or update multiple records with the Data Stores API

Add or update multiple records to your Pipedream Data Store.

 
Try it
End execution if a condition is met with the Filter API

End workflow execution if a condition is met

 
Try it
Append to record with the Data Stores API

Append to a record in your data store Pipedream Data Store. If the record does not exist, a new record will be created in an array format.

 
Try it

Overview of Data Stores

With the Data Stores API, you can build applications that:

  • Store data for later retrieval
  • Retrieve data from a store
  • Update data in a store
  • Delete data from a store

Connect Data Stores

1
2
3
4
5
6
7
8
9
10
11
export default defineComponent({
  props: {
    myDataStore: {
      type: "data_store",
    },
  },
  async run({ steps, $ }) {
    await this.myDataStore.set("key_here","Any serializable JSON as the value")
    return await this.myDataStore.get("key_here")
  },
})

Overview of Filter

The Filter API is a great way to build powerful workflows that can manipulate
and transform data. Here are some examples of what you can build using the
Filter API:

  • A workflow that transforms data from one format to another
  • A workflow that filters out data that does not meet certain criteria
  • A workflow that sorts data in a specific order
  • A workflow that calculates statistics or aggregates data
  • A workflow that combines data from multiple sources

Connect Filter

1
2
3
4
5
6
7
8
9
10
export default defineComponent({
  async run({ steps, $ }) {
    let condition = false
    if (condition == false) {
      $.flow.exit("Ending workflow early because the condition is false")
    } else {
        $.export("$summary", "Continuing workflow, since condition for ending was not met.")
    }
  },
})