in Runtime_env/app/utils/tracing.py [0:0]
def store_in_gcs(self, content: str, span_id: str) -> str:
"""
Initiate storing large content in Google Cloud Storage/
:param content: The content to store
:param span_id: The ID of the span
:return: The GCS URI of the stored content
"""
if not self.storage_client.bucket(self.bucket_name).exists():
logging.warning(
f"Bucket {self.bucket_name} not found. "
"Unable to store span attributes in GCS."
)
return "GCS bucket not found"
blob_name = f"spans/{span_id}.json"
blob = self.bucket.blob(blob_name)
blob.upload_from_string(content, "application/json")
return f"gs://{self.bucket_name}/{blob_name}"