如何将文件上传到 Python 3 上的 Google 云存储？

Question

如何将文件从 Python 3 上传到 Google Cloud Storage？最终 Python 2，如果从 Python 3.

不可行

我看了又看，但没有找到真正有效的解决方案。我尝试了 boto，但是当我尝试通过 gsutil config -e 生成必要的 .boto 文件时，它一直说我需要通过 gcloud auth login 配置身份验证。然而，后者我已经做了很多次，但没有帮助。

Answer 1

使用标准 gcloud 库，它同时支持 Python 2 和 Python 3。

上传文件到云存储示例

from gcloud import storage
from oauth2client.service_account import ServiceAccountCredentials
import os


credentials_dict = {
    'type': 'service_account',
    'client_id': os.environ['BACKUP_CLIENT_ID'],
    'client_email': os.environ['BACKUP_CLIENT_EMAIL'],
    'private_key_id': os.environ['BACKUP_PRIVATE_KEY_ID'],
    'private_key': os.environ['BACKUP_PRIVATE_KEY'],
}
credentials = ServiceAccountCredentials.from_json_keyfile_dict(
    credentials_dict
)
client = storage.Client(credentials=credentials, project='myproject')
bucket = client.get_bucket('mybucket')
blob = bucket.blob('myfile')
blob.upload_from_filename('myfile')

Answer 2

将文件上传到 gcloud 存储桶的简单函数。

from google.cloud import storage
#pip install --upgrade google-cloud-storage. 
def upload_to_bucket(blob_name, path_to_file, bucket_name):
    """ Upload data to a bucket"""
     
    # Explicitly use service account credentials by specifying the private key
    # file.
    storage_client = storage.Client.from_service_account_json(
        'creds.json')

    #print(buckets = list(storage_client.list_buckets())

    bucket = storage_client.get_bucket(bucket_name)
    blob = bucket.blob(blob_name)
    blob.upload_from_filename(path_to_file)
    
    #returns a public url
    return blob.public_url

您可以使用此 link 生成凭据文件：https://cloud.google.com/storage/docs/reference/libraries?authuser=1#client-libraries-install-python

异步示例：

import asyncio
import aiohttp
# pip install aiofile
from aiofile import AIOFile
# pip install gcloud-aio-storage
from gcloud.aio.storage import Storage 

BUCKET_NAME = '<bucket_name>'
FILE_NAME  = 'requirements.txt'
async def async_upload_to_bucket(blob_name, file_obj, folder='uploads'):
    """ Upload csv files to bucket. """
    async with aiohttp.ClientSession() as session:
        storage = Storage(service_file='./creds.json', session=session) 
        status = await storage.upload(BUCKET_NAME, f'{folder}/{blob_name}', file_obj)
        #info of the uploaded file
        # print(status)
        return status['selfLink']
        

async def main():
    async with AIOFile(FILE_NAME, mode='r') as afp:
        f = await afp.read()
        url = await async_upload_to_bucket(FILE_NAME, f)
        print(url)


# Python 3.6
loop = asyncio.get_event_loop()
loop.run_until_complete(main())

# Python 3.7+
# asyncio.run(main())

Answer 3

导入 Google 云客户端库（需要 credentials）

from google.cloud import storage
import os
os.environ["GOOGLE_APPLICATION_CREDENTIALS"]="C:/Users/siva/Downloads/My First Project-e2d95d910f92.json"

实例化客户端

storage_client = storage.Client()

buckets = list(storage_client.list_buckets())

bucket = storage_client.get_bucket("ad_documents")//your bucket name

blob = bucket.blob('/chosen-path-to-object/{name-of-object}')
blob.upload_from_filename('D:/Download/02-06-53.pdf')
print(buckets)

Answer 4

安装 Google 云存储时 API:

pip install google-cloud

会抛出一个 ModuleNotFoundError:

    from google.cloud import storage
ModuleNotFoundError: No module named 'google'

确保按照 Cloud Storage Client Libraries Docs:

安装

pip install --upgrade google-cloud-storage

如何将文件上传到 Python 3 上的 Google 云存储？

How to upload a file to Google Cloud Storage on Python 3?

python

boto

python-3.x

google-cloud-storage

google-cloud-platform

上传文件到云存储示例