我正在工作的项目仍在使用google-api-python-client,它已被弃用,官方文档中也没有相应的示例。我已经让BigQuery使用它了,但是我似乎不知道如何设置configuration properties,特别是这样我就可以运行具有批处理优先级的查询。
有谁能给我指个方向吗?
发布于 2018-03-07 08:30:38
答案是使用jobs().insert()而不是jobs().query()。异步插入新作业使调用者能够指定广泛的选项,但需要它们运行另一个命令才能获得结果。
因此,假设gs是经过身份验证的服务对象:
# insert an asynchronous job
jobr = gs.jobs().insert(projectId='abc-123', body={'configuration':{'query':{'query':'SELECT COUNT(*) FROM schema.table'}}}).execute()
# get query results of job
gs.jobs().getQueryResults(projectId='abc-123', jobId=jobr['jobReference']['jobId']).execute()https://stackoverflow.com/questions/49140722
复制相似问题