首页 > 解决方案 > BigQuery:如何使用 bigquery.Client().copy_table 方法覆盖表

问题描述

这是我用作https://cloud.google.com/bigquery/docs/managing-tables#bigquery-copy-table-python参考的代码:

source_dataset = client.dataset('samples', project='bigquery-public-data')
source_table_ref = source_dataset.table('shakespeare')

# dataset_id = 'my_dataset'
dest_table_ref = client.dataset(dataset_id).table('destination_table')

job = client.copy_table(
    source_table_ref,
    dest_table_ref,
    # Location must match that of the source and destination tables.
    location='US')  # API request

job.result()  # Waits for job to complete.

在我的情况下,目标表存在,我收到此错误:

Already Exists

如何用这个 copy_table 方法覆盖?在 bq 命令行中,我可以使用 -f 选项。所以我正在寻找相同的标志。

标签: google-bigquery

解决方案


您需要将作业配置传递给请求,如下所示:

job_config = bigquery.CopyJobConfig()
job_config.write_disposition = "WRITE_TRUNCATE"
job = client.copy_table(
    source_table_ref,
    dest_table_ref,
    location='US',
    job_config=job_config)  # API request

更多文档在这里:https ://googleapis.github.io/google-cloud-python/latest/bigquery/generated/google.cloud.bigquery.client.Client.copy_table.html


推荐阅读