python - 无法使用 BigQuery Python API 设置目标表

Question

我最近在使用 Python API 时收到以下 BigQuery 错误:

google.api_core.exceptions.BadRequest:无法为脚本 设置 400 configuration.query.destinationTable

这是我使用的功能:

def execute_bigquery_sql(query, dataset_id, table_id, use_legacy_sql=True, write_disposition='WRITE_TRUNCATE'):
    client = bigquery.Client()
    job_config = bigquery.QueryJobConfig()
    job_config.use_legacy_sql = use_legacy_sql

    print("table_id: {table_id}".format(table_id=table_id))
    print("dataset_id: {dataset_id}".format(dataset_id=dataset_id))

    if table_id:
        table_ref = client.dataset(dataset_id).table(table_id)
        print("table_ref: {table_ref}".format(table_ref=table_ref))
        job_config.destination = table_ref
        job_config.write_disposition = write_disposition
        job_config.allow_large_results = True
        job_config.createDisposition = "CREATE_IF_NEEDED"

    query_job = client.query(query,job_config=job_config)
    results = query_job.result()  # Waits for job to complete.

有谁知道可能会发生什么和解决方法？

Answer 1

感谢您的回复，评论确实是在正确的方向。在 BigQuery 脚本中意味着 https://cloud.google.com/bigquery/docs/reference/standard-sql/scripting.

这是不允许的，我的查询有:

DECLARE capital int64 default 10000000;

因此，在我的情况下，删除上面的行是解决方法。

有趣的是，即使在 Web 界面中

如果您使用脚本，界面将不允许保存到表:

相比之下，当不使用脚本语句时，您应该看到: