以下是一个示例代码,演示了如何在BigQuery中使用循环和插入数据:
from google.cloud import bigquery
# 创建BigQuery客户端
client = bigquery.Client()
# 定义要插入的数据
data = [
{"name": "John", "age": 30},
{"name": "Jane", "age": 25},
{"name": "Bob", "age": 35}
]
# 定义要插入数据的表格和数据集
dataset_id = 'your_dataset_id'
table_id = 'your_table_id'
# 创建一个空的插入请求
insert_rows = []
# 构建插入请求的数据
for row in data:
insert_rows.append(row)
# 将数据插入到表格中
errors = client.insert_rows_json(
f"{client.project}.{dataset_id}.{table_id}",
insert_rows,
)
# 检查插入是否成功
if errors == []:
print("数据插入成功")
else:
print(f"数据插入失败:{errors}")
请确保已安装Google Cloud SDK,并使用有效的项目和数据集ID替换示例代码中的your_dataset_id
和your_table_id
。此代码将循环遍历data
列表中的每个字典,并将其插入到指定的BigQuery表格中。如果插入成功,将打印"数据插入成功",否则将打印错误消息。