使 iPython BigQuery Magic Function SQL 查询动态化

【问题标题】：Making iPython BigQuery Magic Function SQL query dynamic使 iPython BigQuery Magic Function SQL 查询动态化
【发布时间】：2020-02-20 17:29:19
【问题描述】：

我在 Jupyter 中使用 bigquery 魔术功能，希望能够动态更改项目和数据集。例如

代替

%%bigquery table
SELECT * FROM `my_project.my_dataset.my_table`

我想要

project = my_project
dataset = my_dataset

%%bigquery table
'SELECT * FROM `{}.{}.my_table`'.format(project,dataset)

【问题讨论】：

标签： google-bigquery ipython magic-function

【解决方案1】：

根据IPython Magics for BigQuery 文档，无法将项目或数据集作为参数传递；不过，您可以使用 BigQuery 客户端库在 Jupyter Notebook 中执行此操作。

from google.cloud import bigquery

client = bigquery.Client()  

project = 'bigquery-public-data'
dataset = 'baseball'

sql ="""SELECT * FROM `{}.{}.games_wide` LIMIT 10"""
query=sql.format(project,dataset)

query_job = client.query(query)

print("The query data:")

for row in query_job:
# Row values can be accessed by field name or index.
print("gameId={}, seasonId={}".format(row[0], row["gameId"]))

我还建议您查看公共文档以了解如何visualize BigQuery data in a Jupyter notebooks。

【讨论】：