Загрузить данные из Google Cloud Storage в BigQuery с помощью Java

Question

Я хочу загрузить данные из Google Cloud Storage в таблицу в Big Query. Существует мой код, чтобы создать работу:

Job job = new Job(); 
    JobConfiguration config = new JobConfiguration(); 
    JobConfigurationLoad loadConfig = new JobConfigurationLoad(); 

    List<String> sources = new ArrayList<String>(); 
    sources.add("gs://bucket/file.cvs"); 
    loadConfig.setSourceUris(sources); 

    TableReference tableRef = new TableReference(); 
    tableRef.setDatasetId("DATASET_ID"); 
    tableRef.setTableId(TABLE_ID); 
    tableRef.setProjectId(PROJECT_ID); 
    loadConfig.setDestinationTable(tableRef); 

    List<TableFieldSchema> fields = FieldsBigQuery.schema(); 

    TableSchema schema = new TableSchema(); 
    schema.setFields(fields); 

    loadConfig.setSchema(schema); 
    config.setLoad(loadConfig); 
    job.setConfiguration(config); 

    Insert insert = _bigquery.jobs().insert(PROJECT_ID, job); 
    insert.setProjectId(PROJECT_ID); 
    JobReference jobRef = insert.execute().getJobReference(); 

у меня нет каких-либо ошибок или исключение, но это не загружать какие-либо данные в моей таблице (Таблица размера 0B). Я попытался создать таблицу без каких-либо данных и чем загрузить данные в эту таблицу, но это не так.

Я был бы признателен за любую помощь,

Большое спасибо!

Answer 1

Не забудьте проверить состояние работы с:

JobStatus status = 
    _bigquery.jobs().get(PROJECT_ID, jobRef.getJobId()).execute().getStatus(); 
System.out.println(status.toPrettyString()); 

Государственной работой может быть ОЖИДАНИЯ или RUNNING, если все работает хорошо, и вам придется ждать, пока это не сделано. Или вы сможете прочитать причину и сообщение о том, почему она не может быть запущена.