Parse PubSub

main.py

import base64
import json
import googleapiclient.discovery
import string
import time

def process_log_entry(data, context):
    #base64 decode the data field
    data_buffer = base64.b64decode(data['data'])
    #Load JSON so we can parse it
    log_entry = json.loads(data_buffer)
    
    # Get Firewall Name by Parsing Log
    firewall_name = log_entry['jsonPayload']['resource']['name']
    # Get Project ID by Parsing Log
    project_id = log_entry['resource']['labels']['project_id']