with InfluxDB Cloud and SARE?
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
Add an email to SARE. Optionally, assign the subscriber to a group. See the documentation
Remove email from specified groups in SARE. See the documentation
Updates an existing 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()
},
})
The SARE API provides robust tools for email marketing and automation, enabling users to manage subscribers, send emails, and analyze campaigns directly via API. By leveraging SARE's features on Pipedream, you can automate workflows involving email operations, integrate with other platforms for enhanced data handling and customer engagement, and streamline communications in various marketing campaigns. This integration can particularly benefit marketers looking to automate responses based on subscriber behavior or integrate email marketing metrics with other business tools.
import { axios } from "@pipedream/platform"
export default defineComponent({
props: {
sare: {
type: "app",
app: "sare",
}
},
async run({steps, $}) {
return await axios($, {
url: `https://s.enewsletter.pl/api/v1/${this.sare.$auth.uid}/email/props`,
headers: {
"ApiKey": `${this.sare.$auth.api_key}`,
},
})
},
})