Liran Galizyan : def handler(pd: “pipedream”):
from google.cloud import bigquery
import json
from datetime import datetime, timedelta
content = json.loads(pd.steps[“trigger”][“event”][“body”][“content”])[0][“body”][0][“results”]
campaign_id = content[0][“campaign”][“resourceName”].split(“/”, -1)[3]
leados_id = content[0][“campaign”][“resourceName”]
budget = content[0][“campaign”][“resourceName”]
bid_raw = content[0][“campaign”][“maximizeConversions”][“targetCpa”]
bid = bid_raw[:len(bid_raw) - 6]
account_id = content[0][“campaign”][“resourceName”].split(“/”, -1)[1]
current_date = datetime.now() + timedelta(days=-1)
yesterday_date = current_date.strftime(“%d/%m/%Y”)
start_end = ‘“”"’
body1 = “INSERT INTO lead-os.c_tmr_42069.bid_budget_test(campaign_id,leados_id,budget,bid) VALUES”
data = f”(campaign_id,leados_id,budget,bid)”
query_raw = start_end + body1 + data + start_end
print(query_raw)
GOOGLE_APPLICATION_CREDENTIALS={
“type”: “service_account”,
“project_id”: “lead-os”,
“private_key_id”: “b22adf2fe22f698f444887a5453d60aaf3176456",
“private_key”: “-----BEGIN PRIVATE KEY-----\nMIIEvQIBADANBge+eCVTH+pwUee3xIAIuexKUbhTl7FZ\n6Ii0oD7TFCDzFHaMVl/M5xg=\n-----END PRIVATE KEY-----\n”,
“client_email”: “lead-os-pipedream-service-acco@lead-os.iam.gserviceaccount.com”,
“client_id”: “105192752132652398886",
“auth_uri”: “https://accounts.google.com/o/oauth2/auth”,
“token_uri”: “https://oauth2.googleapis.com/token”,
“auth_provider_x509_cert_url”: “https://www.googleapis.com/oauth2/v1/certs”,
“client_x509_cert_url”: “https://www.googleapis.com/robot/v1/metadata/x509/lead-os-pipedream-service-acco%40lead-os.iam.gserviceaccount.com”
}
# Construct a BigQuery client object.
client = bigquery.Client()
query = query_raw
query_job = client.query(query) # Make an API request.