Wie eine lokale CSV-Upload große Abfrage Google Python mit

Question

Ich versuche, eine lokale CSV-Upload große Abfrage mit Python

def uploadCsvToGbq(self,table_name): 


    load_config = { 
    'destinationTable': { 
    'projectId': self.project_id, 
    'datasetId': self.dataset_id, 
    'tableId': table_name 
    } 
    } 

    load_config['schema'] = { 
    'fields': [ 
    {'name':'full_name', 'type':'STRING'}, 
    {'name':'age', 'type':'INTEGER'}, 
    ] 
    } 
    load_config['sourceFormat'] = 'CSV' 

    upload = MediaFileUpload('sample.csv', 
        mimetype='application/octet-stream', 
        # This enables resumable uploads. 
        resumable=True) 
    start = time.time() 
    job_id = 'job_%d' % start 
    # Create the job. 
    result = bigquery.jobs.insert(
    projectId=self.project_id, 
    body={ 
    'jobReference': { 
    'jobId': job_id 
    }, 
    'configuration': { 
    'load': load_config 
    } 
    }, 
    media_body=upload).execute() 

    return result 

wenn ich laufe dies wirft Fehler wie

"NameError: global name 'MediaFileUpload' is not defined"

to google

ob ein modul benötigt wird bitte helfen.

Answer 1

Die Klasse MediaFileUpload befindet sich in http.py. Siehe https://google-api-python-client.googlecode.com/hg/docs/epy/apiclient.http.MediaFileUpload-class.html

Answer 2

pip install --upgrade google-api-python-client 

Dann auf Ihre Python-Datei schreiben:

from googleapiclient.http import MediaFileUpload 

Aber kümmern Sie einige Klammer verpassen. Besser schreiben:

result = bigquery.jobs().insert(projectId=PROJECT_ID, body={'jobReference': {'jobId': job_id},'configuration': {'load': load_config}}, media_body=upload).execute(num_retries=5) 

Und übrigens, werden Sie alle Ihre CSV-Zeilen laden, darunter die Top-eine, die Spalten definiert.