如何在BigQuery客户端Python API中以原子方式覆盖表

from google.cloud import bigquery
from google.cloud.bigquery import job

client = bigquery.Client()

def overwrite_table(client, dataset_id, table_id, source_table_id):
    # 获取目标表的引用
    table_ref = client.dataset(dataset_id).table(table_id)
    # 获取源表的引用
    source_table_ref = client.dataset(dataset_id).table(source_table_id)
    # 创建一个查询作业
    job_config = bigquery.QueryJobConfig()
    # 设置查询作业的目标表为目标表的引用
    job_config.destination = table_ref
    # 设置查询作业的覆盖模式为覆盖
    job_config.write_disposition = job.WriteDisposition.WRITE_TRUNCATE
    # 构建查询语句
    query = f"SELECT * FROM `{source_table_ref}`"
    # 运行查询作业
    query_job = client.query(query, job_config=job_config)
    # 等待查询作业完成
    query_job.result()

overwrite_table(client, 'your_dataset_id', 'your_table_id', 'your_source_table_id')