要执行BigQuery的DML操作,可以使用以下步骤:
from google.cloud import bigquery
# 创建BigQuery客户端
client = bigquery.Client()
query = """
INSERT INTO `project.dataset.table` (column1, column2)
VALUES ('value1', 'value2')
"""
query = """
UPDATE `project.dataset.table`
SET column1 = 'new_value'
WHERE column2 = 'condition'
"""
query = """
DELETE FROM `project.dataset.table`
WHERE column1 = 'condition'
"""
query()
方法来执行查询。以下是一个示例代码:# 执行DML查询
job = client.query(query)
# 等待查询完成
job.result()
job.result()
方法来获取查询结果,然后对结果进行处理。以下是一个示例代码:# 获取查询结果
result = job.result()
# 处理结果
for row in result:
print(row)
这些代码示例可以帮助你执行BigQuery的DML操作。请根据你的具体需求修改代码中的表名、列名、条件和值。