2016-05-04 14 views
3

google bigquery v2 apiを使用してクエリジョブを実行し、別のbigqueryテーブルにクエリ結果セットを保存しようとしています。 v2 apiのgo wrapperでそれを行います。生のREST APIペイロードに宛先テーブルを指定する方法がありますが、それを外出先で動作させる必要があります。ここpackage bigquerygolang google-bigquery v2 api宛先表を指定する

答えて

3

参照文書は、以下の簡単な例です。これがあなたに正しい方向を与えることを願っています

import "google.golang.org/api/bigquery/v2" 

bigqueryService, err := bigquery.New(oauthHttpClient) 

if(err != nil) { 
    return "ERROR" 
} 

var projectId = "your-project" 
var datasetId = "your-dataset" 
var tableId = "your-table" 
var queryText = "your-query" 
var writeDisposition = "WRITE_TRUNCATE" 

job := &bigquery.Job{ 
    Configuration: &bigquery.JobConfiguration{ 
     Query: &bigquery.JobConfigurationQuery{ 
      DestinationTable: &bigquery.TableReference{ 
       DatasetId: datasetId, 
       ProjectId: projectId, 
       TableId: tableId, 
      }, 
      Query: queryText, 
      WriteDisposition: writeDisposition, 
     }, 
    }, 
} 

call := bigqueryService.Jobs.Insert(projectId, job) 
job, err2 := call.Do() 
if err2 != nil { 
    return "ERROR" 
} 

//check job status 
var jobid = job.JobReference.JobId 
bqjob, err3 := bigqueryService.Jobs.Get(projectId, jobid).Do() 
if(err3 != nil) { 
    return "ERROR" 
} 
+0

ありがとう、この解決策は役に立ちます –

+0

素晴らしい!答えがあなたの問題を解決するのに役立つならば、それを受け入れることを検討することができます。それを投票することも考慮する必要があります。 http://meter.stackexchange.com/questions/5234/how-does-accepting-an-answer-work#5235のhttp://stackoverflow.com/help/someone-answersおよびUpvoteセクションをご覧ください。 –

関連する問題