【发布时间】:2017-08-14 01:15:30
【问题描述】:
我正在尝试使用 python BigQuery API 查询表并将结果存储在另一个 BigQuery 表中。但是当我在查询部分使用标准 SQL 时,它会抛出无效的表名错误。如何在 BigQuery API 中使用标准 SQL?我正在使用气流 BigQuery 挂钩
'configuration': {
'query': {
'destinationTable': {
'tableId': u 'our_table_name',
'datasetId': 'our_dataset_id',
'projectId': 'our_project_id'
},
'useLegacySql': False,
'allowLargeResults': True,
'writeDisposition': 'WRITE_TRUNCATE',
'query': u'SELECT * FROM `projectID.datasetId.tablename`',
}
}
Exception: BigQuery job failed. Final error was: {u'reason': u'invalid', u'message': u'Invalid table name: `projectId:datasetId.tableId`', u'location': u'`projectId:datasetId.tableId`'}.
【问题讨论】:
-
可以分享job id看看具体细节吗
-
@MoshaPasumansky 工作 ID:job_lIaunDu3LHrgwm_KDOoxwmH39xw
-
我也需要项目名称
-
@MoshaPasumansky 你得到项目 ID 了吗?
-
谢谢,我知道了 - 已发布答案。
标签: python google-bigquery google-api-python-client airflow