要获取BigQuery查询所影响的行数,可以使用BigQuery的INFORMATION_SCHEMA
系统视图中的JOB_HISTORY
表。
以下是一个使用Python代码示例的解决方法:
from google.cloud import bigquery
# 初始化BigQuery客户端
client = bigquery.Client()
# 定义查询语句
query = '''
SELECT COUNT(*) AS num_rows_affected
FROM `project.dataset.table`
WHERE condition
'''
# 执行查询
query_job = client.query(query)
# 等待查询完成
query_job.result()
# 获取查询结果
result = query_job.destination.table_id
rows_affected = result.num_rows_affected
print(f"查询影响的行数:{rows_affected}")
请注意,您需要将project.dataset.table
替换为您要查询的实际数据集和表的名称,并将WHERE condition
替换为您要应用的实际过滤条件。在执行查询后,将等待查询完成并获取查询结果。最后,您可以使用num_rows_affected
属性来获取查询所影响的行数,并将其打印出来。