with Langfuse and QStash?
Emit new event when user feedback (score) is submitted on a trace in Langfuse. See the documentation
Emit new event when a new trace is recorded in Langfuse. See the documentation
import { axios } from "@pipedream/platform"
export default defineComponent({
props: {
langfuse: {
type: "app",
app: "langfuse",
}
},
async run({steps, $}) {
return await axios($, {
url: `https://${this.langfuse.$auth.region}.langfuse.com/api/public/observations`,
auth: {
username: `${this.langfuse.$auth.public_key}`,
password: `${this.langfuse.$auth.secret_key}`,
},
})
},
})
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.
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: "integer",
label: "Delay",
description: "Delay the HTTP request to the callback URL (seconds)",
default: 0,
}
},
async run({steps, $}) {
return axios($, {
url: `https://qstash.upstash.io/v2/publish/${this.callback_url}`,
method: 'POST',
headers: {
'Authorization': `Bearer ${this.qstash.$auth.qstash_token}`,
'Upstash-Delay': `${this.delay}s`
},
data: {
hello: 'world'
}
});
}
})