Fivetran Webhooks -> dbt Cloud Run https://www.loom.com/share/4124fb01427c466797c5329783d7c848

main.py

import enum
import os
import time

# Be sure to `pip install requests` in your python environment
import requests

ACCOUNT_ID = 39
JOB_ID = 302

# Store your dbt Cloud API token securely in your workflow tool
API_KEY = '<put in your dbt Cloud API key here'


def _trigger_job() -> int:
    res = requests.post(
        url=f"https://emea.dbt.com/api/v2/accounts/{ACCOUNT_ID}/jobs/{JOB_ID}/run/",
        headers={'Authorization': f"Token {API_KEY}"},
        json={
            'cause': f"Triggered by Fivetran",
        }
    )

    response_payload = res.json()
    return response_payload['data']['id']



def run(request):
    job_run_id = _trigger_job()

    return(f"job_run_id = {job_run_id}")

  

register_fivetran_webook.ipynb

requirements.txt

requests==2.*