Skip to content

Instantly share code, notes, and snippets.

@jster1357
jster1357 / main.tf
Created June 1, 2022 19:43
Data Fusion Terraform Instance Creation - no shared vpc
resource "google_data_fusion_instance" "create_instance" {
name = var.instance_name
description = var.description
region = var.region
type = var.cdf_version
enable_stackdriver_logging = true
enable_stackdriver_monitoring = true
labels = {
instance_owner = var.instance_owner
}
@jster1357
jster1357 / gcs_cdf_trigger_function.py
Last active July 13, 2021 20:22
Google GCS cloud function trigger for data fusion pipeline
from google.cloud import pubsub_v1
import subprocess
import requests
import json
import os
import time
# get the access token for the API call
def get_access_token():