Http错误：使用jobs.query（）BQ API时缺少400个所需参数

Question

我在堆栈溢出中找不到完全相同的问题。抱歉，如果这是一个重复的问题。我使用此代码片段将查询传递给表。

_body = {'_query':'SELECT * FROM `<projectId>.<datasetId>.<tableId>`',
                   'useLegacySql': False,
                   'maxResults': 100                  
                   }

table = _bq.jobs().query(projectId= <projectId>,alt = "json", body = _body).execute()

我传递所有需要的参数，因为使用jobs.queryAPI，我得到状态代码200，与结果，但在Python程序中集成片段，我得到以下错误：

文件"D：\应用程序\Python27\lib\site-包\oAuth2Client\_helpers.py"，第133行，positional_wrapper\n返回包装（*args，**kwargs）\n'，'File"D：\应用程序\Python27\lib\site-包\googleapiclient\http.py"，行842，在执行\n提高HttpError（resp，内容，uri=self.uri）\n'，'HttpError：https://www.googleapis.com/bigquery/v2/projects/projectId/queries?alt=json返回"所需参数丢失"

Answer 1

您确实没有发送所需的参数。查看此示例以了解如何正确执行此操作：

def sync_query(service, project_id, query, timeout=10000, num_retries=5):
    query_data = {
                    'query': query,
                    'timeoutMs': timeout,
                 }
    return service.jobs().query(
            projectId=project_id,
            body=query_data).execute(num_retries=num_retries)

Answer 2

我不确定您在示例中使用的是哪个库，但我建议使用Python BigQuery客户端库。您将在其GitHub参考页面中找到完整的参考（以及大量示例）。

更具体地说，您将在这里找到一些关于如何使用Python客户端库查询数据的示例。

在安装客户端库并设置身份验证（这两个步骤在我共享的第一个链接中进行了解释）之后，您将能够执行一个脚本，如我下面介绍的脚本。在它中，一个公共数据集正在被查询，但是可以根据您的需要随意修改查询。

from google.cloud import bigquery

client = bigquery.Client()

# Define the query
query = "SELECT * FROM `bigquery-public-data.stackoverflow.posts_questions` LIMIT 10"

# Define the query job, by default uses Standard SQL
query_job = client.query(query)

results = query_job.result()  # Waits for job to complete.

for row in results:
    print("{}".format(row.title))

还请注意，此客户端库默认使用标准SQL（这是使用BigQuery的首选语言），但您始终可以通过调整QueryJobConfig来修改作业设置。

Answer 3

我相信问题不bq参数，但执行（）参数。它应该有超文本传输协议参数，您可以在其中提供超文本传输协议上下文和用户凭据

在appengine中，你可以这样做

SCOPE='https://www.googleapis.com/auth/bigquery https://www.googleapis.com/auth/cloud-patform '
_http = AppAssertionCredentials(scope=SCOPE).authorize(httplib2.Http(timeout=600))
table = _bq.jobs().query(projectId= <projectId>,alt = "json", body = _body).execute(http=_http)