infra-as-code/modules/audio-data-format-change/function-source-code/main.py (25 lines of code) (raw):

import functions_framework import os from lib import AudioFormatterRunner # Triggered by a change in a storage bucket @functions_framework.cloud_event def main(cloud_event): #Getting event data data = cloud_event.data #Getting variables project_id = os.environ.get('PROJECT_ID') raw_audio_bucket_id = data['bucket'] raw_audio_file_name = data['name'] formatted_audio_bucket_id = os.environ.get('FORMATTED_AUDIO_BUCKET_ID') metadata_bucket_id = os.environ.get('METADATA_BUCKET_ID') number_of_channels = os.environ.get('NUMBER_OF_CHANNELS') hash_key = os.environ.get('HASH_KEY') ingest_record_bucket_id = os.environ.get('INGEST_RECORD_BUCKET_ID') audio_formatter = AudioFormatterRunner ( project_id, raw_audio_bucket_id, raw_audio_file_name, formatted_audio_bucket_id, metadata_bucket_id, hash_key, ingest_record_bucket_id, number_of_channels ) audio_formatter.run_format()