dbt Cloud

dbt is an intuitive, collaborative platform that lets you reliably transform data using SQL and Python code.

Integrate the dbt Cloud API with the Salesforce (REST API) API

Setup the dbt Cloud API trigger to run a workflow which integrates with the Salesforce (REST API) API. Pipedream's integration platform allows you to integrate dbt Cloud and Salesforce (REST API) remarkably fast. Free for developers.

Add Contact to Campaign with Salesforce (REST API) API on Job Run Completed (Instant) from dbt Cloud API
dbt Cloud + Salesforce (REST API)
 
Try it
Add Contact to Campaign with Salesforce (REST API) API on Job Run Errored (Instant) from dbt Cloud API
dbt Cloud + Salesforce (REST API)
 
Try it
Add Contact to Campaign with Salesforce (REST API) API on Job Run Started (Instant) from dbt Cloud API
dbt Cloud + Salesforce (REST API)
 
Try it
Add Contact to Campaign with Salesforce (REST API) API on New Job Run Event (Instant) from dbt Cloud API
dbt Cloud + Salesforce (REST API)
 
Try it
Add Lead to Campaign with Salesforce (REST API) API on Job Run Completed (Instant) from dbt Cloud API
dbt Cloud + Salesforce (REST API)
 
Try it
Job Run Completed (Instant) from the dbt Cloud API

Emit new event when a job run has completed.

 
Try it
Job Run Errored (Instant) from the dbt Cloud API

Emit new event when a job run has errored.

 
Try it
Job Run Started (Instant) from the dbt Cloud API

Emit new event when a job run has started.

 
Try it
New Job Run Event (Instant) from the dbt Cloud API

Emit new event when a job run has started, errored, or completed.

 
Try it
New Deleted Record (Instant, of Selectable Type) from the Salesforce (REST API) API

Emit new event immediately after a record of arbitrary object type (selected as an input parameter by the user) is deleted

 
Try it
Get Environment with the dbt Cloud API

Retrieve information about an environment. See the documentation

 
Try it
Add Contact to Campaign with the Salesforce (REST API) API

Adds an existing contact to an existing campaign. See Event SObject and Create Record

 
Try it
Get Run with the dbt Cloud API

Retrieve information about a run. See the documentation

 
Try it
Add Lead to Campaign with the Salesforce (REST API) API

Adds an existing lead to an existing campaign. See Event SObject and Create Record

 
Try it
Get Run Artifact with the dbt Cloud API

Retrieve information about a run artifact. See the documentation

 
Try it

Overview of dbt Cloud

The dbt Cloud API allows users to initiate jobs, check on their status, and interact with dbt Cloud programmatically. On Pipedream, you can harness this functionality to automate workflows, such as triggering dbt runs, monitoring your data transformation jobs, and integrating dbt Cloud with other data services. By leveraging Pipedream's serverless platform, you can create custom workflows that act on dbt Cloud events or use the dbt Cloud API to manage your data transformation processes seamlessly.

Connect dbt Cloud

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
import { axios } from "@pipedream/platform"
export default defineComponent({
  props: {
    dbt: {
      type: "app",
      app: "dbt",
    }
  },
  async run({steps, $}) {
    return await axios($, {
      url: `https://${this.dbt.$auth.region}.com/api/v3/accounts/`,
      headers: {
        "Authorization": `Token ${this.dbt.$auth.api_key}`,
        "Accept": `application/json`,
      },
    })
  },
})

Overview of Salesforce (REST API)

The Salesforce (REST API) provides a powerful platform for creating and managing customer relationships with a wide array of features like data manipulation, querying, and complex automation. With Pipedream's serverless execution, you can create workflows that automate your sales processes, sync data with other platforms, enhance customer engagement, and trigger actions based on specific events. Dive into Salesforce data, streamline lead management, track customer interactions, and push or pull data to or from Salesforce seamlessly.

Connect Salesforce (REST API)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
import { axios } from "@pipedream/platform"
export default defineComponent({
  props: {
    salesforce_rest_api: {
      type: "app",
      app: "salesforce_rest_api",
    }
  },
  async run({steps, $}) {
    return await axios($, {
      url: `${this.salesforce_rest_api.$auth.instancetype}/services/oauth2/userinfo`,
      headers: {
        Authorization: `Bearer ${this.salesforce_rest_api.$auth.oauth_access_token}`,
      },
    })
  },
})