in optional-kubernetes-engine/bookshelf/storage.py [0:0]
def upload_file(file_stream, filename, content_type):
"""
Uploads a file to a given Cloud Storage bucket and returns the public url
to the new object.
"""
_check_extension(filename, current_app.config['ALLOWED_EXTENSIONS'])
filename = _safe_filename(filename)
client = _get_storage_client()
bucket = client.bucket(current_app.config['CLOUD_STORAGE_BUCKET'])
blob = bucket.blob(filename)
blob.upload_from_string(
file_stream,
content_type=content_type)
url = blob.public_url
if isinstance(url, six.binary_type):
url = url.decode('utf-8')
return url