Integrate the QStash API with the Formatting API

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

Popular Ways to Connect QStash with Formatting#

[Data] Convert JSON to String with Formatting API on New Topic Webhook from QStash API

QStash + Formatting

Try it

[Data] Parse JSON with Formatting API on New Topic Webhook from QStash API

QStash + Formatting

Try it

[Date/Time] Add/Subtract Time with Formatting API on New Topic Webhook from QStash API

QStash + Formatting

Try it

[Date/Time] Compare Dates with Formatting API on New Topic Webhook from QStash API

QStash + Formatting

Try it

[Date/Time] Format with Formatting API on New Topic Webhook from QStash API

QStash + Formatting

Try it

Popular QStash and Formatting Triggers#

New Topic Webhook from the QStash API

Emit new events on each new QStash topic message

Try it

Popular QStash and Formatting Actions#

Create Endpoint with the QStash API

Create a new HTTP endpoint on a QStash topic.

Try it

[Data] Convert JSON to String with the Formatting API

Convert an object to a JSON format string

Try it

Create Topic with the QStash API

Create a new QStash topic that emits to multiple endpoints.

Try it

[Data] Parse JSON with the Formatting API

Parse a JSON string

Try it

List Endpoints with the QStash API

Lists all your existing QStash endpoints.

Try it

Overview of QStash#

QStash API offers a secure, scalable, and simple way to manage message queues and defer tasks. Using this API, you can enqueue messages, schedule tasks to run after a delay, and ensure that tasks are executed exactly once, leveraging the power of serverless architecture. With Pipedream's ability to connect to a multitude of services, you can build complex workflows that trigger actions in other apps based on events in QStash, allowing you to automate cross-application business processes with ease.

Connect QStash#

import { axios } from '@pipedream/platform';


export default defineComponent({
  props: {
    qstash: {
      type: "app",
      app: "qstash",
    },
    callback_url: {
      type: "string",
      label: "Callback URL",
      description: "A URL that will be called by QStash with the body given",
    },
    delay: {
      type: "string",
      label: "Delay",
      default: 0,
      description: "Delay the HTTP request to the callback URL (seconds)"
    }
  },
  async run({steps, $}) {
    return axios($, {
      url: `https://qstash.upstash.io/v1/publish/${this.callback_url}`,
      method: 'POST',
      headers: {
        'Authorization': `Bearer ${this.qstash.auth.qstash_token}`,
        'Upstash-Delay': `${this.qstash.delay}s`
      },
      data: {
        hello: 'world'
      }
    });
  }
})

Connect Formatting#

export default defineComponent({
  async run({ steps, $ }) {
    const text = ' Hello world! ';
    return text.trim()
  },
})