with InfluxDB Cloud and Directus?
Emit new event when a new bucket is created. See the documentation
Emit new event when a new script is created. See the documentation
Emit new event when a new task is completed. See the documentation
Runs a script and returns the result. See the documentation
Updates an existing bucket in InfluxDB Cloud. See the documentation
Write data to a specific bucket in InfluxDB Cloud. See the documentation
Harness the power of InfluxDB Cloud API on Pipedream to build robust data workflows. InfluxDB Cloud, a time-series database, is ideal for managing high-velocity data and extracting insights in real-time. On Pipedream, you can easily trigger workflows based on InfluxDB data, automate data ingestion, and connect with countless other services to analyze, visualize, and act upon your data.
import { InfluxDB } from '@influxdata/influxdb-client';
import { HealthAPI } from '@influxdata/influxdb-client-apis';
export default defineComponent({
props: {
influxdb_cloud: {
type: "app",
app: "influxdb_cloud",
}
},
async run({steps, $}) {
// See the Node.js client docs at
// https://github.com/influxdata/influxdb-client-js
const influxDB = new InfluxDB(this.influxdb_cloud.$auth.url);
const healthAPI = new HealthAPI(influxDB)
// Execute a health check to test our credentials
return await healthAPI.getHealth()
},
})
Directus is an open-source headless CMS with a rich API that lets you manage content dynamically and distribute it across various channels. Harness Directus API on Pipedream to automate content operations, streamline workflows, and integrate with countless other apps. With real-time capabilities, you can trigger actions on content changes, automate publishing, sync with external databases, and more. Pipedream's serverless platform provides a powerful, flexible way to build custom automations using Directus, without writing complex infrastructural code.
import { axios } from "@pipedream/platform"
export default defineComponent({
props: {
directus: {
type: "app",
app: "directus",
}
},
async run({steps, $}) {
return await axios($, {
url: `${this.directus.$auth.api_host}/users/me`,
headers: {
Authorization: `Bearer ${this.directus.$auth.access_token}`,
},
})
},
})