in app/python/main.py [0:0]
def retrieve_data(fur, age, location):
filename = "/".join([fur, age, location]) + "/data.json"
storage_client = google.cloud.storage.Client()
processed_bucket = storage_client.get_bucket(PROCESSED_DATA_BUCKET)
blob = processed_bucket.blob(filename)
if not blob.exists():
logging.warning(
f"{PROCESSED_DATA_BUCKET} does not contain {filename}. "
"Has the job been run?"
)
return 0, []
fragment = blob.download_as_text()
data = json.loads(fragment)
squirrel_count = data.pop("_counter")
logging.info(f"Retrieved data for {squirrel_count} entities.")
# Ensure data values are returned ordered by key
data_points = list(dict(sorted(data.items())).values())
return squirrel_count, data_points