2017-12-20 4 views
0

Ich versuche, Daten aus einem Cloud Storage JSON in BigQuery zu laden.BigQuery-Fehler beim Laden von Daten aus Cloud Storage JSON

Ich benutze die BigQuery API.

Dies ist der Fehler, den ich habe:

TypeError: unbound method to_api_repr() must be called with LoadJobConfig instance as first argument (got nothing instead) 

Und das ist der Code:

from google.cloud import bigquery 


bigquery_client = bigquery.Client(project='test') 
table_ref = bigquery_client.dataset('test').table('test_table') 
GS_URL = 'gs://{}/raw/test/test.json'.format('bucket_test') 
job_id_prefix2 = 'copy_test' 
job_config2 = bigquery.LoadJobConfig 
job_config2.create_disposition = 'NEVER' 
job_config2.skip_leading_rows = 0 
job_config2.source_format = 'NEWLINE_DELIMITED_JSON' 
job_config2.write_disposition = 'WRITE_APPEND' 

load_job = bigquery_client.load_table_from_uri(
    GS_URL, 
    table_ref, 
    job_id="job", 
    job_id_prefix=job_id_prefix2, 
    job_config=job_config2) # API request 

assert load_job.state == 'RUNNING' 
assert load_job.job_type == 'load' 


load_job.result() # Waits for table load to complete. 


assert load_job.state == 'DONE' 
assert load_job.job_id.startswith(job_id_prefix2) 

Bin ich etwas fehlt? Irgendeine Hilfe?

Antwort

1

Wie für den Code, den Sie zur Verfügung gestellt haben, sehe ich einen Fehler, wo Sie ein paar Klammern vermissen, die sich auf diese LoadJobConfig beziehen, die Ihnen Probleme verursacht. Der Fehler ist in der folgenden Zeile:

job_config2 = bigquery.LoadJobConfig() 

Versuchen Sie das und Ihr Code sollte jetzt funktionieren. Weitere Informationen und Beispiele zum Laden von Dateien aus einem Cloud Storage-Bucket finden Sie in der offiziellen Dokumentation für die BigQuery Python API.

Verwandte Themen