要在BigQuery中批量删除数据传输操作,需要使用以下代码示例:
from google.cloud import bigquery
client = bigquery.Client()
# 定义要删除的数据传输操作ID列表
job_ids = ["transfer_job_1", "transfer_job_2", "transfer_job_3"]
for job_id in job_ids:
# 获取传输操作
transfer_config = client.get_transfer_config(job_id)
# 如果传输操作存在,则删除
if transfer_config:
client.delete_transfer_config(job_id)
代码中,我们首先导入BigQuery Python API的客户端库。然后,定义要删除的数据传输操作的ID列表。接下来,我们遍历ID列表,使用client.get_transfer_config()
方法获取传输操作,并检查其是否存在。如果存在,则使用client.delete_transfer_config()
方法删除该传输操作。
注意,删除传输操作并不会删除传输作业中已经复制到目标位置的数据。如果要删除已复制的数据,请使用其他方法,如删除目标表或目录。