1 回答
TA贡献1802条经验 获得超4个赞
请参阅此处的文档包 bigquery
下面是一个简单的例子。希望这会给你正确的方向
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"
}
- 1 回答
- 0 关注
- 126 浏览
添加回答
举报