如何使用Python删除或清空BigQuery中的表

pip install google-cloud-bigquery

from google.cloud import bigquery

# 创建BigQuery客户端
client = bigquery.Client()

# 设置要删除的表的信息
project_id = 'your_project_id'
dataset_id = 'your_dataset_id'
table_id = 'your_table_id'

# 构建完整的表名
table_ref = client.dataset(dataset_id, project=project_id).table(table_id)

# 删除表
try:
    client.delete_table(table_ref)
    print(f"Table {table_id} deleted.")
except Exception as e:
    print(f"Failed to delete table {table_id}: {e}")

from google.cloud import bigquery

# 创建BigQuery客户端
client = bigquery.Client()

# 设置要清空的表的信息
project_id = 'your_project_id'
dataset_id = 'your_dataset_id'
table_id = 'your_table_id'

# 构建完整的表名
table_ref = client.dataset(dataset_id, project=project_id).table(table_id)

# 创建SQL查询以清空表
sql = f"DELETE FROM `{table_ref}` WHERE TRUE"

# 执行SQL查询并设置truncate选项
job_config = bigquery.QueryJobConfig()
job_config.use_legacy_sql = False
job_config.destination = table_ref
job_config.write_disposition = bigquery.WriteDisposition.WRITE_TRUNCATE

query_job = client.query(sql, job_config=job_config)

# 等待查询完成
query_job.result()

print(f"Table {table_id} truncated.")