通过 Python API 客户端将经过验证的查询发送到 BigQuery 时出现语法错误

Question

这是我的查询：

SELECT hits.page.pagePath
FROM [(project_id):(dataset_id).ga_sessions_20151019]
GROUP BY hits.page.pagePath LIMIT 1

它在 Web UI 中运行。

这是我的代码：

from oauth2client.service_account import ServiceAccountCredentials
from httplib2 import Http
from apiclient.discovery import build
import json

query = "SELECT hits.page.pagePath FROM [(project_id):(dataset_id).ga_sessions_20151019] GROUP BY hits.page.pagePath LIMIT 1",

path = (filepath of credentials json file)
scopes = ['https://www.googleapis.com/auth/bigquery']
credentials = ServiceAccountCredentials.from_json_keyfile_name(path,scopes)
http_auth = credentials.authorize(Http())
bigquery = build('bigquery','v2',http=http_auth)

req_body = {
    "timeoutMs": 60000,
    "kind": "bigquery#queryRequest",
    "dryRun": False,
    "useQueryCache": True,
    "useLegacySql": False,
    "maxResults": 100,
    "query": query,
    "preserveNulls": True,
  }

bigquery.jobs().query(projectId=(project_id),body=req_body).execute()

当我运行它时，我收到以下错误：

HttpError: <HttpError 400 when requesting https://www.googleapis.com/bigquery/v2/projects/cardinal-path/queries?alt=json returned "Syntax error: Unexpected "["">

它似乎不喜欢我的查询字符串中的括号，但我不知道如何转义它们（如果这是问题的话）。有谁看到我做错了什么？我不认为这是我与 API 的连接的问题，因为我可以通过调用服务对象的 ('bigquery'以上）jobs().list() 函数。谢谢！

Answer 1

我看到您在查询请求中将useLegacySql 设置为False。

像 [projectid:datasetid.tableid] 这样的括号引用文字是旧版 BigQuery SQL 方言的一部分。

新的 sql 方言使用反引号来引用文字。所以试试：

SELECT hits.page.pagePath FROM `project_id:dataset_id.ga_sessions_20151019` GROUP BY hits.page.pagePath LIMIT 1

另外，由于您将 project_id 作为您正在运行作业的项目传递，所有数据集查找将默认解析为该项目，因此您可以删除 projectid: 前缀并只使用 datasetid.tableid 像：

SELECT hits.page.pagePath FROM dataset_id.ga_sessions_20151019 GROUP BY hits.page.pagePath LIMIT 1

虽然这对于用户键入的查询很方便，但如果您的所有查询都是代码生成的，那么始终使用带引号的完全限定引用可能是最安全的。

更新：另一种选择是将 SQL 的标准点分隔符与非旧版 SQL 方言一起使用，即

SELECT hits.page.pagePath 
FROM project_id.dataset_id.ga_sessions_20151019
GROUP BY hits.page.pagePath LIMIT 1