从Google驱动器到Google Cloud Storage，一次上传多个文件

Question

我的目标是在Google驱动器中识别一些文件，并将它们顺序上传到Google存储存储桶中。我正在使用Google的“云功能”来执行此操作，并已经进行了测试以确认连接正常工作。

我似乎与我如何获取文件的名称有关的问题 - 它正在返回“无类型”值。请在下面查看我的代码

    import os.path
    from google.auth.transport.requests import Request
    from google.oauth2.credentials import Credentials
    from google_auth_oauthlib.flow import InstalledAppFlow
    from googleapiclient.discovery import build
    from googleapiclient.errors import HttpError
    from google.cloud import storage
    import io
    from googleapiclient import discovery
    from pandas.io.json import json_normalize
    import google.auth
    import re
    import logging
    
    # Confirming Oauth for Drive API# 
    SCOPES = [ 'https://www.googleapis.com/auth/drive']
    creds, project = google.auth.default(scopes=SCOPES)
    service = build('drive', 'v3', credentials=creds)
    
    # Confirming Oauth #
    storage_client = storage.Client()
    ## target Bucket #
    bucket_name = 'my-bucket'
    bucket = storage_client.bucket(bucket_name)

    get_bucket = storage_client.get_bucket(bucket_name)
    team_drive_loc = 
    'https://drive.google.com/drive/u/0/folders/xxxxxxxxxxx'
    team_drive_parent_folder ='xxxxxxxxxxxxxxxxxA'
    #bucket = storage_client.bucket(bucket_name)
    
    
    query= "name contains 'Customer' and name contains '2022'    "
    drive_files = service.files().list(q= query,
                                 driveId =team_drive_parent_folder,
                                 supportsAllDrives= True,
                                 includeItemsFromAllDrives= True,
                                 corpora ='drive',fields="files(id,name)").execute()

    for file in drive_files:

            source_file_name =service.get(fileId=fileId, fields="files(name)").execute()["files(name)"]
            bucket = storage_client.get_bucket(bucket_name)
            blob = bucket.blob("incoming/iri/IRI_Updates/Ongoing_Sales_Data/2022/" + 
            source_file_name)
            blob.upload_from_filename(source_file_name)
            logging.info('Uploaded {} ...'.format(source_file_name))

...这是我遇到的错误。如果有人可以帮助我正确地源源并上传到GCS存储桶，那将是

/[post] trackback上的例外很棒的exceptions（最新呼叫最后一个）：文件“/layers/google.python.pip/pip/pip/pip/pip /lib/python3.7/site-packages/flask/app.py”，第2073行，在WSGI_APP响应中-packages/flask/app.py”，第1518行，在full_dispatch_request rv = self.handle_user_expection（e）文件“/layers/google.python.pip/pip/pip/pip/lib/python3.7/site-packages/site-packages/site-packages/flask/app/app-app。 py”，第1516行，在full_dispatch_request rv = self.dispatch_request（）文件“/layers/google.python.pip/pip/pip/pip/lib/python3.7/site-packages/flask/flask/app.py返回self.ensure_sync（self.view_functions [rule.endpoint]）（** req.view_args）文件“/layers/google.python.pip/pip/pip/pip/pip/lib/python3.7/site-packages/site-packages/functions_framework/functions_framework/__init__.init__.py _.y.py” ，第171行，在view_func function（数据，上下文）中文件“/workspace/main.py”，第86行，在iri_data_sync源[“ files（name）”] attributeError：'资源'对象没有属性'get'

Answer 1

错误消息告诉您问题

'资源'对象没有属性'get'

而不是service.get service.files（）。get

source_file_name =service.files().get(fileId=fileId, fields="files(name)").execute()["files(name)"]
        

您实际上使用service.files（ ）.LIST您刚刚删除了使用Get请求忘记它。